Path Lines of Code cli/src/test/java/org/apache/uniffle/cli/AdminRestApiTest.java 32 cli/src/test/java/org/apache/uniffle/cli/CLIContentUtilsTest.java 123 cli/src/test/java/org/apache/uniffle/cli/UniffleTestAdminCLI.java 30 cli/src/test/java/org/apache/uniffle/cli/UniffleTestCLI.java 62 client-mr/core/src/test/java/org/apache/hadoop/mapred/SortWriteBufferManagerTest.java 769 client-mr/core/src/test/java/org/apache/hadoop/mapred/SortWriteBufferTest.java 185 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/RssMRUtilsTest.java 220 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/EventFetcherTest.java 286 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/FetcherTest.java 594 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/RMRssShuffleTest.java 240 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/RssInMemoryRemoteMergerTest.java 145 client-mr/core/src/test/java/org/apache/hadoop/mapreduce/task/reduce/RssRemoteMergeManagerTest.java 142 client-mr/core/src/test/java/org/apache/uniffle/client/shuffle/MRCombinerTest.java 83 client-mr/core/src/test/java/org/apache/uniffle/client/shuffle/RecordCollectorTest.java 76 client-mr/core/src/test/resources/log4j2.xml 13 client-spark/common/src/test/java/org/apache/spark/shuffle/RssSparkShuffleUtilsTest.java 214 client-spark/common/src/test/java/org/apache/spark/shuffle/handle/MutableShuffleHandleInfoTest.java 150 client-spark/common/src/test/java/org/apache/spark/shuffle/reader/AbstractRssReaderTest.java 157 client-spark/common/src/test/java/org/apache/spark/shuffle/reader/RssShuffleDataIteratorTest.java 285 client-spark/common/src/test/java/org/apache/spark/shuffle/writer/DataPusherTest.java 101 client-spark/common/src/test/java/org/apache/spark/shuffle/writer/WriteBufferManagerTest.java 525 client-spark/common/src/test/java/org/apache/spark/shuffle/writer/WriteBufferTest.java 59 client-spark/common/src/test/java/org/apache/uniffle/shuffle/manager/DummyRssShuffleManager.java 61 client-spark/common/src/test/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBaseTest.java 541 client-spark/common/src/test/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcServiceTest.java 90 client-spark/common/src/test/java/org/apache/uniffle/shuffle/manager/ShuffleManagerServerFactoryTest.java 21 client-spark/spark2/src/test/java/org/apache/spark/shuffle/DelegationRssShuffleManagerTest.java 166 client-spark/spark2/src/test/java/org/apache/spark/shuffle/RssSpark2ShuffleUtilsTest.java 17 client-spark/spark2/src/test/java/org/apache/spark/shuffle/SparkVersionUtilsTest.java 12 client-spark/spark2/src/test/java/org/apache/spark/shuffle/reader/RssShuffleReaderTest.java 81 client-spark/spark2/src/test/java/org/apache/spark/shuffle/writer/RssShuffleWriterTest.java 442 client-spark/spark3/src/test/java/org/apache/spark/shuffle/DelegationRssShuffleManagerTest.java 185 client-spark/spark3/src/test/java/org/apache/spark/shuffle/FunctionUtilsTests.java 16 client-spark/spark3/src/test/java/org/apache/spark/shuffle/RssShuffleManagerTest.java 177 client-spark/spark3/src/test/java/org/apache/spark/shuffle/RssShuffleManagerTestBase.java 44 client-spark/spark3/src/test/java/org/apache/spark/shuffle/RssSpark3ShuffleUtilsTest.java 17 client-spark/spark3/src/test/java/org/apache/spark/shuffle/SparkVersionUtilsTest.java 22 client-spark/spark3/src/test/java/org/apache/spark/shuffle/TestUtils.java 26 client-spark/spark3/src/test/java/org/apache/spark/shuffle/reader/RssShuffleReaderTest.java 135 client-spark/spark3/src/test/java/org/apache/spark/shuffle/writer/RssShuffleWriterTest.java 928 client-tez/src/test/java/org/apache/tez/common/GetShuffleServerRequestTest.java 41 client-tez/src/test/java/org/apache/tez/common/GetShuffleServerResponseTest.java 98 client-tez/src/test/java/org/apache/tez/common/IdUtilsTest.java 20 client-tez/src/test/java/org/apache/tez/common/InputContextUtilsTest.java 18 client-tez/src/test/java/org/apache/tez/common/RssTezUtilsTest.java 189 client-tez/src/test/java/org/apache/tez/common/ShuffleAssignmentsInfoWritableTest.java 78 client-tez/src/test/java/org/apache/tez/common/TezIdHelperTest.java 16 client-tez/src/test/java/org/apache/tez/dag/app/RssDAGAppMasterTest.java 445 client-tez/src/test/java/org/apache/tez/dag/app/TezRemoteShuffleManagerTest.java 227 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/impl/RssShuffleManagerTest.java 323 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/impl/RssSimpleFetchedInputAllocatorTest.java 61 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTest.java 375 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RMRssShuffleTest.java 389 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssInMemoryMergerTest.java 199 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssMergeManagerTest.java 225 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleSchedulerTest.java 882 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleTest.java 141 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezBypassWriterTest.java 122 client-tez/src/test/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezShuffleDataFetcherTest.java 309 client-tez/src/test/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManagerTest.java 747 client-tez/src/test/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferTest.java 227 client-tez/src/test/java/org/apache/tez/runtime/library/common/sort/impl/RssSorterTest.java 116 client-tez/src/test/java/org/apache/tez/runtime/library/common/sort/impl/RssTezPerPartitionRecordTest.java 29 client-tez/src/test/java/org/apache/tez/runtime/library/common/sort/impl/RssUnSorterTest.java 83 client-tez/src/test/java/org/apache/tez/runtime/library/input/RMRssOrderedGroupedKVInputTest.java 428 client-tez/src/test/java/org/apache/tez/runtime/library/input/RssOrderedGroupedKVInputTest.java 112 client-tez/src/test/java/org/apache/tez/runtime/library/input/RssSortedGroupedMergedInputTest.java 200 client-tez/src/test/java/org/apache/tez/runtime/library/output/OutputTestHelpers.java 55 client-tez/src/test/java/org/apache/tez/runtime/library/output/RssOrderedPartitionedKVOutputTest.java 133 client-tez/src/test/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutputTest.java 128 client-tez/src/test/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutputTest.java 133 client-tez/src/test/resources/log4j2.xml 13 client/src/test/java/org/apache/uniffle/client/ClientUtilsTest.java 137 client/src/test/java/org/apache/uniffle/client/PartitionDataReplicaRequirementTrackingTest.java 103 client/src/test/java/org/apache/uniffle/client/TestUtils.java 70 client/src/test/java/org/apache/uniffle/client/impl/FailedBlockSendTrackerTest.java 53 client/src/test/java/org/apache/uniffle/client/impl/ShuffleReadClientImplTest.java 649 client/src/test/java/org/apache/uniffle/client/impl/ShuffleWriteClientImplTest.java 345 client/src/test/java/org/apache/uniffle/client/record/reader/BufferedSegmentTest.java 75 client/src/test/java/org/apache/uniffle/client/record/reader/MockedShuffleServerClient.java 170 client/src/test/java/org/apache/uniffle/client/record/reader/MockedShuffleWriteClient.java 140 client/src/test/java/org/apache/uniffle/client/record/reader/RMRecordsReaderTest.java 299 client/src/test/java/org/apache/uniffle/client/record/writer/RecordCollectionTest.java 125 client/src/test/java/org/apache/uniffle/client/record/writer/SumByKeyCombiner.java 97 common/src/test/java/org/apache/uniffle/common/ArgumentsTest.java 24 common/src/test/java/org/apache/uniffle/common/BufferSegmentTest.java 48 common/src/test/java/org/apache/uniffle/common/KerberizedHadoop.java 277 common/src/test/java/org/apache/uniffle/common/KerberizedHadoopBase.java 38 common/src/test/java/org/apache/uniffle/common/PartitionRangeTest.java 53 common/src/test/java/org/apache/uniffle/common/ReconfigurableConfManagerTest.java 58 common/src/test/java/org/apache/uniffle/common/ReconfigurableRegistryTest.java 110 common/src/test/java/org/apache/uniffle/common/RemoteStorageInfoTest.java 92 common/src/test/java/org/apache/uniffle/common/ServerStatusTest.java 42 common/src/test/java/org/apache/uniffle/common/ShuffleBlockInfoTest.java 45 common/src/test/java/org/apache/uniffle/common/ShuffleDataResultTest.java 20 common/src/test/java/org/apache/uniffle/common/ShuffleIndexResultTest.java 10 common/src/test/java/org/apache/uniffle/common/ShufflePartitionedBlockTest.java 63 common/src/test/java/org/apache/uniffle/common/ShufflePartitionedDataTest.java 34 common/src/test/java/org/apache/uniffle/common/ShuffleRegisterInfoTest.java 34 common/src/test/java/org/apache/uniffle/common/ShuffleServerInfoTest.java 40 common/src/test/java/org/apache/uniffle/common/UnionKeyTest.java 21 common/src/test/java/org/apache/uniffle/common/compression/CompressionTest.java 147 common/src/test/java/org/apache/uniffle/common/config/ConfigOptionTest.java 260 common/src/test/java/org/apache/uniffle/common/config/ConfigUtilsTest.java 237 common/src/test/java/org/apache/uniffle/common/config/RssConfTest.java 45 common/src/test/java/org/apache/uniffle/common/executor/ThreadPoolManagerTest.java 127 common/src/test/java/org/apache/uniffle/common/filesystem/HadoopFilesystemProviderTest.java 87 common/src/test/java/org/apache/uniffle/common/future/CompletableFutureExtensionTest.java 45 common/src/test/java/org/apache/uniffle/common/future/CompletableFutureUtilsTest.java 49 common/src/test/java/org/apache/uniffle/common/log/TestLoggerExtension.java 87 common/src/test/java/org/apache/uniffle/common/log/TestLoggerParamResolver.java 20 common/src/test/java/org/apache/uniffle/common/merger/MergerTest.java 92 common/src/test/java/org/apache/uniffle/common/metrics/MetricReporterFactoryTest.java 18 common/src/test/java/org/apache/uniffle/common/metrics/MetricsManagerTest.java 53 common/src/test/java/org/apache/uniffle/common/metrics/TestUtils.java 55 common/src/test/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporterTest.java 85 common/src/test/java/org/apache/uniffle/common/netty/EncoderAndDecoderTest.java 192 common/src/test/java/org/apache/uniffle/common/netty/TransportFrameDecoderTest.java 239 common/src/test/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBufferTest.java 34 common/src/test/java/org/apache/uniffle/common/netty/client/TransportClientFactoryTest.java 86 common/src/test/java/org/apache/uniffle/common/netty/client/TransportClientTestBase.java 90 common/src/test/java/org/apache/uniffle/common/netty/protocol/NettyProtocolTest.java 299 common/src/test/java/org/apache/uniffle/common/netty/protocol/NettyProtocolTestUtils.java 113 common/src/test/java/org/apache/uniffle/common/records/RecordsReaderWriterTest.java 272 common/src/test/java/org/apache/uniffle/common/rpc/GrpcServerTest.java 85 common/src/test/java/org/apache/uniffle/common/rpc/StatusCodeTest.java 42 common/src/test/java/org/apache/uniffle/common/security/HadoopSecurityContextTest.java 138 common/src/test/java/org/apache/uniffle/common/security/SecurityContextFactoryTest.java 45 common/src/test/java/org/apache/uniffle/common/segment/FixedSizeSegmentSplitterTest.java 101 common/src/test/java/org/apache/uniffle/common/segment/LocalOrderSegmentSplitterTest.java 322 common/src/test/java/org/apache/uniffle/common/serializer/KryoSerializerTest.java 117 common/src/test/java/org/apache/uniffle/common/serializer/SerInputOutputStreamTest.java 134 common/src/test/java/org/apache/uniffle/common/serializer/SerializerFactoryTest.java 32 common/src/test/java/org/apache/uniffle/common/serializer/SerializerUtils.java 213 common/src/test/java/org/apache/uniffle/common/serializer/WritableSerializerTest.java 173 common/src/test/java/org/apache/uniffle/common/storage/StorageInfoUtilsTest.java 41 common/src/test/java/org/apache/uniffle/common/util/BlockIdLayoutTest.java 150 common/src/test/java/org/apache/uniffle/common/util/BlockIdTest.java 33 common/src/test/java/org/apache/uniffle/common/util/ByteBufUtilsTest.java 44 common/src/test/java/org/apache/uniffle/common/util/ChecksumUtilsTest.java 83 common/src/test/java/org/apache/uniffle/common/util/ExitUtilsTest.java 29 common/src/test/java/org/apache/uniffle/common/util/ExpiringCloseableSupplierTest.java 136 common/src/test/java/org/apache/uniffle/common/util/JavaUtilsTest.java 17 common/src/test/java/org/apache/uniffle/common/util/NettyUtilsTest.java 117 common/src/test/java/org/apache/uniffle/common/util/OutputUtilsTest.java 28 common/src/test/java/org/apache/uniffle/common/util/RetryUtilsTest.java 95 common/src/test/java/org/apache/uniffle/common/util/RssUtilsTest.java 336 common/src/test/java/org/apache/uniffle/common/util/ThreadUtilsTest.java 112 common/src/test/java/org/apache/uniffle/common/util/UnitConverterTest.java 101 common/src/test/java/org/apache/uniffle/common/web/JettyServerTest.java 64 coordinator/src/test/java/org/apache/uniffle/coordinator/ApplicationManagerTest.java 94 coordinator/src/test/java/org/apache/uniffle/coordinator/CoordinatorConfTest.java 24 coordinator/src/test/java/org/apache/uniffle/coordinator/CoordinatorServerTest.java 61 coordinator/src/test/java/org/apache/uniffle/coordinator/GenericTestUtils.java 40 coordinator/src/test/java/org/apache/uniffle/coordinator/QuotaManagerTest.java 192 coordinator/src/test/java/org/apache/uniffle/coordinator/ServerNodeTest.java 54 coordinator/src/test/java/org/apache/uniffle/coordinator/SimpleClusterManagerTest.java 449 coordinator/src/test/java/org/apache/uniffle/coordinator/access/AccessManagerTest.java 96 coordinator/src/test/java/org/apache/uniffle/coordinator/checker/AccessCandidatesCheckerTest.java 118 coordinator/src/test/java/org/apache/uniffle/coordinator/checker/AccessClusterLoadCheckerTest.java 108 coordinator/src/test/java/org/apache/uniffle/coordinator/checker/AccessQuotaCheckerTest.java 96 coordinator/src/test/java/org/apache/uniffle/coordinator/conf/DynamicClientConfServiceTest.java 105 coordinator/src/test/java/org/apache/uniffle/coordinator/conf/LegacyClientConfParserTest.java 20 coordinator/src/test/java/org/apache/uniffle/coordinator/conf/RssClientConfApplyManagerTest.java 75 coordinator/src/test/java/org/apache/uniffle/coordinator/conf/YamlClientConfParserTest.java 84 coordinator/src/test/java/org/apache/uniffle/coordinator/metric/CoordinatorMetricsTest.java 122 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/assignment/BasicAssignmentStrategyTest.java 242 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionBalanceAssignmentStrategyTest.java 422 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionRangeAssignmentTest.java 39 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionRangeTest.java 16 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/partition/ContinuousSelectPartitionStrategyTest.java 88 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategyTest.java 162 coordinator/src/test/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategyTest.java 181 coordinator/src/test/java/org/apache/uniffle/coordinator/util/CoordinatorUtilsTest.java 103 coordinator/src/test/java/org/apache/uniffle/coordinator/web/CoordinatorTestServer.java 30 coordinator/src/test/java/org/apache/uniffle/coordinator/web/UniffleJavaProcess.java 43 coordinator/src/test/java/org/apache/uniffle/coordinator/web/UniffleServicesRESTTest.java 321 coordinator/src/test/resources/dynamicClientConf.yaml 22 dashboard/src/test/java/org/apache/uniffle/dashboard/web/utils/DashboardUtilsTest.java 14 deploy/kubernetes/integration-test/e2e/set-up-local-cluster.sh 138 deploy/kubernetes/integration-test/e2e/start-e2e.sh 13 deploy/kubernetes/integration-test/e2e/template/metrics-server.yaml 190 deploy/kubernetes/integration-test/e2e/template/rss-controller-template.yaml 114 deploy/kubernetes/integration-test/e2e/template/rss-template.yaml 90 deploy/kubernetes/integration-test/e2e/template/rss-webhook-template.yaml 137 deploy/kubernetes/operator/pkg/controller/controller/process_rss_test.go 106 deploy/kubernetes/operator/pkg/controller/controller/rss_test.go 254 deploy/kubernetes/operator/pkg/controller/controller/shuffle_server_test.go 122 deploy/kubernetes/operator/pkg/controller/controller/test.go 13 deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator_test.go 546 deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver_test.go 590 deploy/kubernetes/operator/pkg/controller/util/kubernetes/hpa_test.go 79 deploy/kubernetes/operator/pkg/controller/util/util_test.go 224 deploy/kubernetes/operator/pkg/utils/rss_test.go 45 deploy/kubernetes/operator/pkg/webhook/inspector/pod_test.go 171 deploy/kubernetes/operator/pkg/webhook/inspector/rss_test.go 315 deploy/kubernetes/operator/pkg/webhook/manager_test.go 120 deploy/kubernetes/operator/pkg/webhook/util/util_test.go 50 integration-test/common/src/test/java/org/apache/uniffle/test/AccessCandidatesCheckerHadoopTest.java 124 integration-test/common/src/test/java/org/apache/uniffle/test/AccessCandidatesCheckerKerberizedHadoopTest.java 34 integration-test/common/src/test/java/org/apache/uniffle/test/AccessClusterTest.java 146 integration-test/common/src/test/java/org/apache/uniffle/test/AssignmentWithTagsTest.java 150 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorAdminServiceTest.java 39 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorAssignmentTest.java 157 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcServerTest.java 67 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorGrpcTest.java 370 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorReconfigureNodeMaxTest.java 96 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorTestBase.java 27 integration-test/common/src/test/java/org/apache/uniffle/test/CoordinatorTestUtils.java 19 integration-test/common/src/test/java/org/apache/uniffle/test/DiskErrorToleranceTest.java 178 integration-test/common/src/test/java/org/apache/uniffle/test/DynamicClientConfServiceHadoopTest.java 97 integration-test/common/src/test/java/org/apache/uniffle/test/DynamicClientConfServiceKerberlizedHadoopTest.java 20 integration-test/common/src/test/java/org/apache/uniffle/test/FetchClientConfTest.java 189 integration-test/common/src/test/java/org/apache/uniffle/test/HealthCheckCoordinatorGrpcTest.java 137 integration-test/common/src/test/java/org/apache/uniffle/test/HealthCheckTest.java 96 integration-test/common/src/test/java/org/apache/uniffle/test/HybridStorageFaultToleranceBase.java 170 integration-test/common/src/test/java/org/apache/uniffle/test/HybridStorageHadoopFallbackTest.java 40 integration-test/common/src/test/java/org/apache/uniffle/test/HybridStorageLocalFileFallbackTest.java 69 integration-test/common/src/test/java/org/apache/uniffle/test/IntegrationTestBase.java 235 integration-test/common/src/test/java/org/apache/uniffle/test/PartitionBalanceCoordinatorGrpcTest.java 69 integration-test/common/src/test/java/org/apache/uniffle/test/QuorumTest.java 881 integration-test/common/src/test/java/org/apache/uniffle/test/RemoteMergeShuffleWithRssClientTest.java 862 integration-test/common/src/test/java/org/apache/uniffle/test/RemoteMergeShuffleWithRssClientTestWhenShuffleFlushed.java 876 integration-test/common/src/test/java/org/apache/uniffle/test/RpcClientRetryTest.java 196 integration-test/common/src/test/java/org/apache/uniffle/test/ServletTest.java 313 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleReadWriteBase.java 162 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerConcurrentWriteOfHadoopTest.java 157 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerFaultToleranceTest.java 283 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerGrpcTest.java 943 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerInternalGrpcTest.java 80 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerOnRandomPortTest.java 75 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithHadoopTest.java 218 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithKerberizedHadoopTest.java 327 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithLocalOfExceptionTest.java 59 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithLocalOfLocalOrderTest.java 276 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithLocalTest.java 171 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithMemLocalHadoopTest.java 306 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleServerWithMemoryTest.java 418 integration-test/common/src/test/java/org/apache/uniffle/test/ShuffleWithRssClientTest.java 433 integration-test/common/src/test/resources/log4j2.xml 17 integration-test/mr/src/test/java/org/apache/uniffle/test/DynamicConfTest.java 39 integration-test/mr/src/test/java/org/apache/uniffle/test/FailoverAppMaster.java 13 integration-test/mr/src/test/java/org/apache/uniffle/test/HadoopConfTest.java 38 integration-test/mr/src/test/java/org/apache/uniffle/test/LargeSorterTest.java 34 integration-test/mr/src/test/java/org/apache/uniffle/test/MRIntegrationTestBase.java 273 integration-test/mr/src/test/java/org/apache/uniffle/test/RMWordCountTest.java 75 integration-test/mr/src/test/java/org/apache/uniffle/test/SecondarySortTest.java 75 integration-test/mr/src/test/java/org/apache/uniffle/test/WordCountTest.java 67 integration-test/mr/src/test/resources/log4j2.xml 17 integration-test/spark-common/src/test/java/org/apache/uniffle/test/AutoAccessTest.java 151 integration-test/spark-common/src/test/java/org/apache/uniffle/test/CombineByKeyTest.java 22 integration-test/spark-common/src/test/java/org/apache/uniffle/test/DynamicFetchClientConfTest.java 95 integration-test/spark-common/src/test/java/org/apache/uniffle/test/FailingTasksTest.java 71 integration-test/spark-common/src/test/java/org/apache/uniffle/test/GroupByKeyTest.java 27 integration-test/spark-common/src/test/java/org/apache/uniffle/test/NullOfKeyOrValueTest.java 30 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RSSStageDynamicServerReWriteTest.java 76 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RSSStageResubmitTest.java 63 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RepartitionTest.java 70 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RepartitionWithHadoopHybridStorageRssTest.java 47 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RepartitionWithLocalFileRssTest.java 74 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RepartitionWithMemoryHybridStorageRssTest.java 36 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RepartitionWithMemoryRssTest.java 50 integration-test/spark-common/src/test/java/org/apache/uniffle/test/RssShuffleManagerTest.java 200 integration-test/spark-common/src/test/java/org/apache/uniffle/test/ShuffleServerManagerTestBase.java 51 integration-test/spark-common/src/test/java/org/apache/uniffle/test/ShuffleUnregisterWithHadoopTest.java 76 integration-test/spark-common/src/test/java/org/apache/uniffle/test/ShuffleUnregisterWithLocalfileTest.java 87 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SimpleShuffleServerManagerTest.java 21 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SimpleTestBase.java 28 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalForMultiPartLocalStorageManagerTest.java 155 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkClientWithLocalTest.java 447 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkIntegrationTestBase.java 134 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkSQLTest.java 68 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkSQLWithDelegationShuffleManagerFallbackTest.java 55 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkSQLWithDelegationShuffleManagerTest.java 58 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkSQLWithMemoryLocalTest.java 49 integration-test/spark-common/src/test/java/org/apache/uniffle/test/SparkTaskFailureIntegrationTestBase.java 15 integration-test/spark-common/src/test/java/org/apache/uniffle/test/TestUtils.java 47 integration-test/spark-common/src/test/java/org/apache/uniffle/test/WriteAndReadMetricsTest.java 43 integration-test/spark-common/src/test/java/org/apache/uniffle/test/listener/WriteAndReadMetricsSparkListener.java 28 integration-test/spark-common/src/test/resources/log4j2.xml 17 integration-test/spark2/src/test/java/org/apache/uniffle/test/GetReaderTest.java 138 integration-test/spark2/src/test/resources/log4j2.xml 17 integration-test/spark3/src/test/java/org/apache/uniffle/test/AQERepartitionTest.java 75 integration-test/spark3/src/test/java/org/apache/uniffle/test/AQESkewedJoinTest.java 107 integration-test/spark3/src/test/java/org/apache/uniffle/test/AQESkewedJoinWithLocalOrderTest.java 15 integration-test/spark3/src/test/java/org/apache/uniffle/test/ContinuousSelectPartitionStrategyTest.java 199 integration-test/spark3/src/test/java/org/apache/uniffle/test/GetReaderTest.java 254 integration-test/spark3/src/test/java/org/apache/uniffle/test/GetShuffleReportForMultiPartTest.java 232 integration-test/spark3/src/test/java/org/apache/uniffle/test/MapSideCombineTest.java 99 integration-test/spark3/src/test/java/org/apache/uniffle/test/PartitionBlockDataReassignBasicTest.java 73 integration-test/spark3/src/test/java/org/apache/uniffle/test/PartitionBlockDataReassignMultiTimesTest.java 65 integration-test/spark3/src/test/java/org/apache/uniffle/test/PartitionSplitOfLoadBalanceModeTest.java 87 integration-test/spark3/src/test/java/org/apache/uniffle/test/ReassignAndStageRetryTest.java 36 integration-test/spark3/src/test/resources/log4j2.xml 17 integration-test/tez/src/test/java/org/apache/tez/dag/app/RssDAGAppMasterForWordCountWithFailures.java 301 integration-test/tez/src/test/java/org/apache/uniffle/test/RMTezOrderedWordCountTest.java 91 integration-test/tez/src/test/java/org/apache/uniffle/test/TezCartesianProductTest.java 58 integration-test/tez/src/test/java/org/apache/uniffle/test/TezHashJoinTest.java 39 integration-test/tez/src/test/java/org/apache/uniffle/test/TezIntegrationTestBase.java 299 integration-test/tez/src/test/java/org/apache/uniffle/test/TezJoinIntegrationTestBase.java 57 integration-test/tez/src/test/java/org/apache/uniffle/test/TezOrderedWordCountTest.java 65 integration-test/tez/src/test/java/org/apache/uniffle/test/TezSimpleSessionExampleTest.java 125 integration-test/tez/src/test/java/org/apache/uniffle/test/TezSortMergeJoinTest.java 24 integration-test/tez/src/test/java/org/apache/uniffle/test/TezWordCountTest.java 48 integration-test/tez/src/test/java/org/apache/uniffle/test/TezWordCountWithFailuresTest.java 279 integration-test/tez/src/test/resources/log4j2.xml 17 internal-client/src/test/java/org/apache/uniffle/client/factory/ShuffleManagerClientFactoryTest.java 19 server/src/test/java/org/apache/uniffle/server/HealthScriptCheckerTest.java 49 server/src/test/java/org/apache/uniffle/server/HealthyMockChecker.java 11 server/src/test/java/org/apache/uniffle/server/KerberizedShuffleTaskManagerTest.java 137 server/src/test/java/org/apache/uniffle/server/LocalSingleStorageTypeFromEnvProviderTest.java 70 server/src/test/java/org/apache/uniffle/server/LocalStorageCheckerTest.java 87 server/src/test/java/org/apache/uniffle/server/MockedGrpcServer.java 17 server/src/test/java/org/apache/uniffle/server/MockedShuffleServer.java 10 server/src/test/java/org/apache/uniffle/server/MockedShuffleServerFactory.java 23 server/src/test/java/org/apache/uniffle/server/MockedShuffleServerGrpcService.java 263 server/src/test/java/org/apache/uniffle/server/ShuffleFlushManagerOnKerberizedHadoopTest.java 131 server/src/test/java/org/apache/uniffle/server/ShuffleFlushManagerTest.java 783 server/src/test/java/org/apache/uniffle/server/ShuffleServerConfTest.java 106 server/src/test/java/org/apache/uniffle/server/ShuffleServerGrpcMetricsTest.java 46 server/src/test/java/org/apache/uniffle/server/ShuffleServerMetricsTest.java 251 server/src/test/java/org/apache/uniffle/server/ShuffleServerTest.java 131 server/src/test/java/org/apache/uniffle/server/ShuffleTaskInfoTest.java 107 server/src/test/java/org/apache/uniffle/server/ShuffleTaskManagerTest.java 1079 server/src/test/java/org/apache/uniffle/server/StorageCheckerTest.java 213 server/src/test/java/org/apache/uniffle/server/TopNShuffleDataSizeOfAppCalcTaskTest.java 245 server/src/test/java/org/apache/uniffle/server/UnHealthyMockChecker.java 11 server/src/test/java/org/apache/uniffle/server/buffer/BufferTestBase.java 43 server/src/test/java/org/apache/uniffle/server/buffer/ShuffleBufferManagerTest.java 719 server/src/test/java/org/apache/uniffle/server/buffer/ShuffleBufferWithLinkedListTest.java 501 server/src/test/java/org/apache/uniffle/server/buffer/ShuffleBufferWithSkipListTest.java 151 server/src/test/java/org/apache/uniffle/server/merge/BlockFlushFileReaderTest.java 223 server/src/test/java/org/apache/uniffle/server/merge/MergedResultTest.java 151 server/src/test/java/org/apache/uniffle/server/merge/ShuffleMergeManagerTest.java 218 server/src/test/java/org/apache/uniffle/server/storage/HadoopStorageManagerTest.java 158 server/src/test/java/org/apache/uniffle/server/storage/HybridStorageManagerTest.java 129 server/src/test/java/org/apache/uniffle/server/storage/LocalStorageManagerTest.java 280 server/src/test/java/org/apache/uniffle/server/storage/StorageManagerFallbackStrategyTest.java 111 server/src/test/resources/healthy-script1.sh 1 server/src/test/resources/healthy-script2.sh 1 server/src/test/resources/healthy-script3.sh 1 server/src/test/resources/healthy-script4.sh 1 server/src/test/resources/log4j2.xml 13 storage/src/test/java/org/apache/uniffle/storage/HadoopShuffleHandlerTestBase.java 124 storage/src/test/java/org/apache/uniffle/storage/HadoopTestBase.java 46 storage/src/test/java/org/apache/uniffle/storage/common/DefaultStorageMediaProviderTest.java 35 storage/src/test/java/org/apache/uniffle/storage/common/LocalStorageTest.java 163 storage/src/test/java/org/apache/uniffle/storage/common/ShuffleFileInfoTest.java 19 storage/src/test/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandlerTest.java 104 storage/src/test/java/org/apache/uniffle/storage/handler/impl/HadoopFileReaderTest.java 57 storage/src/test/java/org/apache/uniffle/storage/handler/impl/HadoopFileWriterTest.java 119 storage/src/test/java/org/apache/uniffle/storage/handler/impl/HadoopHandlerTest.java 107 storage/src/test/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleReadHandlerTest.java 190 storage/src/test/java/org/apache/uniffle/storage/handler/impl/KerberizedHadoopClientReadHandlerTest.java 21 storage/src/test/java/org/apache/uniffle/storage/handler/impl/KerberizedHadoopShuffleReadHandlerTest.java 21 storage/src/test/java/org/apache/uniffle/storage/handler/impl/LocalFileHandlerTest.java 123 storage/src/test/java/org/apache/uniffle/storage/handler/impl/LocalFileHandlerTestBase.java 139 storage/src/test/java/org/apache/uniffle/storage/handler/impl/LocalFileServerReadHandlerTest.java 112 storage/src/test/java/org/apache/uniffle/storage/handler/impl/PooledHadoopShuffleWriteHandlerTest.java 170 storage/src/test/java/org/apache/uniffle/storage/handler/impl/PrefetchableClientReadHandlerTest.java 84 storage/src/test/java/org/apache/uniffle/storage/util/ShuffleHadoopStorageUtilsTest.java 38 storage/src/test/java/org/apache/uniffle/storage/util/ShuffleKerberizedHadoopStorageUtilsTest.java 22 storage/src/test/java/org/apache/uniffle/storage/util/ShuffleStorageUtilsTest.java 290 storage/src/test/java/org/apache/uniffle/storage/util/StorageTypeTest.java 40