Path	Lines of Code
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/BufferPackSuitJ.java	203
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java	101
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/PartitionSortedBufferSuitJ.java	275
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/PluginSideConfSuiteJ.java	36
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGateSuiteJ.java	68
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerTest.java	97
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfoSuitJ.java	33
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/UnpackSuiteJ.java	54
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplierSuiteJ.java	90
client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterTest.java	210
client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.14/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java	38
client-flink/flink-1.14/src/test/resources/log4j2-test.xml	24
client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterTest.java	210
client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.15/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java	38
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterTest.java	236
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java	38
client-spark/common/src/test/java/org/apache/spark/shuffle/celeborn/PackedRecordPointerSuiteJ.java	80
client-spark/common/src/test/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorterSuiteJ.java	113
client-spark/common/src/test/java/org/apache/spark/shuffle/celeborn/SortBasedPusherSuiteJ.java	98
client-spark/common/src/test/resources/log4j2-test.xml	24
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/CelebornShuffleWriterSuiteBase.java	286
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriterSuiteJ.java	16
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriterSuiteJ.java	22
client-spark/spark-2/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleManagerSuite.scala	44
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/CelebornShuffleWriterSuiteBase.java	295
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriterSuiteJ.java	20
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriterSuiteJ.java	20
client-spark/spark-3/src/test/resources/log4j2-test.xml	24
client-spark/spark-3/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleManagerSuite.scala	44
client/src/test/java/org/apache/celeborn/client/DummyShuffleClient.java	124
client/src/test/java/org/apache/celeborn/client/ShuffleClientBaseSuiteJ.java	78
client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java	260
client/src/test/java/org/apache/celeborn/client/compress/CodecSuiteJ.java	39
client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuiteJ.java	125
client/src/test/resources/log4j2-test.xml	24
client/src/test/scala/org/apache/celeborn/client/WithShuffleClientSuite.scala	116
client/src/test/scala/org/apache/celeborn/client/WorkerStatusTrackerSuite.scala	68
common/src/test/java/org/apache/celeborn/common/client/MasterClientSuiteJ.java	294
common/src/test/java/org/apache/celeborn/common/meta/DiskStatusSuiteJ.java	14
common/src/test/java/org/apache/celeborn/common/network/RpcIntegrationSuiteJ.java	259
common/src/test/java/org/apache/celeborn/common/network/StreamTestHelper.java	75
common/src/test/java/org/apache/celeborn/common/network/TestManagedBuffer.java	72
common/src/test/java/org/apache/celeborn/common/network/TransportClientFactorySuiteJ.java	147
common/src/test/java/org/apache/celeborn/common/network/TransportResponseHandlerSuiteJ.java	134
common/src/test/java/org/apache/celeborn/common/protocol/PartitionLocationSuiteJ.java	209
common/src/test/java/org/apache/celeborn/common/unsafe/PlatformUtilSuite.java	63
common/src/test/java/org/apache/celeborn/common/util/JavaUtilsSuite.java	14
common/src/test/java/org/apache/celeborn/common/write/SlowStartPushStrategyTest.java	93
common/src/test/resources/log4j2-test.xml	24
common/src/test/resources/test-quota.yaml	10
common/src/test/scala/org/apache/celeborn/CelebornFunSuite.scala	134
common/src/test/scala/org/apache/celeborn/ConfigurationSuite.scala	121
common/src/test/scala/org/apache/celeborn/ThreadAudit.scala	38
common/src/test/scala/org/apache/celeborn/benchmark/Benchmark.scala	147
common/src/test/scala/org/apache/celeborn/benchmark/BenchmarkBase.scala	43
common/src/test/scala/org/apache/celeborn/benchmark/Benchmarks.scala	60
common/src/test/scala/org/apache/celeborn/common/CelebornConfSuite.scala	171
common/src/test/scala/org/apache/celeborn/common/ComputeIfAbsentBenchmark.scala	37
common/src/test/scala/org/apache/celeborn/common/HAConfSuite.scala	67
common/src/test/scala/org/apache/celeborn/common/identity/UserIdentifierSuite.scala	35
common/src/test/scala/org/apache/celeborn/common/meta/DeviceInfoSuite.scala	19
common/src/test/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfoSuite.scala	57
common/src/test/scala/org/apache/celeborn/common/meta/TimeWindowSuite.scala	22
common/src/test/scala/org/apache/celeborn/common/meta/WorkerInfoSuite.scala	261
common/src/test/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfoSuite.scala	48
common/src/test/scala/org/apache/celeborn/common/metrics/source/CelebornSourceSuite.scala	61
common/src/test/scala/org/apache/celeborn/common/quota/BaseQuotaManagerSuite.scala	5
common/src/test/scala/org/apache/celeborn/common/quota/DefaultQuotaManagerSuite.scala	25
common/src/test/scala/org/apache/celeborn/common/quota/QuotaSuite.scala	38
common/src/test/scala/org/apache/celeborn/common/util/PbSerDeUtilsTest.scala	136
common/src/test/scala/org/apache/celeborn/common/util/UtilsSuite.scala	140
master/src/test/java/org/apache/celeborn/service/deploy/master/SlotsAllocatorRackAwareSuiteJ.java	100
master/src/test/java/org/apache/celeborn/service/deploy/master/SlotsAllocatorSuiteJ.java	284
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/DefaultMetaSystemSuiteJ.java	524
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterRatisServerSuiteJ.java	24
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterStateMachineSuiteJ.java	232
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/RatisBaseSuiteJ.java	33
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/RatisMasterStatusSystemSuiteJ.java	793
master/src/test/resources/log4j2-test.xml	24
master/src/test/scala/org/apache/celeborn/service/deploy/master/AppDiskUsageMetricSuite.scala	73
master/src/test/scala/org/apache/celeborn/service/deploy/master/MasterArgumentsSuite.scala	27
master/src/test/scala/org/apache/celeborn/service/deploy/master/MasterSuite.scala	36
master/src/test/scala/org/apache/celeborn/service/deploy/master/network/CelebornRackResolverSuite.scala	59
tests/flink-it/pom.xml	83
tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/WordCountHelper.java	65
tests/flink-it/src/test/resources/log4j2-test.xml	24
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/HeartbeatTest.scala	52
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala	63
tests/kubernetes-it/docker/helm/values.yaml	79
tests/kubernetes-it/pom.xml	52
tests/kubernetes-it/src/test/resources/log4j2-test.xml	20
tests/kubernetes-it/src/test/scala/org.apache.celeborn.integration/DeploySuite.scala	31
tests/kubernetes-it/src/test/scala/org.apache.celeborn.integration/WithMiniKube.scala	9
tests/spark-it/pom.xml	136
tests/spark-it/src/test/resources/log4j2-test.xml	24
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/ShuffleClientSuite.scala	39
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornHashCheckDiskSuite.scala	68
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornHashSuite.scala	40
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornNonPipelineSortSuite.scala	43
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornPipelineSortSuite.scala	34
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/HeartbeatTest.scala	34
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/HugeDataTest.scala	31
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/PushDataTimeoutTest.scala	111
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/RetryCommitFilesTest.scala	35
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/RetryReviveTest.scala	34
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ShuffleFallbackSuite.scala	34
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SkewJoinSuite.scala	83
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SlotsAssignMaxWorkersLargeTest.scala	35
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SlotsAssignMaxWorkersSmallTest.scala	36
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SparkTestBase.scala	67
tests/spark-it/src/test/scala/org/apache/spark/SparkContextHelper.scala	7
worker/src/test/java/org/apache/celeborn/service/deploy/worker/WorkerSuiteJ.java	16
worker/src/test/java/org/apache/celeborn/service/deploy/worker/WorkingPartitionSuiteJ.java	47
worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java	106
worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestTimeSlidingHub.java	82
worker/src/test/java/org/apache/celeborn/service/deploy/worker/network/RequestTimeoutIntegrationSuiteJ.java	197
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/ChunkFetchIntegrationSuiteJ.java	200
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManagerSuiteJ.java	35
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManagerSuiteJ.java	98
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/FileWriterSuiteJ.java	634
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionFileWriterSuiteJ.java	141
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorterSuiteJ.java	168
worker/src/test/resources/log4j2-test.xml	24
worker/src/test/scala/org/apache/celeborn/service/deploy/HeartbeatFeature.scala	115
worker/src/test/scala/org/apache/celeborn/service/deploy/MiniClusterFeature.scala	105
worker/src/test/scala/org/apache/celeborn/service/deploy/WorkerArgumentsSuite.scala	24
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ClusterReadWriteTestWithLZ4.scala	7
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ClusterReadWriteTestWithNONE.scala	7
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ClusterReadWriteTestWithZSTD.scala	7
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala	79
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitorSuite.scala	355
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/WorkerSuite.scala	84