Path	Lines of Code
charts/celeborn/tests/configmap_test.yaml	18
charts/celeborn/tests/master/podmonitor_test.yaml	63
charts/celeborn/tests/master/priorityclass_test.yaml	30
charts/celeborn/tests/master/service_test.yaml	59
charts/celeborn/tests/master/statefulset_test.yaml	266
charts/celeborn/tests/role_test.yaml	37
charts/celeborn/tests/rolebinding_test.yaml	30
charts/celeborn/tests/serviceaccount_test.yaml	22
charts/celeborn/tests/worker/podmonitor_test.yaml	63
charts/celeborn/tests/worker/priorityclass_test.yaml	30
charts/celeborn/tests/worker/service_test.yaml	25
charts/celeborn/tests/worker/statefulset_test.yaml	265
cli/src/test/scala/org/apache/celeborn/cli/TestCelebornCliCommands.scala	239
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/BufferPackSuiteJ.java	357
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/FlinkShuffleClientImplSuiteJ.java	102
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/PluginSideConfSuiteJ.java	30
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/ShuffleTaskInfoSuiteJ.java	33
client-flink/common/src/test/java/org/apache/celeborn/plugin/flink/SortBasedDataBufferSuiteJ.java	276
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	226
client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	307
client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuitJ.java	38
client-flink/flink-1.16/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	99
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	319
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
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/RemoteShuffleServiceFactorySuiteJ.java	38
client-flink/flink-1.17/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	99
client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	319
client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuiteJ.java	38
client-flink/flink-1.18/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	99
client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	320
client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	517
client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuiteJ.java	38
client-flink/flink-1.19/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	99
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	331
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	520
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuiteJ.java	38
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	110
client-flink/flink-1.20/src/test/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgentSuiteJ.java	155
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleMasterSuiteJ.java	331
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactorySuiteJ.java	28
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionSuiteJ.java	520
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactorySuiteJ.java	38
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/ShuffleResourceTrackerSuiteJ.java	110
client-flink/flink-2.0/src/test/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgentSuiteJ.java	156
client-spark/common/src/test/java/org/apache/spark/shuffle/celeborn/PackedRecordPointerSuiteJ.java	78
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	101
client-spark/common/src/test/java/org/apache/spark/shuffle/celeborn/SparkCommonUtilsSuiteJ.java	9
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	22
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/ShuffleManagerHook.java	14
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriterSuiteJ.java	22
client-spark/spark-2/src/test/java/org/apache/spark/shuffle/celeborn/TestCelebornShuffleManager.java	22
client-spark/spark-2/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleManagerSuite.scala	69
client-spark/spark-3-columnar-shuffle/src/test/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriterSuiteJ.java	105
client-spark/spark-3-columnar-shuffle/src/test/resources/log4j2-test.xml	24
client-spark/spark-3-columnar-shuffle/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReaderSuite.scala	98
client-spark/spark-3.5-columnar-shuffle/src/test/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriterSuiteJ.java	105
client-spark/spark-3.5-columnar-shuffle/src/test/resources/log4j2-test.xml	24
client-spark/spark-3.5-columnar-shuffle/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReaderSuite.scala	98
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/CelebornPartitionUtilSuiteJ.java	154
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/CelebornShuffleWriterSuiteBase.java	304
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriterSuiteJ.java	26
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/ShuffleManagerHook.java	14
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriterSuiteJ.java	168
client-spark/spark-3/src/test/java/org/apache/spark/shuffle/celeborn/TestCelebornShuffleManager.java	43
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	91
client-spark/spark-3/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReaderSuite.scala	64
client-spark/spark-4-columnar-shuffle/src/test/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriterSuiteJ.java	105
client-spark/spark-4-columnar-shuffle/src/test/resources/log4j2-test.xml	24
client-spark/spark-4-columnar-shuffle/src/test/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReaderSuite.scala	98
client/src/test/java/org/apache/celeborn/client/ShuffleClientBaseSuiteJ.java	78
client/src/test/java/org/apache/celeborn/client/ShuffleClientSuiteJ.java	531
client/src/test/java/org/apache/celeborn/client/compress/CodecSuiteJ.java	40
client/src/test/java/org/apache/celeborn/client/write/DataPushQueueSuiteJ.java	124
client/src/test/resources/log4j2-test.xml	24
client/src/test/scala/org/apache/celeborn/client/WithShuffleClientSuite.scala	152
client/src/test/scala/org/apache/celeborn/client/WorkerStatusTrackerSuite.scala	72
common/src/test/java/org/apache/celeborn/common/client/MasterClientSuiteJ.java	359
common/src/test/java/org/apache/celeborn/common/meta/DiskStatusSuiteJ.java	14
common/src/test/java/org/apache/celeborn/common/network/AutoSSLRpcIntegrationSuite.java	28
common/src/test/java/org/apache/celeborn/common/network/RpcIntegrationSuiteJ.java	203
common/src/test/java/org/apache/celeborn/common/network/SSLRpcIntegrationSuiteJ.java	23
common/src/test/java/org/apache/celeborn/common/network/SSLTransportClientFactorySuiteJ.java	25
common/src/test/java/org/apache/celeborn/common/network/StreamTestHelper.java	75
common/src/test/java/org/apache/celeborn/common/network/TestHelper.java	30
common/src/test/java/org/apache/celeborn/common/network/TestManagedBuffer.java	76
common/src/test/java/org/apache/celeborn/common/network/TransportClientFactorySuiteJ.java	203
common/src/test/java/org/apache/celeborn/common/network/TransportResponseHandlerSuiteJ.java	134
common/src/test/java/org/apache/celeborn/common/network/protocol/EncryptedMessageWithHeaderSuiteJ.java	98
common/src/test/java/org/apache/celeborn/common/network/sasl/CelebornSaslSuiteJ.java	97
common/src/test/java/org/apache/celeborn/common/network/sasl/RegistrationSuiteJ.java	81
common/src/test/java/org/apache/celeborn/common/network/sasl/SaslTestBase.java	111
common/src/test/java/org/apache/celeborn/common/network/server/TransportRequestHandlerSuiteJ.java	55
common/src/test/java/org/apache/celeborn/common/network/ssl/ReloadingX509TrustManagerSuiteJ.java	188
common/src/test/java/org/apache/celeborn/common/network/ssl/SSLUtilsSuite.java	35
common/src/test/java/org/apache/celeborn/common/network/ssl/SslConnectivitySuiteJ.java	318
common/src/test/java/org/apache/celeborn/common/network/ssl/SslSampleConfigs.java	189
common/src/test/java/org/apache/celeborn/common/network/util/TransportConfSuiteJ.java	113
common/src/test/java/org/apache/celeborn/common/protocol/PartitionLocationSuiteJ.java	213
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/util/ShuffleBlockInfoUtilsTest.java	101
common/src/test/java/org/apache/celeborn/common/write/PushFailedBatchSuiteJ.java	52
common/src/test/java/org/apache/celeborn/common/write/SlowStartPushStrategyTest.java	93
common/src/test/resources/log4j2-test.xml	24
common/src/test/resources/ssl/generate_certs.sh	25
common/src/test/scala/org/apache/celeborn/CelebornFunSuite.scala	134
common/src/test/scala/org/apache/celeborn/ConfigurationSuite.scala	123
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	389
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/client/MasterEndpointResolverSuite.scala	54
common/src/test/scala/org/apache/celeborn/common/client/StaticMasterEndpointResolverSuite.scala	47
common/src/test/scala/org/apache/celeborn/common/identity/DefaultIdentityProviderSuite.scala	25
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	58
common/src/test/scala/org/apache/celeborn/common/meta/TimeWindowSuite.scala	22
common/src/test/scala/org/apache/celeborn/common/meta/WorkerInfoSuite.scala	374
common/src/test/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfoSuite.scala	48
common/src/test/scala/org/apache/celeborn/common/metrics/ResettableSlidingWindowReservoirSuite.scala	16
common/src/test/scala/org/apache/celeborn/common/metrics/source/CelebornSourceSuite.scala	83
common/src/test/scala/org/apache/celeborn/common/metrics/source/JVMSourceSuite.scala	30
common/src/test/scala/org/apache/celeborn/common/network/CelebornRackResolverSuite.scala	106
common/src/test/scala/org/apache/celeborn/common/rpc/RpcAddressSuite.scala	32
common/src/test/scala/org/apache/celeborn/common/rpc/RpcEnvSuite.scala	656
common/src/test/scala/org/apache/celeborn/common/rpc/RpcSecurityContextSuite.scala	97
common/src/test/scala/org/apache/celeborn/common/rpc/TestRpcEndpoint.scala	72
common/src/test/scala/org/apache/celeborn/common/rpc/netty/InboxSuite.scala	127
common/src/test/scala/org/apache/celeborn/common/rpc/netty/NettyRpcAddressSuite.scala	13
common/src/test/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnvSuite.scala	126
common/src/test/scala/org/apache/celeborn/common/rpc/netty/NettyRpcHandlerSuite.scala	36
common/src/test/scala/org/apache/celeborn/common/rpc/netty/SSLNettyRpcEnvSuite.scala	22
common/src/test/scala/org/apache/celeborn/common/util/PbSerDeUtilsTest.scala	561
common/src/test/scala/org/apache/celeborn/common/util/UtilsSuite.scala	214
cpp/celeborn/client/tests/WorkerPartitionReaderTest.cpp	179
cpp/celeborn/conf/tests/BaseConfTest.cpp	126
cpp/celeborn/conf/tests/CelebornConfTest.cpp	72
cpp/celeborn/memory/tests/ByteBufferTest.cpp	170
cpp/celeborn/network/tests/FrameDecoderTest.cpp	91
cpp/celeborn/network/tests/MessageDispatcherTest.cpp	152
cpp/celeborn/network/tests/MessageTest.cpp	130
cpp/celeborn/network/tests/NettyRpcEndpointRefTest.cpp	85
cpp/celeborn/network/tests/TransportClientTest.cpp	204
cpp/celeborn/protocol/tests/ControlMessagesTest.cpp	200
cpp/celeborn/protocol/tests/PartitionLocationTest.cpp	78
cpp/celeborn/protocol/tests/TransportMessageTest.cpp	35
cpp/celeborn/tests/DataSumWithReaderClient.cpp	58
cpp/celeborn/utils/tests/ExceptionTest.cpp	793
master/src/test/java/org/apache/celeborn/service/deploy/master/SlotsAllocatorJmhBenchmark.java	59
master/src/test/java/org/apache/celeborn/service/deploy/master/SlotsAllocatorRackAwareSuiteJ.java	383
master/src/test/java/org/apache/celeborn/service/deploy/master/SlotsAllocatorSuiteJ.java	434
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/DefaultMetaSystemSuiteJ.java	824
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/GrpcRatisMasterStatusSystemSuiteJ.java	16
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	465
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	1406
master/src/test/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/SSLRatisMasterStatusSystemSuiteJ.java	111
master/src/test/resources/dynamicConfig-quota-2.yaml	18
master/src/test/resources/dynamicConfig-quota-3.yaml	18
master/src/test/resources/dynamicConfig-quota.yaml	17
master/src/test/resources/dynamicConfig-tags.yaml	21
master/src/test/resources/log4j2-test.xml	24
master/src/test/scala/org/apache/celeborn/service/deploy/master/ApiMasterResourceAuthenticationSuite.scala	16
master/src/test/scala/org/apache/celeborn/service/deploy/master/MasterArgumentsSuite.scala	27
master/src/test/scala/org/apache/celeborn/service/deploy/master/MasterClusterFeature.scala	127
master/src/test/scala/org/apache/celeborn/service/deploy/master/MasterSuite.scala	123
master/src/test/scala/org/apache/celeborn/service/deploy/master/http/api/ApiMasterResourceSuite.scala	63
master/src/test/scala/org/apache/celeborn/service/deploy/master/http/api/TestMasterHttpResourceUtils.scala	16
master/src/test/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApiV1MasterResourceSuite.scala	94
master/src/test/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManagerSuite.scala	615
master/src/test/scala/org/apache/celeborn/service/deploy/master/tags/TagsManagerSuite.scala	140
service/src/test/java/org/apache/celeborn/server/common/service/config/ConfigServiceSuiteJ.java	274
service/src/test/resources/celeborn-0.6.0-h2-ut-data.sql	36
service/src/test/resources/celeborn-0.6.0-h2.sql	55
service/src/test/resources/dynamicConfig.yaml	47
service/src/test/resources/dynamicConfig_2.yaml	10
service/src/test/scala/org/apache/celeborn/server/common/container/ContainerInfoSuite.scala	13
service/src/test/scala/org/apache/celeborn/server/common/http/ApiBaseResourceAuthenticationSuite.scala	115
service/src/test/scala/org/apache/celeborn/server/common/http/ApiBaseResourceSuite.scala	73
service/src/test/scala/org/apache/celeborn/server/common/http/HttpTestHelper.scala	47
service/src/test/scala/org/apache/celeborn/server/common/http/api/v1/ApiV1BaseResourceSuite.scala	87
service/src/test/scala/org/apache/celeborn/server/common/http/authentication/UserDefinePasswordAuthenticationProviderImpl.scala	21
service/src/test/scala/org/apache/celeborn/server/common/http/authentication/UserDefineTokenAuthenticationProviderImpl.scala	20
tests/flink-it/pom.xml	77
tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/FlinkVersion.java	40
tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/JobGraphRunningHelper.java	41
tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/SplitHelper.java	52
tests/flink-it/src/test/java/org/apache/celeborn/tests/flink/WordCountHelper.java	70
tests/flink-it/src/test/resources/log4j2-test.xml	24
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/HeartbeatTest.scala	55
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/HybridShuffleWordCountTest.scala	131
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/SplitTest.scala	52
tests/flink-it/src/test/scala/org/apache/celeborn/tests/flink/WordCountTest.scala	96
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	30
tests/kubernetes-it/src/test/scala/org.apache.celeborn.integration/WithMiniKube.scala	9
tests/mr-it/pom.xml	156
tests/mr-it/src/test/resources/log4j2-test.xml	24
tests/mr-it/src/test/scala/org/apache/celeborn/tests/mr/WordCountTest.scala	197
tests/spark-it/pom.xml	222
tests/spark-it/src/test/resources/log4j2-test.xml	24
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/ChangePartitionManagerUpdateWorkersSuite.scala	368
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerCommitFilesSuite.scala	243
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerDestroySlotsSuite.scala	135
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerReserveSlotsSuite.scala	128
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerSetupEndpointSuite.scala	56
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerSuite.scala	70
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/LifecycleManagerUnregisterShuffleSuite.scala	89
tests/spark-it/src/test/scala/org/apache/celeborn/tests/client/ShuffleClientSuite.scala	42
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornFetchFailureSuite.scala	327
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornHashCheckDiskSuite.scala	65
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornHashSuite.scala	76
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornSortSuite.scala	78
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/CelebornStageRerunSuite.scala	43
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	114
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/PushFailedBatchSuite.scala	57
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/RetryReviveTest.scala	57
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ReusedExchangeSuite.scala	67
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/ShuffleFallbackSuite.scala	52
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SkewJoinSuite.scala	89
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SlotsAssignMaxWorkersLargeTest.scala	34
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SlotsAssignMaxWorkersSmallTest.scala	35
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/SparkTestBase.scala	124
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/memory/MemorySkewJoinSuite.scala	122
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/memory/MemorySparkTestBase.scala	39
tests/spark-it/src/test/scala/org/apache/celeborn/tests/spark/memory/MemoryStorageReusedExchangeSuite.scala	58
tests/spark-it/src/test/scala/org/apache/spark/SparkContextHelper.scala	7
tests/spark-it/src/test/scala/org/apache/spark/shuffle/celeborn/SparkUtilsSuite.scala	178
tests/tez-it/pom.xml	301
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/BroadcastAndOneToOneExample.java	225
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/BroadcastAndOneToOneTest.scala	12
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezCartesianProductTest.scala	42
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezHashJoinBroadcastTest.scala	15
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezHashJoinTest.scala	14
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezIntegrationTestBase.scala	246
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezJoinIntegrationTestBase.scala	50
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezOrderedWordCountTest.scala	46
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezSortMergeJoinTest.scala	16
tests/tez-it/src/test/java/org/apache/celeborn/tests/tez/TezWordCountTest.scala	38
tests/tez-it/src/test/resources/log4j2.xml	13
tests/tez-it/src/test/resources/tez-site.xml	4
worker/src/test/java/org/apache/celeborn/service/deploy/worker/FetchHandlerSuiteJ.java	405
worker/src/test/java/org/apache/celeborn/service/deploy/worker/WorkerSecretRegistryImplSuiteJ.java	52
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	49
worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestCongestionController.java	273
worker/src/test/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TestTimeSlidingHub.java	84
worker/src/test/java/org/apache/celeborn/service/deploy/worker/network/RequestTimeoutIntegrationSuiteJ.java	235
worker/src/test/java/org/apache/celeborn/service/deploy/worker/network/SSLRequestTimeoutIntegrationSuiteJ.java	26
worker/src/test/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBProviderSuiteJ.java	51
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/ChunkFetchIntegrationSuiteJ.java	234
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	105
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriterSuiteUtils.java	208
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/SSLChunkFetchIntegrationSuiteJ.java	24
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/SSLReducePartitionDataWriterSuiteJ.java	25
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/local/DiskMapPartitionDataWriterSuiteJ.java	148
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/local/DiskPartitionFilesSorterSuiteJ.java	180
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/local/DiskReducePartitionDataWriterSuiteJ.java	780
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/memory/MemoryPartitionFilesSorterSuiteJ.java	126
worker/src/test/java/org/apache/celeborn/service/deploy/worker/storage/memory/MemoryReducePartitionDataWriterSuiteJ.java	866
worker/src/test/resources/dynamicConfig.yaml	4
worker/src/test/resources/dynamicConfig_2.yaml	13
worker/src/test/resources/log4j2-test.xml	24
worker/src/test/scala/org/apache/celeborn/service/deploy/HeartbeatFeature.scala	110
worker/src/test/scala/org/apache/celeborn/service/deploy/MiniClusterFeature.scala	262
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/JavaReadCppWriteTestBase.scala	104
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/JavaReadCppWriteTestWithNONE.scala	7
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/LocalReadByChunkOffsetsTest.scala	145
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/LocalReadWriteTestWithLZ4.scala	7
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/PushMergedDataSplitSuite.scala	124
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestBase.scala	129
worker/src/test/scala/org/apache/celeborn/service/deploy/cluster/ReadWriteTestWithFailures.scala	104
worker/src/test/scala/org/apache/celeborn/service/deploy/memory/MemoryManagerSuite.scala	215
worker/src/test/scala/org/apache/celeborn/service/deploy/memory/ReadBufferDispactherSuite.scala	52
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/WorkerStatusManagerSuite.scala	51
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/WorkerSuite.scala	235
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/http/api/ApiWorkerResourceSuite.scala	43
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApiV1OpenapiClientSuite.scala	82
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApiV1WorkerOpenapiClientSuite.scala	60
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApiV1WorkerResourceSuite.scala	50
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/monitor/JVMQuakeSuite.scala	42
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/ApiWorkerResourceAuthenticationSuite.scala	20
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitorSuite.scala	386
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/PartitionMetaHandlerSuite.scala	155
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManagerSuite.scala	68
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriterSuite.scala	243
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/WriterUtils.scala	33
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/storagePolicy/StoragePolicyCase1.scala	89
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/storagePolicy/StoragePolicyCase2.scala	89
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/storagePolicy/StoragePolicyCase3.scala	92
worker/src/test/scala/org/apache/celeborn/service/deploy/worker/storage/storagePolicy/StoragePolicyCase4.scala	90