Skip to content

[#1472][FOLLOWUP] fix(client): Fix IllegalReferenceCountException iss…

Sign in for the full log view
GitHub Actions / Test Results failed Feb 22, 2024 in 0s. View latest attempt.

1 fail, 1 skipped, 821 pass in 4h 39m 36s

2 432 files  2 432 suites   4h 39m 36s ⏱️
  823 tests   821 ✅  1 💤 1 ❌
9 737 runs  9 722 ✅ 14 💤 1 ❌

Results for commit fc84871.

Annotations

Check warning on line 0 in org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 out of 9 runs failed: unregisterShuffleTest (org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest) 

artifacts/test-reports-spark3/integration-test/spark-common/target/surefire-reports/TEST-org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest.xml [took 12s]
Raw output 
expected: <false> but was: <true>
org.opentest4j.AssertionFailedError: expected: <false> but was: <true>
	at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55)
	at org.junit.jupiter.api.AssertFalse.assertFalse(AssertFalse.java:40)
	at org.junit.jupiter.api.AssertFalse.assertFalse(AssertFalse.java:35)
	at org.junit.jupiter.api.Assertions.assertFalse(Assertions.java:227)
	at org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest.runTest(ShuffleUnregisterWithHadoopTest.java:95)
	at org.apache.uniffle.test.SparkIntegrationTestBase.runSparkApp(SparkIntegrationTestBase.java:93)
	at org.apache.uniffle.test.SparkIntegrationTestBase.run(SparkIntegrationTestBase.java:60)
	at org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest.unregisterShuffleTest(ShuffleUnregisterWithHadoopTest.java:65)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:498)
	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:725)
	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestMethod(TimeoutExtension.java:84)
	at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$7(TestMethodTestDescriptor.java:214)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:210)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:135)
	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:66)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:151)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at java.util.ArrayList.forEach(ArrayList.java:1259)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at java.util.ArrayList.forEach(ArrayList.java:1259)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:41)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$6(NodeTestTask.java:155)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:141)
	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$9(NodeTestTask.java:139)
	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:138)
	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:95)
	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:35)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
	at org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
	at org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
	at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
2024-02-22 19:48:42,398 INFO  [main] hdfs.MiniDFSCluster (MiniDFSCluster.java:<init>(460)) - starting cluster: numNameNodes=1, numDataNodes=1
Formatting using clusterid: testClusterID
2024-02-22 19:48:42,398 INFO  [main] namenode.FSEditLog (FSEditLog.java:newInstance(225)) - Edit logging is async:true
2024-02-22 19:48:42,399 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(742)) - KeyProvider: null
2024-02-22 19:48:42,399 INFO  [main] namenode.FSNamesystem (FSNamesystemLock.java:<init>(120)) - fsLock is fair: true
2024-02-22 19:48:42,399 INFO  [main] namenode.FSNamesystem (FSNamesystemLock.java:<init>(136)) - Detailed lock hold time metrics enabled: false
2024-02-22 19:48:42,399 INFO  [main] blockmanagement.DatanodeManager (DatanodeManager.java:<init>(241)) - dfs.block.invalidate.limit=1000
2024-02-22 19:48:42,399 INFO  [main] blockmanagement.DatanodeManager (DatanodeManager.java:<init>(247)) - dfs.namenode.datanode.registration.ip-hostname-check=true
2024-02-22 19:48:42,399 INFO  [main] blockmanagement.BlockManager (InvalidateBlocks.java:printBlockDeletionTime(73)) - dfs.namenode.startup.delay.block.deletion.sec is set to 000:00:00:00.000
2024-02-22 19:48:42,400 INFO  [main] blockmanagement.BlockManager (InvalidateBlocks.java:printBlockDeletionTime(78)) - The block deletion will start around 2024 Feb 22 19:48:42
2024-02-22 19:48:42,400 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map BlocksMap
2024-02-22 19:48:42,400 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,400 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 2.0% max memory 2.7 GB = 54.6 MB
2024-02-22 19:48:42,400 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^23 = 8388608 entries
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:createBlockTokenSecretManager(417)) - dfs.block.access.token.enable=false
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(403)) - defaultReplication         = 1
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(404)) - maxReplication             = 512
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(405)) - minReplication             = 1
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(406)) - maxReplicationStreams      = 2
2024-02-22 19:48:42,401 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(407)) - replicationRecheckInterval = 3000
2024-02-22 19:48:42,402 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(408)) - encryptDataTransfer        = false
2024-02-22 19:48:42,402 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(409)) - maxNumBlocksToLog          = 1000
2024-02-22 19:48:42,402 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(767)) - fsOwner             = runner (auth:SIMPLE)
2024-02-22 19:48:42,402 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(768)) - supergroup          = supergroup
2024-02-22 19:48:42,402 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(769)) - isPermissionEnabled = true
2024-02-22 19:48:42,402 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(780)) - HA Enabled: false
2024-02-22 19:48:42,402 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(822)) - Append Enabled: true
2024-02-22 19:48:42,402 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map INodeMap
2024-02-22 19:48:42,403 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,403 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 1.0% max memory 2.7 GB = 27.3 MB
2024-02-22 19:48:42,403 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^22 = 4194304 entries
2024-02-22 19:48:42,404 INFO  [main] namenode.FSDirectory (FSDirectory.java:<init>(265)) - ACLs enabled? false
2024-02-22 19:48:42,404 INFO  [main] namenode.FSDirectory (FSDirectory.java:<init>(269)) - XAttrs enabled? true
2024-02-22 19:48:42,404 INFO  [main] namenode.NameNode (FSDirectory.java:<init>(333)) - Caching file names occurring more than 10 times
2024-02-22 19:48:42,404 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map cachedBlocks
2024-02-22 19:48:42,404 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,404 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 0.25% max memory 2.7 GB = 6.8 MB
2024-02-22 19:48:42,404 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^20 = 1048576 entries
2024-02-22 19:48:42,405 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4418)) - dfs.namenode.safemode.threshold-pct = 0.9990000128746033
2024-02-22 19:48:42,405 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4419)) - dfs.namenode.safemode.min.datanodes = 0
2024-02-22 19:48:42,405 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4420)) - dfs.namenode.safemode.extension     = 0
2024-02-22 19:48:42,405 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(76)) - NNTop conf: dfs.namenode.top.window.num.buckets = 10
2024-02-22 19:48:42,405 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(78)) - NNTop conf: dfs.namenode.top.num.users = 10
2024-02-22 19:48:42,405 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(80)) - NNTop conf: dfs.namenode.top.windows.minutes = 1,5,25
2024-02-22 19:48:42,405 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:initRetryCache(968)) - Retry cache on namenode is enabled
2024-02-22 19:48:42,405 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:initRetryCache(976)) - Retry cache will use 0.03 of total heap and retry cache entry expiry time is 600000 millis
2024-02-22 19:48:42,406 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map NameNodeRetryCache
2024-02-22 19:48:42,406 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,406 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 0.029999999329447746% max memory 2.7 GB = 839.0 KB
2024-02-22 19:48:42,406 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^17 = 131072 entries
2024-02-22 19:48:42,406 INFO  [main] namenode.FSImage (FSImage.java:format(163)) - Allocated new BlockPoolId: BP-253271122-127.0.0.1-1708631322406
2024-02-22 19:48:42,408 INFO  [main] common.Storage (NNStorage.java:format(577)) - Storage directory /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1 has been successfully formatted.
2024-02-22 19:48:42,410 INFO  [main] common.Storage (NNStorage.java:format(577)) - Storage directory /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2 has been successfully formatted.
2024-02-22 19:48:42,410 INFO  [FSImageSaver for /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1 of type IMAGE_AND_EDITS] namenode.FSImageFormatProtobuf (FSImageFormatProtobuf.java:save(425)) - Saving image file /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/current/fsimage.ckpt_0000000000000000000 using no compression
2024-02-22 19:48:42,410 INFO  [FSImageSaver for /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2 of type IMAGE_AND_EDITS] namenode.FSImageFormatProtobuf (FSImageFormatProtobuf.java:save(425)) - Saving image file /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2/current/fsimage.ckpt_0000000000000000000 using no compression
2024-02-22 19:48:42,416 INFO  [FSImageSaver for /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1 of type IMAGE_AND_EDITS] namenode.FSImageFormatProtobuf (FSImageFormatProtobuf.java:save(428)) - Image file /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/current/fsimage.ckpt_0000000000000000000 of size 323 bytes saved in 0 seconds.
2024-02-22 19:48:42,418 INFO  [FSImageSaver for /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2 of type IMAGE_AND_EDITS] namenode.FSImageFormatProtobuf (FSImageFormatProtobuf.java:save(428)) - Image file /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2/current/fsimage.ckpt_0000000000000000000 of size 323 bytes saved in 0 seconds.
2024-02-22 19:48:42,419 INFO  [main] namenode.NNStorageRetentionManager (NNStorageRetentionManager.java:getImageTxIdToRetain(203)) - Going to retain 1 images with txid >= 0
2024-02-22 19:48:42,419 INFO  [main] namenode.NameNode (NameNode.java:createNameNode(1551)) - createNameNode []
2024-02-22 19:48:42,420 WARN  [main] impl.MetricsConfig (MetricsConfig.java:loadFirst(128)) - Cannot locate configuration: tried hadoop-metrics2-namenode.properties,hadoop-metrics2.properties
2024-02-22 19:48:42,421 INFO  [main] impl.MetricsSystemImpl (MetricsSystemImpl.java:startTimer(374)) - Scheduled Metric snapshot period at 10 second(s).
2024-02-22 19:48:42,421 INFO  [main] impl.MetricsSystemImpl (MetricsSystemImpl.java:start(191)) - NameNode metrics system started
2024-02-22 19:48:42,422 INFO  [main] namenode.NameNode (NameNode.java:setClientNamenodeAddress(439)) - fs.defaultFS is hdfs://127.0.0.1:0
2024-02-22 19:48:42,424 INFO  [org.apache.hadoop.util.JvmPauseMonitor$Monitor@f74436a] util.JvmPauseMonitor (JvmPauseMonitor.java:run(183)) - Starting JVM pause monitor
2024-02-22 19:48:42,424 INFO  [main] hdfs.DFSUtil (DFSUtil.java:httpServerTemplateForNNAndJN(1467)) - Starting Web-server for hdfs at: http://localhost:0
2024-02-22 19:48:42,425 INFO  [main] server.AuthenticationFilter (AuthenticationFilter.java:constructSecretProvider(240)) - Unable to initialize FileSignerSecretProvider, falling back to use random secrets.
2024-02-22 19:48:42,425 WARN  [main] http.HttpRequestLog (HttpRequestLog.java:getRequestLog(100)) - Jetty request log can only be enabled using Log4j
2024-02-22 19:48:42,426 INFO  [main] http.HttpServer2 (HttpServer2.java:addGlobalFilter(789)) - Added global filter 'safety' (class=org.apache.hadoop.http.HttpServer2$QuotingInputFilter)
2024-02-22 19:48:42,426 INFO  [main] http.HttpServer2 (HttpServer2.java:addFilter(764)) - Added filter static_user_filter (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to context hdfs
2024-02-22 19:48:42,426 INFO  [main] http.HttpServer2 (HttpServer2.java:addFilter(772)) - Added filter static_user_filter (class=org.apache.hadoop.http.lib.StaticUserWebFilter$StaticUserFilter) to context static
2024-02-22 19:48:42,427 INFO  [main] http.HttpServer2 (NameNodeHttpServer.java:initWebHdfs(94)) - Added filter 'org.apache.hadoop.hdfs.web.AuthFilter' (class=org.apache.hadoop.hdfs.web.AuthFilter)
2024-02-22 19:48:42,427 INFO  [main] http.HttpServer2 (HttpServer2.java:addJerseyResourcePackage(688)) - addJerseyResourcePackage: packageName=org.apache.hadoop.hdfs.server.namenode.web.resources;org.apache.hadoop.hdfs.web.resources, pathSpec=/webhdfs/v1/*
2024-02-22 19:48:42,427 INFO  [main] http.HttpServer2 (HttpServer2.java:openListeners(994)) - Jetty bound to port 33813
2024-02-22 19:48:42,427 INFO  [main] mortbay.log (Slf4jLog.java:info(67)) - jetty-6.1.26
2024-02-22 19:48:42,431 INFO  [main] mortbay.log (Slf4jLog.java:info(67)) - Extract jar:file:/home/runner/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.8.5/hadoop-hdfs-2.8.5-tests.jar!/webapps/hdfs to /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/Jetty_localhost_33813_hdfs____99g42s/webapp
2024-02-22 19:48:42,503 INFO  [main] mortbay.log (Slf4jLog.java:info(67)) - Started HttpServer2$SelectChannelConnectorWithSafeStartup@localhost:33813
2024-02-22 19:48:42,504 INFO  [main] namenode.FSEditLog (FSEditLog.java:newInstance(225)) - Edit logging is async:true
2024-02-22 19:48:42,504 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(742)) - KeyProvider: null
2024-02-22 19:48:42,504 INFO  [main] namenode.FSNamesystem (FSNamesystemLock.java:<init>(120)) - fsLock is fair: true
2024-02-22 19:48:42,504 INFO  [main] namenode.FSNamesystem (FSNamesystemLock.java:<init>(136)) - Detailed lock hold time metrics enabled: false
2024-02-22 19:48:42,505 INFO  [main] blockmanagement.DatanodeManager (DatanodeManager.java:<init>(241)) - dfs.block.invalidate.limit=1000
2024-02-22 19:48:42,505 INFO  [main] blockmanagement.DatanodeManager (DatanodeManager.java:<init>(247)) - dfs.namenode.datanode.registration.ip-hostname-check=true
2024-02-22 19:48:42,505 INFO  [main] blockmanagement.BlockManager (InvalidateBlocks.java:printBlockDeletionTime(73)) - dfs.namenode.startup.delay.block.deletion.sec is set to 000:00:00:00.000
2024-02-22 19:48:42,505 INFO  [main] blockmanagement.BlockManager (InvalidateBlocks.java:printBlockDeletionTime(78)) - The block deletion will start around 2024 Feb 22 19:48:42
2024-02-22 19:48:42,505 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map BlocksMap
2024-02-22 19:48:42,505 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,505 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 2.0% max memory 2.7 GB = 54.6 MB
2024-02-22 19:48:42,506 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^23 = 8388608 entries
2024-02-22 19:48:42,506 INFO  [main] blockmanagement.BlockManager (BlockManager.java:createBlockTokenSecretManager(417)) - dfs.block.access.token.enable=false
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(403)) - defaultReplication         = 1
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(404)) - maxReplication             = 512
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(405)) - minReplication             = 1
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(406)) - maxReplicationStreams      = 2
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(407)) - replicationRecheckInterval = 3000
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(408)) - encryptDataTransfer        = false
2024-02-22 19:48:42,507 INFO  [main] blockmanagement.BlockManager (BlockManager.java:<init>(409)) - maxNumBlocksToLog          = 1000
2024-02-22 19:48:42,507 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(767)) - fsOwner             = runner (auth:SIMPLE)
2024-02-22 19:48:42,508 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(768)) - supergroup          = supergroup
2024-02-22 19:48:42,508 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(769)) - isPermissionEnabled = true
2024-02-22 19:48:42,508 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(780)) - HA Enabled: false
2024-02-22 19:48:42,508 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(822)) - Append Enabled: true
2024-02-22 19:48:42,508 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map INodeMap
2024-02-22 19:48:42,508 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,508 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 1.0% max memory 2.7 GB = 27.3 MB
2024-02-22 19:48:42,509 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^22 = 4194304 entries
2024-02-22 19:48:42,510 INFO  [main] namenode.FSDirectory (FSDirectory.java:<init>(265)) - ACLs enabled? false
2024-02-22 19:48:42,510 INFO  [main] namenode.FSDirectory (FSDirectory.java:<init>(269)) - XAttrs enabled? true
2024-02-22 19:48:42,510 INFO  [main] namenode.NameNode (FSDirectory.java:<init>(333)) - Caching file names occurring more than 10 times
2024-02-22 19:48:42,510 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map cachedBlocks
2024-02-22 19:48:42,510 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,510 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 0.25% max memory 2.7 GB = 6.8 MB
2024-02-22 19:48:42,510 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^20 = 1048576 entries
2024-02-22 19:48:42,511 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4418)) - dfs.namenode.safemode.threshold-pct = 0.9990000128746033
2024-02-22 19:48:42,511 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4419)) - dfs.namenode.safemode.min.datanodes = 0
2024-02-22 19:48:42,511 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:<init>(4420)) - dfs.namenode.safemode.extension     = 0
2024-02-22 19:48:42,511 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(76)) - NNTop conf: dfs.namenode.top.window.num.buckets = 10
2024-02-22 19:48:42,511 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(78)) - NNTop conf: dfs.namenode.top.num.users = 10
2024-02-22 19:48:42,511 INFO  [main] metrics.TopMetrics (TopMetrics.java:logConf(80)) - NNTop conf: dfs.namenode.top.windows.minutes = 1,5,25
2024-02-22 19:48:42,511 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:initRetryCache(968)) - Retry cache on namenode is enabled
2024-02-22 19:48:42,511 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:initRetryCache(976)) - Retry cache will use 0.03 of total heap and retry cache entry expiry time is 600000 millis
2024-02-22 19:48:42,512 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(395)) - Computing capacity for map NameNodeRetryCache
2024-02-22 19:48:42,512 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(396)) - VM type       = 64-bit
2024-02-22 19:48:42,512 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(397)) - 0.029999999329447746% max memory 2.7 GB = 839.0 KB
2024-02-22 19:48:42,512 INFO  [main] util.GSet (LightWeightGSet.java:computeCapacity(402)) - capacity      = 2^17 = 131072 entries
2024-02-22 19:48:42,513 INFO  [main] common.Storage (Storage.java:tryLock(732)) - Lock on /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/in_use.lock acquired by nodename 24673@action-host
2024-02-22 19:48:42,514 INFO  [main] common.Storage (Storage.java:tryLock(732)) - Lock on /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2/in_use.lock acquired by nodename 24673@action-host
2024-02-22 19:48:42,514 INFO  [main] namenode.FileJournalManager (FileJournalManager.java:recoverUnfinalizedSegments(390)) - Recovering unfinalized segments in /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/current
2024-02-22 19:48:42,515 INFO  [main] namenode.FileJournalManager (FileJournalManager.java:recoverUnfinalizedSegments(390)) - Recovering unfinalized segments in /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name2/current
2024-02-22 19:48:42,515 INFO  [main] namenode.FSImage (FSImage.java:loadFSImage(711)) - No edit log streams selected.
2024-02-22 19:48:42,515 INFO  [main] namenode.FSImage (FSImage.java:loadFSImageFile(778)) - Planning to load image: FSImageFile(file=/home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/current/fsimage_0000000000000000000, cpktTxId=0000000000000000000)
2024-02-22 19:48:42,516 INFO  [main] namenode.FSImageFormatPBINode (FSImageFormatPBINode.java:loadINodeSection(262)) - Loading 1 INodes.
2024-02-22 19:48:42,516 INFO  [main] namenode.FSImageFormatProtobuf (FSImageFormatProtobuf.java:load(185)) - Loaded FSImage in 0 seconds.
2024-02-22 19:48:42,516 INFO  [main] namenode.FSImage (FSImage.java:loadFSImage(944)) - Loaded image for txid 0 from /home/runner/work/incubator-uniffle/incubator-uniffle/integration-test/spark-common/target/tmp/junit3470805626854664921/name1/current/fsimage_0000000000000000000
2024-02-22 19:48:42,516 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:loadFSImage(1051)) - Need to save fs image? false (staleImage=false, haEnabled=false, isRollingUpgrade=false)
2024-02-22 19:48:42,516 INFO  [main] namenode.FSEditLog (FSEditLog.java:startLogSegment(1294)) - Starting log segment at 1
2024-02-22 19:48:42,521 INFO  [main] namenode.NameCache (NameCache.java:initialized(143)) - initialized with 0 entries 0 lookups
2024-02-22 19:48:42,521 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:loadFromDisk(714)) - Finished loading FSImage in 9 msecs
2024-02-22 19:48:42,521 INFO  [main] namenode.NameNode (NameNodeRpcServer.java:<init>(414)) - RPC server is binding to localhost:0
2024-02-22 19:48:42,521 INFO  [main] ipc.CallQueueManager (CallQueueManager.java:<init>(83)) - Using callQueue: class java.util.concurrent.LinkedBlockingQueue queueCapacity: 1000 scheduler: class org.apache.hadoop.ipc.DefaultRpcScheduler
2024-02-22 19:48:42,521 INFO  [Socket Reader #1 for port 37225] ipc.Server (Server.java:run(956)) - Starting Socket Reader #1 for port 37225
2024-02-22 19:48:42,524 INFO  [main] namenode.NameNode (NameNode.java:initialize(704)) - Clients are to use localhost:37225 to access this namenode/service.
2024-02-22 19:48:42,524 INFO  [main] namenode.FSNamesystem (FSNamesystem.java:registerMBean(5322)) - Registered FSNamesystemState MBean
2024-02-22 19:48:42,533 INFO  [main] namenode.LeaseManager (LeaseManager.java:getNumUnderConstructionBlocks(155)) - Number of blocks under construction: 0
2024-02-22 19:48:42,533 INFO  [main] blockmanagement.BlockManager (BlockManager.java:initializeReplQueues(3877)) - initializing replication queues
2024-02-22 19:48:42,533 INFO  [main] hdfs.StateChange (FSNamesystem.java:leave(4505)) - STATE* Leaving safe mode after 0 secs
2024-02-22 19:48:42,533 INFO  [main] hdfs.StateChange (FSNamesystem.java:leave(4517)) - STATE* Network topology has 0 racks and 0 datanodes
2024-02-22 19:48:42,533 INFO  [main] hdfs.StateChange (FSNamesystem.java:leave(4520)) - STATE* UnderReplicatedBlocks has 0 blocks
2024-02-22 19:48:42,535 INFO  [IPC Server listener on 37225] ipc.Server (Server.java:run(1035)) - IPC Server listener on 37225: starting
2024-02-22 19:48:42,535 INFO  [IPC Server Responder] ipc.Server (Server.java:run(1196)) - IPC Server Responder: starting
2024-02-22 19:48:42,537 INFO  [Replication Queue Initializer] blockmanagement.BlockManager (BlockManager.java:processMisReplicatesAsync(2901)) - Total number of blocks            = 0
2024-02-22 19:48:42,537 INFO  [Replication Queue Initializer] blockmanagement.BlockManager (BlockManager.java:processMisReplicatesAsync(2902)) - Number of invalid blocks          = 0
2024-02-22 19:48:42,537 INFO  [Replication Queue Initializer] blockmanagement.BlockManager (BlockManager.java:processMisReplicatesAsync(2903)) - Number of under-replicated blocks = 0
2024-02-22 19:48:42…3292 [Receiving block BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005]] datanode.DataNode (DataXceiver.java:writeBlock(704)) - Receiving BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005 src: /127.0.0.1:53292 dest: /127.0.0.1:34033
2024-02-22 19:48:54,662 INFO  [IPC Server handler 6 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:54,667 INFO  [IPC Server handler 7 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:54,668 INFO  [IPC Server handler 1 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=create	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index	dst=null	perm=runner:supergroup:rw-r--r--	proto=rpc
2024-02-22 19:48:54,669 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005, type=LAST_IN_PIPELINE] DataNode.clienttrace (BlockReceiver.java:finalizeBlock(1454)) - src: /127.0.0.1:53292, dest: /127.0.0.1:34033, bytes: 80, op: HDFS_WRITE, cliID: DFSClient_NONMAPREDUCE_-549788326_1, offset: 0, srvID: 7e99c4f5-4c3d-4f19-b9ae-d66deb3c411d, blockid: BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005, duration: 1740496
2024-02-22 19:48:54,670 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005, type=LAST_IN_PIPELINE] datanode.DataNode (BlockReceiver.java:run(1427)) - PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741829_1005, type=LAST_IN_PIPELINE terminating
2024-02-22 19:48:54,671 INFO  [IPC Server handler 0 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:logAllocatedBlock(725)) - BLOCK* allocate blk_1073741830_1006, replicas=127.0.0.1:34033 for /rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index
2024-02-22 19:48:54,672 INFO  [IPC Server handler 2 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:completeFile(605)) - DIR* completeFile: /rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.index is closed by DFSClient_NONMAPREDUCE_-549788326_1
2024-02-22 19:48:54,672 INFO  [DataXceiver for client DFSClient_NONMAPREDUCE_-549788326_1 at /127.0.0.1:53308 [Receiving block BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006]] datanode.DataNode (DataXceiver.java:writeBlock(704)) - Receiving BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006 src: /127.0.0.1:53308 dest: /127.0.0.1:34033
2024-02-22 19:48:54,673 INFO  [IPC Server handler 9 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:logAllocatedBlock(725)) - BLOCK* allocate blk_1073741831_1007, replicas=127.0.0.1:34033 for /rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.data
2024-02-22 19:48:54,674 INFO  [DataXceiver for client DFSClient_NONMAPREDUCE_-549788326_1 at /127.0.0.1:53318 [Receiving block BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007]] datanode.DataNode (DataXceiver.java:writeBlock(704)) - Receiving BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007 src: /127.0.0.1:53318 dest: /127.0.0.1:34033
2024-02-22 19:48:54,687 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006, type=LAST_IN_PIPELINE] DataNode.clienttrace (BlockReceiver.java:finalizeBlock(1454)) - src: /127.0.0.1:53308, dest: /127.0.0.1:34033, bytes: 80, op: HDFS_WRITE, cliID: DFSClient_NONMAPREDUCE_-549788326_1, offset: 0, srvID: 7e99c4f5-4c3d-4f19-b9ae-d66deb3c411d, blockid: BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006, duration: 11939719
2024-02-22 19:48:54,687 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006, type=LAST_IN_PIPELINE] datanode.DataNode (BlockReceiver.java:run(1427)) - PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741830_1006, type=LAST_IN_PIPELINE terminating
2024-02-22 19:48:54,688 INFO  [IPC Server handler 8 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:completeFile(605)) - DIR* completeFile: /rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index is closed by DFSClient_NONMAPREDUCE_-549788326_1
2024-02-22 19:48:54,688 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007, type=LAST_IN_PIPELINE] DataNode.clienttrace (BlockReceiver.java:finalizeBlock(1454)) - src: /127.0.0.1:53318, dest: /127.0.0.1:34033, bytes: 122, op: HDFS_WRITE, cliID: DFSClient_NONMAPREDUCE_-549788326_1, offset: 0, srvID: 7e99c4f5-4c3d-4f19-b9ae-d66deb3c411d, blockid: BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007, duration: 10652902
2024-02-22 19:48:54,690 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007, type=LAST_IN_PIPELINE] datanode.DataNode (BlockReceiver.java:run(1427)) - PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741831_1007, type=LAST_IN_PIPELINE terminating
2024-02-22 19:48:54,690 INFO  [IPC Server handler 6 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:completeFile(605)) - DIR* completeFile: /rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.data is closed by DFSClient_NONMAPREDUCE_-549788326_1
2024-02-22 19:48:54,690 INFO  [IPC Server handler 7 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:logAllocatedBlock(725)) - BLOCK* allocate blk_1073741832_1008, replicas=127.0.0.1:34033 for /rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data
2024-02-22 19:48:54,692 INFO  [DataXceiver for client DFSClient_NONMAPREDUCE_-549788326_1 at /127.0.0.1:53324 [Receiving block BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008]] datanode.DataNode (DataXceiver.java:writeBlock(704)) - Receiving BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008 src: /127.0.0.1:53324 dest: /127.0.0.1:34033
2024-02-22 19:48:54,695 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008, type=LAST_IN_PIPELINE] DataNode.clienttrace (BlockReceiver.java:finalizeBlock(1454)) - src: /127.0.0.1:53324, dest: /127.0.0.1:34033, bytes: 122, op: HDFS_WRITE, cliID: DFSClient_NONMAPREDUCE_-549788326_1, offset: 0, srvID: 7e99c4f5-4c3d-4f19-b9ae-d66deb3c411d, blockid: BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008, duration: 2299448
2024-02-22 19:48:54,695 INFO  [PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008, type=LAST_IN_PIPELINE] datanode.DataNode (BlockReceiver.java:run(1427)) - PacketResponder: BP-253271122-127.0.0.1-1708631322406:blk_1073741832_1008, type=LAST_IN_PIPELINE terminating
2024-02-22 19:48:54,698 INFO  [IPC Server handler 5 on 37225] namenode.FSNamesystem (FSNamesystem.java:checkBlocksComplete(2768)) - BLOCK* blk_1073741832_1008 is COMMITTED but not COMPLETE(numNodes= 0 <  minimum = 1) in file /rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data
2024-02-22 19:48:54,759 INFO  [SimpleClusterManager-0] coordinator.SimpleClusterManager (SimpleClusterManager.java:nodesCheck(162)) - Alive servers number: 1, ids: [10.1.0.17-20001-21010]
2024-02-22 19:48:54,790 WARN  [ReconfigurableThread-0] config.ReconfigurableBase (ReconfigurableBase.java:checkConfiguration(60)) - Config file name isn't set, we skip checking
2024-02-22 19:48:54,839 INFO  [Executor task launch worker for task 0.0 in stage 3.0 (TID 4)] writer.RssShuffleWriter (RssShuffleWriter.java:writeImpl(296)) - Finish write shuffle for appId[local-1708631330011_1708631329981], shuffleId[1], taskId[4_0] with write 202 ms, include checkSendResult[1], commit[201], WriteBufferManager cost copyTime[0], writeTime[0], serializeTime[0], compressTime[0], estimateTime[0], requireMemoryTime[0], uncompressedDataLen[126]
2024-02-22 19:48:54,839 INFO  [Grpc-0] server.ShuffleServerGrpcService (ShuffleServerGrpcService.java:reportShuffleResult(499)) - Report 2 blocks as shuffle result for the task of appId[local-1708631330011_1708631329981], shuffleId[1], taskAttemptId[0]
2024-02-22 19:48:54,839 INFO  [Executor task launch worker for task 0.0 in stage 3.0 (TID 4)] impl.ShuffleWriteClientImpl (ShuffleWriteClientImpl.java:reportShuffleResult(703)) - Report shuffle result to ShuffleServerInfo{host[10.1.0.17], grpc port[20001], netty port[21010]} for appId[local-1708631330011_1708631329981], shuffleId[1] successfully
2024-02-22 19:48:54,839 INFO  [Executor task launch worker for task 0.0 in stage 3.0 (TID 4)] writer.RssShuffleWriter (RssShuffleWriter.java:stop(576)) - Report shuffle result for task[0] with bitmapNum[1] cost 0 ms
2024-02-22 19:48:54,840 INFO  [Executor task launch worker for task 0.0 in stage 3.0 (TID 4)] executor.Executor (Logging.scala:logInfo(57)) - Finished task 0.0 in stage 3.0 (TID 4). 1419 bytes result sent to driver
2024-02-22 19:48:54,840 INFO  [task-result-getter-0] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Finished task 0.0 in stage 3.0 (TID 4) in 264 ms on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net (executor driver) (1/2)
2024-02-22 19:48:54,844 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] writer.RssShuffleWriter (RssShuffleWriter.java:sendCommit(538)) - Wait commit to shuffle server for task[4] cost 200 ms
2024-02-22 19:48:55,099 INFO  [IPC Server handler 2 on 37225] hdfs.StateChange (FSDirWriteFileOp.java:completeFile(605)) - DIR* completeFile: /rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data is closed by DFSClient_NONMAPREDUCE_-549788326_1
2024-02-22 19:48:55,245 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] writer.RssShuffleWriter (RssShuffleWriter.java:sendCommit(538)) - Wait commit to shuffle server for task[4] cost 601 ms
2024-02-22 19:48:55,645 INFO  [Grpc-7] server.ShuffleTaskManager (ShuffleTaskManager.java:commitShuffle(354)) - Checking commit result for appId[local-1708631330011_1708631329981], shuffleId[1], expect committed[4], remain[4]
2024-02-22 19:48:55,645 INFO  [Grpc-7] server.ShuffleTaskManager (ShuffleTaskManager.java:commitShuffle(366)) - Finish commit for appId[local-1708631330011_1708631329981], shuffleId[1] with expectedCommitted[4], cost 1000 ms to check
2024-02-22 19:48:55,646 INFO  [ForkJoinPool-31-worker-1] grpc.ShuffleServerGrpcClient (ShuffleServerGrpcClient.java:finishShuffle(637)) - FinishShuffle to 10.1.0.17:20001 for appId[local-1708631330011_1708631329981], shuffleId[1] cost 1001 ms
2024-02-22 19:48:55,646 INFO  [ForkJoinPool-31-worker-1] impl.ShuffleWriteClientImpl (ShuffleWriteClientImpl.java:lambda$null$18(492)) - Successfully finish shuffle to ShuffleServerInfo{host[10.1.0.17], grpc port[20001], netty port[21010]} for shuffleId[1]
2024-02-22 19:48:56,035 INFO  [Grpc-2] server.ShuffleServerGrpcService (ShuffleServerGrpcService.java:appHeartbeat(477)) - Get heartbeat from local-1708631330011_1708631329981
2024-02-22 19:48:56,035 INFO  [client-heartbeat-1] impl.ShuffleWriteClientImpl (ShuffleWriteClientImpl.java:lambda$sendAppHeartbeat$26(923)) - Successfully send heartbeat to Coordinator grpc client ref to 10.1.0.17:19999
2024-02-22 19:48:56,035 INFO  [rss-heartbeat-0] shuffle.RssShuffleManager (RssShuffleManager.java:lambda$startHeartbeat$4(987)) - Finish send heartbeat to coordinator and servers
2024-02-22 19:48:56,045 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] writer.RssShuffleWriter (RssShuffleWriter.java:writeImpl(296)) - Finish write shuffle for appId[local-1708631330011_1708631329981], shuffleId[1], taskId[5_0] with write 1403 ms, include checkSendResult[2], commit[1401], WriteBufferManager cost copyTime[0], writeTime[0], serializeTime[0], compressTime[0], estimateTime[0], requireMemoryTime[0], uncompressedDataLen[126]
2024-02-22 19:48:56,045 INFO  [Grpc-6] server.ShuffleServerGrpcService (ShuffleServerGrpcService.java:reportShuffleResult(499)) - Report 2 blocks as shuffle result for the task of appId[local-1708631330011_1708631329981], shuffleId[1], taskAttemptId[4]
2024-02-22 19:48:56,046 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] impl.ShuffleWriteClientImpl (ShuffleWriteClientImpl.java:reportShuffleResult(703)) - Report shuffle result to ShuffleServerInfo{host[10.1.0.17], grpc port[20001], netty port[21010]} for appId[local-1708631330011_1708631329981], shuffleId[1] successfully
2024-02-22 19:48:56,046 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] writer.RssShuffleWriter (RssShuffleWriter.java:stop(576)) - Report shuffle result for task[4] with bitmapNum[1] cost 1 ms
2024-02-22 19:48:56,046 INFO  [Executor task launch worker for task 1.0 in stage 3.0 (TID 5)] executor.Executor (Logging.scala:logInfo(57)) - Finished task 1.0 in stage 3.0 (TID 5). 1419 bytes result sent to driver
2024-02-22 19:48:56,047 INFO  [task-result-getter-1] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Finished task 1.0 in stage 3.0 (TID 5) in 1471 ms on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net (executor driver) (2/2)
2024-02-22 19:48:56,047 INFO  [task-result-getter-1] scheduler.TaskSchedulerImpl (Logging.scala:logInfo(57)) - Removed TaskSet 3.0, whose tasks have all completed, from pool 
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - ShuffleMapStage 3 (groupByKey at ShuffleUnregisterWithHadoopTest.java:79) finished in 1.473 s
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - looking for newly runnable stages
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - running: Set()
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - waiting: Set(ResultStage 4)
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - failed: Set()
2024-02-22 19:48:56,047 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - Submitting ResultStage 4 (ShuffledRDD[5] at sortByKey at ShuffleUnregisterWithHadoopTest.java:79), which has no missing parents
2024-02-22 19:48:56,048 INFO  [dag-scheduler-event-loop] memory.MemoryStore (Logging.scala:logInfo(57)) - Block broadcast_5 stored as values in memory (estimated size 5.3 KiB, free 1458.6 MiB)
2024-02-22 19:48:56,049 INFO  [dag-scheduler-event-loop] memory.MemoryStore (Logging.scala:logInfo(57)) - Block broadcast_5_piece0 stored as bytes in memory (estimated size 3.2 KiB, free 1458.6 MiB)
2024-02-22 19:48:56,049 INFO  [dispatcher-BlockManagerMaster] storage.BlockManagerInfo (Logging.scala:logInfo(57)) - Added broadcast_5_piece0 in memory on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net:33789 (size: 3.2 KiB, free: 1458.6 MiB)
2024-02-22 19:48:56,049 INFO  [dag-scheduler-event-loop] spark.SparkContext (Logging.scala:logInfo(57)) - Created broadcast 5 from broadcast at DAGScheduler.scala:1388
2024-02-22 19:48:56,050 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - Submitting 2 missing tasks from ResultStage 4 (ShuffledRDD[5] at sortByKey at ShuffleUnregisterWithHadoopTest.java:79) (first 15 tasks are for partitions Vector(0, 1))
2024-02-22 19:48:56,050 INFO  [dag-scheduler-event-loop] scheduler.TaskSchedulerImpl (Logging.scala:logInfo(57)) - Adding task set 4.0 with 2 tasks resource profile 0
2024-02-22 19:48:56,050 INFO  [dispatcher-event-loop-1] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Starting task 0.0 in stage 4.0 (TID 6) (fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net, executor driver, partition 0, ANY, 4271 bytes) taskResourceAssignments Map()
2024-02-22 19:48:56,050 INFO  [dispatcher-event-loop-1] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Starting task 1.0 in stage 4.0 (TID 7) (fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net, executor driver, partition 1, ANY, 4271 bytes) taskResourceAssignments Map()
2024-02-22 19:48:56,050 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] executor.Executor (Logging.scala:logInfo(57)) - Running task 0.0 in stage 4.0 (TID 6)
2024-02-22 19:48:56,050 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] executor.Executor (Logging.scala:logInfo(57)) - Running task 1.0 in stage 4.0 (TID 7)
2024-02-22 19:48:56,051 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] shuffle.RssShuffleManager (RssShuffleManager.java:getReader(620)) - Get taskId cost 0 ms, and request expected blockIds from 2 tasks for shuffleId[1], partitionId[1, 2]
2024-02-22 19:48:56,051 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] shuffle.RssShuffleManager (RssShuffleManager.java:getReader(620)) - Get taskId cost 0 ms, and request expected blockIds from 2 tasks for shuffleId[1], partitionId[0, 1]
2024-02-22 19:48:56,052 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] shuffle.RssShuffleManager (RssShuffleManager.java:getReaderImpl(721)) - Get shuffle blockId cost 1 ms, and get 2 blockIds for shuffleId[1], startPartition[0], endPartition[1]
2024-02-22 19:48:56,053 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] shuffle.RssShuffleManager (RssShuffleManager.java:getReaderImpl(742)) - Shuffle reader using remote storage hdfs://localhost:37225/rss/test,empty conf
2024-02-22 19:48:56,052 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] shuffle.RssShuffleManager (RssShuffleManager.java:getReaderImpl(721)) - Get shuffle blockId cost 1 ms, and get 2 blockIds for shuffleId[1], startPartition[1], endPartition[2]
2024-02-22 19:48:56,053 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] shuffle.RssShuffleManager (RssShuffleManager.java:getReaderImpl(742)) - Shuffle reader using remote storage hdfs://localhost:37225/rss/test,empty conf
2024-02-22 19:48:56,080 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] reader.RssShuffleReader (RssShuffleReader.java:read(124)) - Shuffle read started:appId=local-1708631330011_1708631329981, shuffleId=1,taskId=7_0, partitions: [1, 2), maps: [0, 2147483647)
2024-02-22 19:48:56,080 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] reader.RssShuffleReader (RssShuffleReader.java:read(153)) - Inserting aggregated records to sorter
2024-02-22 19:48:56,089 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] reader.RssShuffleReader (RssShuffleReader.java:read(124)) - Shuffle read started:appId=local-1708631330011_1708631329981, shuffleId=1,taskId=6_0, partitions: [0, 1), maps: [0, 2147483647)
2024-02-22 19:48:56,089 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] reader.RssShuffleReader (RssShuffleReader.java:read(153)) - Inserting aggregated records to sorter
2024-02-22 19:48:56,090 INFO  [IPC Server handler 2 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=listStatus	src=/rss/test/local-1708631330011_1708631329981/1/1-1	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,090 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] impl.HadoopClientReadHandler (HadoopClientReadHandler.java:init(156)) - Find index file for shuffleId[1], partitionId[1] hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index
2024-02-22 19:48:56,091 INFO  [IPC Server handler 9 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,092 INFO  [IPC Server handler 4 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=open	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,093 INFO  [IPC Server handler 8 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,093 INFO  [IPC Server handler 3 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=open	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,094 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] impl.HadoopClientReadHandler (HadoopClientReadHandler.java:init(184)) - Reading order of Hadoop files with name prefix: [hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0]
2024-02-22 19:48:56,095 INFO  [IPC Server handler 6 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,095 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] impl.HadoopShuffleReadHandler (HadoopShuffleReadHandler.java:readShuffleIndex(124)) - Read index files hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/1-1/10.1.0.17-20001-21010_0_0.index for 1 ms
2024-02-22 19:48:56,099 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] impl.ShuffleReadClientImpl (ShuffleReadClientImpl.java:logStatics(313)) - Metrics for shuffleId[1], partitionId[1], read data cost 16 ms, copy data cost 0 ms, crc check cost 0 ms
2024-02-22 19:48:56,099 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] impl.AbstractClientReadHandler (AbstractClientReadHandler.java:logConsumedBlockInfo(54)) - Client read [2 blocks, bytes:122 uncompressed bytes:126], skipped[0 blocks, bytes:0 uncompressed bytes:0]
2024-02-22 19:48:56,099 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] reader.RssShuffleDataIterator (RssShuffleDataIterator.java:hasNext(141)) - Fetch 122 bytes cost 16 ms and 1 ms to serialize, 0 ms to decompress with unCompressionLength[126]
2024-02-22 19:48:56,099 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] reader.RssShuffleReader (RssShuffleReader.java:read(156)) - Inserted aggregated records to sorter: millis:19
2024-02-22 19:48:56,099 INFO  [Executor task launch worker for task 1.0 in stage 4.0 (TID 7)] executor.Executor (Logging.scala:logInfo(57)) - Finished task 1.0 in stage 4.0 (TID 7). 1269 bytes result sent to driver
2024-02-22 19:48:56,100 INFO  [task-result-getter-2] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Finished task 1.0 in stage 4.0 (TID 7) in 50 ms on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net (executor driver) (1/2)
2024-02-22 19:48:56,101 INFO  [IPC Server handler 7 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=listStatus	src=/rss/test/local-1708631330011_1708631329981/1/0-0	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,102 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] impl.HadoopClientReadHandler (HadoopClientReadHandler.java:init(156)) - Find index file for shuffleId[1], partitionId[0] hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.index
2024-02-22 19:48:56,102 INFO  [IPC Server handler 5 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,103 INFO  [IPC Server handler 1 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=open	src=/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.index	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,104 INFO  [IPC Server handler 0 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,104 INFO  [IPC Server handler 2 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=open	src=/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,105 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] impl.HadoopClientReadHandler (HadoopClientReadHandler.java:init(184)) - Reading order of Hadoop files with name prefix: [hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0]
2024-02-22 19:48:56,106 INFO  [IPC Server handler 9 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.data	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,106 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] impl.HadoopShuffleReadHandler (HadoopShuffleReadHandler.java:readShuffleIndex(124)) - Read index files hdfs://localhost:37225/rss/test/local-1708631330011_1708631329981/1/0-0/10.1.0.17-20001-21010_0_0.index for 1 ms
2024-02-22 19:48:56,108 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] impl.ShuffleReadClientImpl (ShuffleReadClientImpl.java:logStatics(313)) - Metrics for shuffleId[1], partitionId[0], read data cost 18 ms, copy data cost 0 ms, crc check cost 0 ms
2024-02-22 19:48:56,108 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] impl.AbstractClientReadHandler (AbstractClientReadHandler.java:logConsumedBlockInfo(54)) - Client read [2 blocks, bytes:122 uncompressed bytes:126], skipped[0 blocks, bytes:0 uncompressed bytes:0]
2024-02-22 19:48:56,108 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] reader.RssShuffleDataIterator (RssShuffleDataIterator.java:hasNext(141)) - Fetch 122 bytes cost 18 ms and 1 ms to serialize, 0 ms to decompress with unCompressionLength[126]
2024-02-22 19:48:56,108 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] reader.RssShuffleReader (RssShuffleReader.java:read(156)) - Inserted aggregated records to sorter: millis:19
2024-02-22 19:48:56,109 INFO  [Executor task launch worker for task 0.0 in stage 4.0 (TID 6)] executor.Executor (Logging.scala:logInfo(57)) - Finished task 0.0 in stage 4.0 (TID 6). 1269 bytes result sent to driver
2024-02-22 19:48:56,109 INFO  [task-result-getter-3] scheduler.TaskSetManager (Logging.scala:logInfo(57)) - Finished task 0.0 in stage 4.0 (TID 6) in 59 ms on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net (executor driver) (2/2)
2024-02-22 19:48:56,109 INFO  [task-result-getter-3] scheduler.TaskSchedulerImpl (Logging.scala:logInfo(57)) - Removed TaskSet 4.0, whose tasks have all completed, from pool 
2024-02-22 19:48:56,109 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - ResultStage 4 (collectAsMap at ShuffleUnregisterWithHadoopTest.java:80) finished in 0.061 s
2024-02-22 19:48:56,109 INFO  [dag-scheduler-event-loop] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - Job 1 is finished. Cancelling potential speculative or zombie tasks for this job
2024-02-22 19:48:56,109 INFO  [dag-scheduler-event-loop] scheduler.TaskSchedulerImpl (Logging.scala:logInfo(57)) - Killing all running tasks in stage 4: Stage finished
2024-02-22 19:48:56,110 INFO  [main] scheduler.DAGScheduler (Logging.scala:logInfo(57)) - Job 1 finished: collectAsMap at ShuffleUnregisterWithHadoopTest.java:80, took 1.542082 s
2024-02-22 19:48:56,110 INFO  [IPC Server handler 4 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=listStatus	src=/rss/test	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,111 INFO  [IPC Server handler 8 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/0	dst=null	perm=null	proto=rpc
2024-02-22 19:48:56,171 WARN  [unregister-shuffle-0] impl.ShuffleWriteClientImpl (ShuffleWriteClientImpl.java:lambda$unregisterShuffle$27(973)) - Error happened when unregistering to ShuffleServerInfo{host[10.1.0.17], grpc port[20001], netty port[21010]}
io.grpc.StatusRuntimeException: CANCELLED: Thread interrupted
	at io.grpc.stub.ClientCalls.toStatusRuntimeException(ClientCalls.java:268)
	at io.grpc.stub.ClientCalls.getUnchecked(ClientCalls.java:249)
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:167)
	at org.apache.uniffle.proto.ShuffleServerGrpc$ShuffleServerBlockingStub.unregisterShuffle(ShuffleServerGrpc.java:765)
	at org.apache.uniffle.client.impl.grpc.ShuffleServerGrpcClient.doUnregisterShuffle(ShuffleServerGrpcClient.java:371)
	at org.apache.uniffle.client.impl.grpc.ShuffleServerGrpcClient.unregisterShuffle(ShuffleServerGrpcClient.java:377)
	at org.apache.uniffle.client.impl.ShuffleWriteClientImpl.lambda$unregisterShuffle$27(ShuffleWriteClientImpl.java:968)
	at org.apache.uniffle.common.util.ThreadUtils.lambda$null$0(ThreadUtils.java:110)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:750)
Caused by: java.lang.InterruptedException
	at io.grpc.stub.ClientCalls$ThreadlessExecutor.throwIfInterrupted(ClientCalls.java:750)
	at io.grpc.stub.ClientCalls$ThreadlessExecutor.waitAndDrain(ClientCalls.java:711)
	at io.grpc.stub.ClientCalls.blockingUnaryCall(ClientCalls.java:159)
	... 9 more
2024-02-22 19:48:56,172 INFO  [dispatcher-BlockManagerMaster] storage.BlockManagerInfo (Logging.scala:logInfo(57)) - Removed broadcast_5_piece0 on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net:33789 in memory (size: 3.2 KiB, free: 1458.6 MiB)
2024-02-22 19:48:56,174 INFO  [dispatcher-BlockManagerMaster] storage.BlockManagerInfo (Logging.scala:logInfo(57)) - Removed broadcast_4_piece0 on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net:33789 in memory (size: 4.5 KiB, free: 1458.6 MiB)
2024-02-22 19:48:56,175 INFO  [dispatcher-BlockManagerMaster] storage.BlockManagerInfo (Logging.scala:logInfo(57)) - Removed broadcast_2_piece0 on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net:33789 in memory (size: 4.6 KiB, free: 1458.6 MiB)
2024-02-22 19:48:56,177 INFO  [dispatcher-BlockManagerMaster] storage.BlockManagerInfo (Logging.scala:logInfo(57)) - Removed broadcast_1_piece0 on fv-az1243-116.pw5g10og0bkuhgysqdgndzj0hc.ex.internal.cloudapp.net:33789 in memory (size: 3.3 KiB, free: 1458.6 MiB)
2024-02-22 19:48:57,172 INFO  [IPC Server handler 3 on 37225] FSNamesystem.audit (FSNamesystem.java:logAuditMessage(7695)) - allowed=true	ugi=runner (auth:SIMPLE)	ip=/127.0.0.1	cmd=getfileinfo	src=/rss/test/local-1708631330011_1708631329981/0	dst=null	perm=null	proto=rpc

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

1 skipped test found 

There is 1 skipped test, see "Raw output" for the name of the skipped test.
Raw output 
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ rpcMetricsTest

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

823 tests found (test 1 to 758) 

There are 823 tests, see "Raw output" for the list of tests 1 to 758.
Raw output 
org.apache.hadoop.mapred.SortWriteBufferManagerTest ‑ testCombineBuffer
org.apache.hadoop.mapred.SortWriteBufferManagerTest ‑ testCommitBlocksWhenMemoryShuffleDisabled
org.apache.hadoop.mapred.SortWriteBufferManagerTest ‑ testOnePartition
org.apache.hadoop.mapred.SortWriteBufferManagerTest ‑ testWriteException
org.apache.hadoop.mapred.SortWriteBufferManagerTest ‑ testWriteNormal
org.apache.hadoop.mapred.SortWriteBufferTest ‑ testReadWrite
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ applyDynamicClientConfTest
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ baskAttemptIdTest
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ blockConvertTest
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ partitionIdConvertBlockTest
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ testEstimateTaskConcurrency
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ testGetRequiredShuffleServerNumber
org.apache.hadoop.mapreduce.RssMRUtilsTest ‑ testValidateRssClientConf
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ extraEventFetch
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ missingEventFetch
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ multiPassEventFetch
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ obsoletedAndTipFailedEventFetch
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ singlePassEventFetch
org.apache.hadoop.mapreduce.task.reduce.EventFetcherTest ‑ singlePassWithRepeatedSuccessEventFetch
org.apache.hadoop.mapreduce.task.reduce.FetcherTest ‑ testCodecIsDuplicated
org.apache.hadoop.mapreduce.task.reduce.FetcherTest ‑ writeAndReadDataMergeFailsTestWithRss
org.apache.hadoop.mapreduce.task.reduce.FetcherTest ‑ writeAndReadDataTestWithRss
org.apache.hadoop.mapreduce.task.reduce.FetcherTest ‑ writeAndReadDataTestWithoutRss
org.apache.hadoop.mapreduce.task.reduce.RssInMemoryRemoteMergerTest ‑ mergerTest{File}
org.apache.hadoop.mapreduce.task.reduce.RssRemoteMergeManagerTest ‑ mergerTest{File}
org.apache.spark.shuffle.DelegationRssShuffleManagerTest ‑ testCreateFallback
org.apache.spark.shuffle.DelegationRssShuffleManagerTest ‑ testCreateInDriver
org.apache.spark.shuffle.DelegationRssShuffleManagerTest ‑ testCreateInDriverDenied
org.apache.spark.shuffle.DelegationRssShuffleManagerTest ‑ testCreateInExecutor
org.apache.spark.shuffle.DelegationRssShuffleManagerTest ‑ testTryAccessCluster
org.apache.spark.shuffle.RssShuffleManagerTest ‑ testCreateShuffleManagerServer
org.apache.spark.shuffle.RssShuffleManagerTest ‑ testGetDataDistributionType
org.apache.spark.shuffle.RssShuffleManagerTest ‑ testGetTaskAttemptIdWithSpeculation
org.apache.spark.shuffle.RssShuffleManagerTest ‑ testGetTaskAttemptIdWithoutSpeculation
org.apache.spark.shuffle.RssShuffleManagerTest ‑ testRssShuffleManagerInterface
org.apache.spark.shuffle.RssSpark2ShuffleUtilsTest ‑ testCreateFetchFailedException
org.apache.spark.shuffle.RssSpark2ShuffleUtilsTest ‑ testIsStageResubmitSupported
org.apache.spark.shuffle.RssSpark3ShuffleUtilsTest ‑ testCreateFetchFailedException
org.apache.spark.shuffle.RssSpark3ShuffleUtilsTest ‑ testIsStageResubmitSupported
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ applyDynamicClientConfTest
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ odfsConfigurationTest
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ testAssignmentTags
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ testEstimateTaskConcurrency
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ testGetRequiredShuffleServerNumber
org.apache.spark.shuffle.RssSparkShuffleUtilsTest ‑ testValidateRssClientConf
org.apache.spark.shuffle.SparkVersionUtilsTest ‑ testSpark3Version
org.apache.spark.shuffle.SparkVersionUtilsTest ‑ testSparkVersion
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ cleanup
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest1
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest2
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest3
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest4
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest5
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTest7
org.apache.spark.shuffle.reader.RssShuffleDataIteratorTest ‑ readTestUncompressedShuffle
org.apache.spark.shuffle.reader.RssShuffleReaderTest ‑ readTest
org.apache.spark.shuffle.writer.DataPusherTest ‑ testSendData
org.apache.spark.shuffle.writer.RssShuffleWriterTest ‑ checkBlockSendResultTest
org.apache.spark.shuffle.writer.RssShuffleWriterTest ‑ dataConsistencyWhenSpillTriggeredTest
org.apache.spark.shuffle.writer.RssShuffleWriterTest ‑ postBlockEventTest
org.apache.spark.shuffle.writer.RssShuffleWriterTest ‑ writeTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addFirstRecordWithLargeSizeTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addHugeRecordTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addNullValueRecordTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addPartitionDataTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addRecordCompressedTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ addRecordUnCompressedTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ buildBlockEventsTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ createBlockIdTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ spillByOthersTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ spillByOwnTest
org.apache.spark.shuffle.writer.WriteBufferManagerTest ‑ spillByOwnWithSparkTaskMemoryManagerTest
org.apache.spark.shuffle.writer.WriteBufferTest ‑ test
org.apache.tez.common.GetShuffleServerRequestTest ‑ testSerDe
org.apache.tez.common.GetShuffleServerResponseTest ‑ testSerDe
org.apache.tez.common.IdUtilsTest ‑ testConvertTezTaskAttemptID
org.apache.tez.common.InputContextUtilsTest ‑ testGetTezTaskAttemptID
org.apache.tez.common.RssTezUtilsTest ‑ attemptTaskIdTest
org.apache.tez.common.RssTezUtilsTest ‑ baskAttemptIdTest
org.apache.tez.common.RssTezUtilsTest ‑ blockConvertTest
org.apache.tez.common.RssTezUtilsTest ‑ testApplyDynamicClientConf
org.apache.tez.common.RssTezUtilsTest ‑ testComputeShuffleId
org.apache.tez.common.RssTezUtilsTest ‑ testEstimateTaskConcurrency
org.apache.tez.common.RssTezUtilsTest ‑ testFilterRssConf
org.apache.tez.common.RssTezUtilsTest ‑ testGetRequiredShuffleServerNumber
org.apache.tez.common.RssTezUtilsTest ‑ testParseDagId
org.apache.tez.common.RssTezUtilsTest ‑ testParseRssWorker
org.apache.tez.common.RssTezUtilsTest ‑ testPartitionIdConvertBlock
org.apache.tez.common.RssTezUtilsTest ‑ testTaskIdStrToTaskId
org.apache.tez.common.ShuffleAssignmentsInfoWritableTest ‑ testSerDe
org.apache.tez.common.TezIdHelperTest ‑ testTetTaskAttemptId
org.apache.tez.dag.app.RssDAGAppMasterTest ‑ testDagStateChangeCallback
org.apache.tez.dag.app.RssDAGAppMasterTest ‑ testFetchRemoteStorageFromCoordinator
org.apache.tez.dag.app.RssDAGAppMasterTest ‑ testFetchRemoteStorageFromDynamicConf
org.apache.tez.dag.app.TezRemoteShuffleManagerTest ‑ testTezRemoteShuffleManager
org.apache.tez.dag.app.TezRemoteShuffleManagerTest ‑ testTezRemoteShuffleManagerSecure
org.apache.tez.runtime.library.common.shuffle.impl.RssShuffleManagerTest ‑ testFetchFailed
org.apache.tez.runtime.library.common.shuffle.impl.RssShuffleManagerTest ‑ testProgressWithEmptyPendingHosts
org.apache.tez.runtime.library.common.shuffle.impl.RssShuffleManagerTest ‑ testUseSharedExecutor
org.apache.tez.runtime.library.common.shuffle.impl.RssSimpleFetchedInputAllocatorTest ‑ testAllocate{File}
org.apache.tez.runtime.library.common.shuffle.impl.RssTezFetcherTest ‑ testReadWithDiskFetchedInput{File}
org.apache.tez.runtime.library.common.shuffle.impl.RssTezFetcherTest ‑ testReadWithRemoteFetchedInput{File}
org.apache.tez.runtime.library.common.shuffle.impl.RssTezFetcherTest ‑ writeAndReadDataTestWithoutRss
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssInMemoryMergerTest ‑ mergerTest
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssMergeManagerTest ‑ mergerTest
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testPenalty
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testProgressDuringGetHostWait
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth1
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth2
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth3
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth4
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth5
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth6
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testReducerHealth7
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleSchedulerTest ‑ testShutdownWithInterrupt
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleTest ‑ testKillSelf
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssShuffleTest ‑ testSchedulerTerminatesOnException
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssTezBypassWriterTest ‑ testCalcChecksum
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssTezBypassWriterTest ‑ testWrite
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssTezBypassWriterTest ‑ testWriteDiskFetchInput{File}
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssTezBypassWriterTest ‑ testWriteRemoteFetchInput
org.apache.tez.runtime.library.common.shuffle.orderedgrouped.RssTezShuffleDataFetcherTest ‑ testIteratorWithInMemoryReader
org.apache.tez.runtime.library.common.sort.buffer.WriteBufferManagerTest ‑ testCommitBlocksWhenMemoryShuffleDisabled{File}
org.apache.tez.runtime.library.common.sort.buffer.WriteBufferManagerTest ‑ testFailFastWhenFailedToSendBlocks{File}
org.apache.tez.runtime.library.common.sort.buffer.WriteBufferManagerTest ‑ testWriteException{File}
org.apache.tez.runtime.library.common.sort.buffer.WriteBufferManagerTest ‑ testWriteNormal{File}
org.apache.tez.runtime.library.common.sort.buffer.WriteBufferTest ‑ testReadWrite
org.apache.tez.runtime.library.common.sort.impl.RssSorterTest ‑ testCollectAndRecordsPerPartition
org.apache.tez.runtime.library.common.sort.impl.RssTezPerPartitionRecordTest ‑ testNumPartitions
org.apache.tez.runtime.library.common.sort.impl.RssTezPerPartitionRecordTest ‑ testRssTezIndexHasData
org.apache.tez.runtime.library.common.sort.impl.RssUnSorterTest ‑ testCollectAndRecordsPerPartition
org.apache.tez.runtime.library.input.RssOrderedGroupedKVInputTest ‑ testInterruptWhileAwaitingInput
org.apache.tez.runtime.library.input.RssSortedGroupedMergedInputTest ‑ testSimpleConcatenatedMergedKeyValueInput
org.apache.tez.runtime.library.input.RssSortedGroupedMergedInputTest ‑ testSimpleConcatenatedMergedKeyValuesInput
org.apache.tez.runtime.library.output.RssOrderedPartitionedKVOutputTest ‑ testClose
org.apache.tez.runtime.library.output.RssOrderedPartitionedKVOutputTest ‑ testNonStartedOutput
org.apache.tez.runtime.library.output.RssUnorderedKVOutputTest ‑ testClose
org.apache.tez.runtime.library.output.RssUnorderedKVOutputTest ‑ testNonStartedOutput
org.apache.tez.runtime.library.output.RssUnorderedPartitionedKVOutputTest ‑ testClose
org.apache.tez.runtime.library.output.RssUnorderedPartitionedKVOutputTest ‑ testNonStartedOutput
org.apache.uniffle.cli.AdminRestApiTest ‑ testRunRefreshAccessChecker
org.apache.uniffle.cli.CLIContentUtilsTest ‑ testTableFormat
org.apache.uniffle.cli.UniffleTestAdminCLI ‑ testAdminRefreshCLI
org.apache.uniffle.cli.UniffleTestAdminCLI ‑ testMissingClientCLI
org.apache.uniffle.cli.UniffleTestCLI ‑ testExampleCLI
org.apache.uniffle.cli.UniffleTestCLI ‑ testHelp
org.apache.uniffle.client.ClientUtilsTest ‑ getBlockIdTest
org.apache.uniffle.client.ClientUtilsTest ‑ testGenerateTaskIdBitMap
org.apache.uniffle.client.ClientUtilsTest ‑ testValidateClientType
org.apache.uniffle.client.ClientUtilsTest ‑ testWaitUntilDoneOrFail
org.apache.uniffle.client.factory.ShuffleManagerClientFactoryTest ‑ createShuffleManagerClient
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest1
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest10
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest11
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest12
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest13
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest14
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest15
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest2
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest3
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest4
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest5
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest7
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest8
org.apache.uniffle.client.impl.ShuffleReadClientImplTest ‑ readTest9
org.apache.uniffle.client.impl.ShuffleWriteClientImplTest ‑ testAbandonEventWhenTaskFailed
org.apache.uniffle.client.impl.ShuffleWriteClientImplTest ‑ testRegisterAndUnRegisterShuffleServer
org.apache.uniffle.client.impl.ShuffleWriteClientImplTest ‑ testSendData
org.apache.uniffle.client.impl.ShuffleWriteClientImplTest ‑ testSendDataWithDefectiveServers
org.apache.uniffle.client.impl.ShuffleWriteClientImplTest ‑ testSettingRssClientConfigs
org.apache.uniffle.common.ArgumentsTest ‑ argEmptyTest
org.apache.uniffle.common.ArgumentsTest ‑ argTest
org.apache.uniffle.common.BufferSegmentTest ‑ testEquals
org.apache.uniffle.common.BufferSegmentTest ‑ testGetOffset
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[1]
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[2]
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[3]
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[4]
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[5]
org.apache.uniffle.common.BufferSegmentTest ‑ testNotEquals{long, long, int, int, long, long}[6]
org.apache.uniffle.common.BufferSegmentTest ‑ testToString
org.apache.uniffle.common.PartitionRangeTest ‑ testCompareTo
org.apache.uniffle.common.PartitionRangeTest ‑ testEquals
org.apache.uniffle.common.PartitionRangeTest ‑ testHashCode
org.apache.uniffle.common.PartitionRangeTest ‑ testPartitionRange
org.apache.uniffle.common.PartitionRangeTest ‑ testToString
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testEmptyStoragePath{String}[1]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testEmptyStoragePath{String}[2]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testEquals
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testHashCode
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testNotEquals{String}[1]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testNotEquals{String}[2]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testNotEquals{String}[3]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testRemoteStorageInfo{String, Map, String}[1]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testRemoteStorageInfo{String, Map, String}[2]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testRemoteStorageInfo{String, Map, String}[3]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testUncommonConfString{String}[1]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testUncommonConfString{String}[2]
org.apache.uniffle.common.RemoteStorageInfoTest ‑ testUncommonConfString{String}[3]
org.apache.uniffle.common.ServerStatusTest ‑ test
org.apache.uniffle.common.ShuffleBlockInfoTest ‑ testToString
org.apache.uniffle.common.ShuffleDataResultTest ‑ testEmpty
org.apache.uniffle.common.ShuffleIndexResultTest ‑ testEmpty
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ shufflePartitionedBlockTest
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testEquals
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testNotEquals{int, long, long, int}[1]
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testNotEquals{int, long, long, int}[2]
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testNotEquals{int, long, long, int}[3]
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testNotEquals{int, long, long, int}[4]
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testSize
org.apache.uniffle.common.ShufflePartitionedBlockTest ‑ testToString
org.apache.uniffle.common.ShufflePartitionedDataTest ‑ testToString
org.apache.uniffle.common.ShuffleRegisterInfoTest ‑ testEquals
org.apache.uniffle.common.ShuffleRegisterInfoTest ‑ testToString
org.apache.uniffle.common.ShuffleServerInfoTest ‑ testEquals
org.apache.uniffle.common.ShuffleServerInfoTest ‑ testToString
org.apache.uniffle.common.UnionKeyTest ‑ test
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[10]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[11]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[12]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[13]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[14]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[15]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[16]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[17]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[18]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[19]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[1]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[20]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[21]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[22]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[23]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[24]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[2]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[3]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[4]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[5]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[6]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[7]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[8]
org.apache.uniffle.common.compression.CompressionTest ‑ testCompression{int, Type}[9]
org.apache.uniffle.common.config.ConfigOptionTest ‑ testBasicTypes
org.apache.uniffle.common.config.ConfigOptionTest ‑ testDeprecatedAndFallbackKeys
org.apache.uniffle.common.config.ConfigOptionTest ‑ testDeprecatedKeys
org.apache.uniffle.common.config.ConfigOptionTest ‑ testEnumType
org.apache.uniffle.common.config.ConfigOptionTest ‑ testFallbackKeys
org.apache.uniffle.common.config.ConfigOptionTest ‑ testListTypes
org.apache.uniffle.common.config.ConfigOptionTest ‑ testSetKVWithStringTypeDirectly
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[10]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[11]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[12]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[13]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToBoolean{Object, Boolean}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[10]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[11]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[12]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[13]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToDouble{Object, Double}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[10]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[11]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[12]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[13]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[14]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[15]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[16]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[17]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToFloat{Object, Float}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToInt{Object, Integer}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[10]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[11]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[12]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[13]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToLong{Object, Long}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[10]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[11]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[12]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[13]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[14]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToSizeInBytes{Object, long}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToString{Object, String}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToString{Object, String}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertToString{Object, String}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValueWithUnsupportedType
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testConvertValue{Object, Class}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testGetAllConfigOptions
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testNonNegativeLongValidator{long}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPercentageDoubleValidator{double}[9]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator2{int}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[6]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[7]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveIntegerValidator{long}[8]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[1]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[2]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[3]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[4]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[5]
org.apache.uniffle.common.config.ConfigUtilsTest ‑ testPositiveLongValidator{long}[6]
org.apache.uniffle.common.config.RssConfTest ‑ testOptionWithDefault
org.apache.uniffle.common.config.RssConfTest ‑ testOptionWithNoDefault
org.apache.uniffle.common.config.RssConfTest ‑ testSetStringAndGetConcreteType
org.apache.uniffle.common.filesystem.HadoopFilesystemProviderTest ‑ testGetSecuredFilesystem
org.apache.uniffle.common.filesystem.HadoopFilesystemProviderTest ‑ testGetSecuredFilesystemButNotInitializeHadoopSecurityContext
org.apache.uniffle.common.filesystem.HadoopFilesystemProviderTest ‑ testWriteAndReadBySecuredFilesystem
org.apache.uniffle.common.metrics.MetricReporterFactoryTest ‑ testGetMetricReporter
org.apache.uniffle.common.metrics.MetricsManagerTest ‑ testMetricsManager
org.apache.uniffle.common.metrics.prometheus.PrometheusPushGatewayMetricReporterTest ‑ test
org.apache.uniffle.common.metrics.prometheus.PrometheusPushGatewayMetricReporterTest ‑ testParseGroupingKey
org.apache.uniffle.common.metrics.prometheus.PrometheusPushGatewayMetricReporterTest ‑ testParseIncompleteGroupingKey
org.apache.uniffle.common.netty.EncoderAndDecoderTest ‑ test
org.apache.uniffle.common.netty.TransportFrameDecoderTest ‑ testShouldRpcRequestsToBeReleased
org.apache.uniffle.common.netty.TransportFrameDecoderTest ‑ testShouldRpcResponsesToBeReleased
org.apache.uniffle.common.netty.client.TransportClientFactoryTest ‑ testClientDiffPartition
org.apache.uniffle.common.netty.client.TransportClientFactoryTest ‑ testClientDiffServer
org.apache.uniffle.common.netty.client.TransportClientFactoryTest ‑ testClientReuse
org.apache.uniffle.common.netty.client.TransportClientFactoryTest ‑ testCreateClient
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetLocalShuffleDataRequest
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetLocalShuffleDataResponse
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetLocalShuffleIndexRequest
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetLocalShuffleIndexResponse
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetMemoryShuffleDataRequest
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testGetMemoryShuffleDataResponse
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testRpcResponse
org.apache.uniffle.common.netty.protocol.NettyProtocolTest ‑ testSendShuffleDataRequest
org.apache.uniffle.common.rpc.GrpcServerTest ‑ testGrpcExecutorPool
org.apache.uniffle.common.rpc.GrpcServerTest ‑ testRandomPort
org.apache.uniffle.common.rpc.StatusCodeTest ‑ test
org.apache.uniffle.common.security.HadoopSecurityContextTest ‑ testCreateIllegalContext
org.apache.uniffle.common.security.HadoopSecurityContextTest ‑ testSecuredCallable
org.apache.uniffle.common.security.HadoopSecurityContextTest ‑ testSecuredDisableProxyUser
org.apache.uniffle.common.security.HadoopSecurityContextTest ‑ testWithOutKrb5Conf
org.apache.uniffle.common.security.SecurityContextFactoryTest ‑ testCreateHadoopSecurityContext
org.apache.uniffle.common.security.SecurityContextFactoryTest ‑ testDefaultSecurityContext
org.apache.uniffle.common.segment.FixedSizeSegmentSplitterTest ‑ testAvoidEOFException{int}[1]
org.apache.uniffle.common.segment.FixedSizeSegmentSplitterTest ‑ testAvoidEOFException{int}[2]
org.apache.uniffle.common.segment.FixedSizeSegmentSplitterTest ‑ testAvoidEOFException{int}[3]
org.apache.uniffle.common.segment.FixedSizeSegmentSplitterTest ‑ testSplit
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[1]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[2]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[3]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[4]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[5]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testConsistentWithFixSizeSplitterWhenNoSkew{int}[6]
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testDiscontinuousMapTaskIds
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testSplit
org.apache.uniffle.common.segment.LocalOrderSegmentSplitterTest ‑ testSplitForMergeContinuousSegments
org.apache.uniffle.common.storage.StorageInfoUtilsTest ‑ testFromProto
org.apache.uniffle.common.storage.StorageInfoUtilsTest ‑ testToProto
org.apache.uniffle.common.util.ByteBufUtilsTest ‑ test
org.apache.uniffle.common.util.ChecksumUtilsTest ‑ crc32ByteBufferTest
org.apache.uniffle.common.util.ChecksumUtilsTest ‑ crc32TestWithByte
org.apache.uniffle.common.util.ChecksumUtilsTest ‑ crc32TestWithByteBuff
org.apache.uniffle.common.util.ExitUtilsTest ‑ test
org.apache.uniffle.common.util.JavaUtilsTest ‑ test
org.apache.uniffle.common.util.NettyUtilsTest ‑ test
org.apache.uniffle.common.util.RetryUtilsTest ‑ testRetry
org.apache.uniffle.common.util.RetryUtilsTest ‑ testRetryWithCondition
org.apache.uniffle.common.util.RssUtilsTest ‑ getMetricNameForHostNameTest
org.apache.uniffle.common.util.RssUtilsTest ‑ testCloneBitmap
org.apache.uniffle.common.util.RssUtilsTest ‑ testGenerateServerToPartitions
org.apache.uniffle.common.util.RssUtilsTest ‑ testGetConfiguredLocalDirs
org.apache.uniffle.common.util.RssUtilsTest ‑ testGetHostIp
org.apache.uniffle.common.util.RssUtilsTest ‑ testGetPropertiesFromFile
org.apache.uniffle.common.util.RssUtilsTest ‑ testLoadExtentions
org.apache.uniffle.common.util.RssUtilsTest ‑ testSerializeBitmap
org.apache.uniffle.common.util.RssUtilsTest ‑ testShuffleBitmapToPartitionBitmap
org.apache.uniffle.common.util.RssUtilsTest ‑ testStartServiceOnPort
org.apache.uniffle.common.util.ThreadUtilsTest ‑ shutdownThreadPoolTest
org.apache.uniffle.common.util.ThreadUtilsTest ‑ testExecuteTasksWithFutureHandler
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[10]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[11]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[12]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[13]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[14]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[15]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[16]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[17]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[18]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[19]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[1]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[20]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[21]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[22]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[23]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[24]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[25]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[26]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[27]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[28]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[2]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[3]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[4]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[5]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[6]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[7]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[8]
org.apache.uniffle.common.util.UnitConverterTest ‑ testByteString{Long, String, ByteUnit}[9]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[10]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[11]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[12]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[13]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[14]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[15]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[16]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[17]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[18]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[1]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[2]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[3]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[4]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[5]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[6]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[7]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[8]
org.apache.uniffle.common.util.UnitConverterTest ‑ testTimeString{Long, String, TimeUnit}[9]
org.apache.uniffle.common.web.JettyServerTest ‑ jettyServerStartTest
org.apache.uniffle.common.web.JettyServerTest ‑ jettyServerTest
org.apache.uniffle.coordinator.ApplicationManagerTest ‑ clearWithoutRemoteStorageTest
org.apache.uniffle.coordinator.ApplicationManagerTest ‑ refreshTest
org.apache.uniffle.coordinator.CoordinatorConfTest ‑ test
org.apache.uniffle.coordinator.CoordinatorServerTest ‑ test
org.apache.uniffle.coordinator.QuotaManagerTest ‑ testCheckQuota
org.apache.uniffle.coordinator.QuotaManagerTest ‑ testCheckQuotaMetrics
org.apache.uniffle.coordinator.QuotaManagerTest ‑ testCheckQuotaWithDefault
org.apache.uniffle.coordinator.QuotaManagerTest ‑ testDetectUserResource
org.apache.uniffle.coordinator.QuotaManagerTest ‑ testQuotaManagerWithoutAccessQuotaChecker
org.apache.uniffle.coordinator.ServerNodeTest ‑ compareTest
org.apache.uniffle.coordinator.ServerNodeTest ‑ testNettyPort
org.apache.uniffle.coordinator.ServerNodeTest ‑ testStorageInfoOfServerNode
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ excludeNodesNoDelayTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ getLostServerListTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ getServerListForNettyTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ getServerListTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ getUnhealthyServerList
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ heartbeatTimeoutTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ startupSilentPeriodTest
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ testGetCorrectServerNodesWhenOneNodeRemoved
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ testGetCorrectServerNodesWhenOneNodeRemovedAndUnhealthyNodeFound
org.apache.uniffle.coordinator.SimpleClusterManagerTest ‑ updateExcludeNodesTest
org.apache.uniffle.coordinator.access.AccessManagerTest ‑ test
org.apache.uniffle.coordinator.checker.AccessCandidatesCheckerTest ‑ test{File}
org.apache.uniffle.coordinator.checker.AccessClusterLoadCheckerTest ‑ testAccessInfoRequiredShuffleServers
org.apache.uniffle.coordinator.checker.AccessClusterLoadCheckerTest ‑ testWhenAvailableServerThresholdSpecified
org.apache.uniffle.coordinator.checker.AccessQuotaCheckerTest ‑ testAccessInfoRequiredShuffleServers
org.apache.uniffle.coordinator.conf.DynamicClientConfServiceTest ‑ testByLegacyParser{File}
org.apache.uniffle.coordinator.conf.LegacyClientConfParserTest ‑ testParse
org.apache.uniffle.coordinator.conf.YamlClientConfParserTest ‑ testFromFile
org.apache.uniffle.coordinator.conf.YamlClientConfParserTest ‑ testParse
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testAllMetrics
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testCoordinatorMetrics
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testCoordinatorMetricsWithNames
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testDynamicMetrics
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testGrpcMetrics
org.apache.uniffle.coordinator.metric.CoordinatorMetricsTest ‑ testJvmMetrics
org.apache.uniffle.coordinator.strategy.assignment.BasicAssignmentStrategyTest ‑ testAssign
org.apache.uniffle.coordinator.strategy.assignment.BasicAssignmentStrategyTest ‑ testAssignWithDifferentNodeNum
org.apache.uniffle.coordinator.strategy.assignment.BasicAssignmentStrategyTest ‑ testAssignmentShuffleNodesNum
org.apache.uniffle.coordinator.strategy.assignment.BasicAssignmentStrategyTest ‑ testRandomAssign
org.apache.uniffle.coordinator.strategy.assignment.BasicAssignmentStrategyTest ‑ testWithContinuousSelectPartitionStrategy
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testAssign
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testAssignmentShuffleNodesNum
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testAssignmentWithMustDiff
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testAssignmentWithNone
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testAssignmentWithPreferDiff
org.apache.uniffle.coordinator.strategy.assignment.PartitionBalanceAssignmentStrategyTest ‑ testWithContinuousSelectPartitionStrategy
org.apache.uniffle.coordinator.strategy.assignment.PartitionRangeAssignmentTest ‑ test
org.apache.uniffle.coordinator.strategy.assignment.PartitionRangeTest ‑ test
org.apache.uniffle.coordinator.strategy.partition.ContinuousSelectPartitionStrategyTest ‑ test
org.apache.uniffle.coordinator.strategy.storage.AppBalanceSelectStorageStrategyTest ‑ selectStorageTest
org.apache.uniffle.coordinator.strategy.storage.AppBalanceSelectStorageStrategyTest ‑ storageCounterMulThreadTest
org.apache.uniffle.coordinator.strategy.storage.LowestIOSampleCostSelectStorageStrategyTest ‑ selectStorageMulThreadTest
org.apache.uniffle.coordinator.strategy.storage.LowestIOSampleCostSelectStorageStrategyTest ‑ selectStorageTest
org.apache.uniffle.coordinator.util.CoordinatorUtilsTest ‑ testExtractClusterConf
org.apache.uniffle.coordinator.util.CoordinatorUtilsTest ‑ testGenerateRanges
org.apache.uniffle.coordinator.util.CoordinatorUtilsTest ‑ testGenerateRangesGroup
org.apache.uniffle.coordinator.util.CoordinatorUtilsTest ‑ testNextId
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplications
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplicationsPage
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplicationsWithAppRegex
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplicationsWithNoFilter
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplicationsWithNull
org.apache.uniffle.coordinator.web.UniffleServicesRESTTest ‑ testGetApplicationsWithStartTimeAndEndTime
org.apache.uniffle.server.HealthScriptCheckerTest ‑ checkIsHealthy
org.apache.uniffle.server.KerberizedShuffleTaskManagerTest ‑ removeShuffleDataWithHdfsTest
org.apache.uniffle.server.LocalSingleStorageTypeFromEnvProviderTest ‑ testJsonSourceParse
org.apache.uniffle.server.LocalSingleStorageTypeFromEnvProviderTest ‑ testMultipleMountPoints
org.apache.uniffle.server.LocalStorageCheckerTest ‑ testGetUniffleUsedSpace{File}
org.apache.uniffle.server.ShuffleFlushManagerOnKerberizedHadoopTest ‑ clearTest
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ clearLocalTest{File}
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ clearTest
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ complexWriteTest
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ concurrentWrite2HdfsWriteOfSinglePartition
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ concurrentWrite2HdfsWriteOneByOne
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ defaultFlushEventHandlerTest{File}
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ fallbackWrittenWhenHybridStorageManagerEnableTest{File}
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ hadoopConfTest
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ localMetricsTest{File}
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ totalLocalFileWriteDataMetricTest
org.apache.uniffle.server.ShuffleFlushManagerTest ‑ writeTest
org.apache.uniffle.server.ShuffleServerConfTest ‑ confByStringTest
org.apache.uniffle.server.ShuffleServerConfTest ‑ confTest
org.apache.uniffle.server.ShuffleServerConfTest ‑ defaultConfTest
org.apache.uniffle.server.ShuffleServerConfTest ‑ envConfTest
org.apache.uniffle.server.ShuffleServerGrpcMetricsTest ‑ testLatencyMetrics
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testGrpcMetrics
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testHadoopStorageWriteDataSize
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testJvmMetrics
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testNettyMetrics
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testServerMetrics
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testServerMetricsConcurrently
org.apache.uniffle.server.ShuffleServerMetricsTest ‑ testStorageCounter
org.apache.uniffle.server.ShuffleServerTest ‑ decommissionTest{boolean}[1]
org.apache.uniffle.server.ShuffleServerTest ‑ decommissionTest{boolean}[2]
org.apache.uniffle.server.ShuffleServerTest ‑ nettyServerTest
org.apache.uniffle.server.ShuffleServerTest ‑ startTest
org.apache.uniffle.server.ShuffleTaskInfoTest ‑ hugePartitionConcurrentTest
org.apache.uniffle.server.ShuffleTaskInfoTest ‑ hugePartitionTest
org.apache.uniffle.server.ShuffleTaskInfoTest ‑ partitionSizeSummaryTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ checkAndClearLeakShuffleDataTest{File}
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ clearMultiTimesTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ clearTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ getBlockIdsByMultiPartitionTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ getBlockIdsByPartitionIdTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ hugePartitionMemoryUsageLimitTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ partitionDataSizeSummaryTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ registerShuffleTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ removeResourcesByShuffleIdsMultiTimesTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ removeShuffleDataWithHdfsTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ removeShuffleDataWithLocalfileTest
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ testAddFinishedBlockIdsWithoutRegister
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ testGetFinishedBlockIds
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ testGetMaxConcurrencyWriting
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ testRegisterShuffleAfterAppIsExpired
org.apache.uniffle.server.ShuffleTaskManagerTest ‑ writeProcessTest
org.apache.uniffle.server.StorageCheckerTest ‑ checkTest{File}
org.apache.uniffle.server.TopNShuffleDataSizeOfAppCalcTaskTest ‑ testTopNShuffleDataSizeOfAppCalcTask
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ bufferManagerInitTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ bufferSizeTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ cacheShuffleDataTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ cacheShuffleDataWithPreAllocationTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ flushBufferTestWhenNotSelectedStorage{File}
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ flushSingleBufferForHugePartitionTest{File}
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ flushSingleBufferTest{File}
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ getShuffleDataTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ getShuffleDataWithExpectedTaskIdsTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ registerBufferTest
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ shuffleFlushThreshold
org.apache.uniffle.server.buffer.ShuffleBufferManagerTest ‑ shuffleIdToSizeTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ appendMultiBlocksTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ appendTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ getShuffleDataTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ getShuffleDataWithExpectedTaskIdsFilterTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ getShuffleDataWithLocalOrderTest
org.apache.uniffle.server.buffer.ShuffleBufferTest ‑ toFlushEventTest
org.apache.uniffle.server.storage.HadoopStorageManagerTest ‑ testRegisterRemoteStorage
org.apache.uniffle.server.storage.HadoopStorageManagerTest ‑ testRemoveResources
org.apache.uniffle.server.storage.HybridStorageManagerTest ‑ fallbackTestWhenLocalStorageCorrupted
org.apache.uniffle.server.storage.HybridStorageManagerTest ‑ selectStorageManagerTest
org.apache.uniffle.server.storage.HybridStorageManagerTest ‑ testStorageManagerSelectorOfPreferCold
org.apache.uniffle.server.storage.HybridStorageManagerTest ‑ underStorageManagerSelectionTest
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testEnvStorageTypeProvider
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testGetLocalStorageInfo
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testInitLocalStorageManager
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testInitializeLocalStorage
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testStorageSelection
org.apache.uniffle.server.storage.LocalStorageManagerTest ‑ testStorageSelectionWhenReachingHighWatermark
org.apache.uniffle.server.storage.StorageManagerFallbackStrategyTest ‑ testDefaultFallbackStrategy
org.apache.uniffle.server.storage.StorageManagerFallbackStrategyTest ‑ testHadoopFallbackStrategy
org.apache.uniffle.server.storage.StorageManagerFallbackStrategyTest ‑ testLocalFallbackStrategy
org.apache.uniffle.shuffle.manager.RssShuffleManagerBaseTest ‑ testGetDefaultRemoteStorageInfo
org.apache.uniffle.shuffle.manager.ShuffleManagerGrpcServiceTest ‑ testShuffleManagerGrpcService
org.apache.uniffle.shuffle.manager.ShuffleManagerServerFactoryTest ‑ testShuffleManagerServerType
org.apache.uniffle.storage.common.DefaultStorageMediaProviderTest ‑ getGetDeviceName
org.apache.uniffle.storage.common.DefaultStorageMediaProviderTest ‑ getGetFileStore{File}
org.apache.uniffle.storage.common.DefaultStorageMediaProviderTest ‑ testStorageProvider
org.apache.uniffle.storage.common.LocalStorageTest ‑ baseDirectoryInitTest
org.apache.uniffle.storage.common.LocalStorageTest ‑ canWriteTest
org.apache.uniffle.storage.common.LocalStorageTest ‑ canWriteTestWithDiskCapacityCheck
org.apache.uniffle.storage.common.LocalStorageTest ‑ diskStorageInfoTest
org.apache.uniffle.storage.common.LocalStorageTest ‑ getCapacityInitTest
org.apache.uniffle.storage.common.LocalStorageTest ‑ writeHandlerTest
org.apache.uniffle.storage.common.ShuffleFileInfoTest ‑ test
org.apache.uniffle.storage.handler.impl.HadoopClientReadHandlerTest ‑ test
org.apache.uniffle.storage.handler.impl.HadoopFileReaderTest ‑ createStreamAppendTest
org.apache.uniffle.storage.handler.impl.HadoopFileReaderTest ‑ createStreamTest
org.apache.uniffle.storage.handler.impl.HadoopFileReaderTest ‑ readDataTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ createStreamAppendTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ createStreamDirectory
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ createStreamFirstTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ createStreamTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ writeBufferArrayTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ writeBufferTest
org.apache.uniffle.storage.handler.impl.HadoopFileWriterTest ‑ writeSegmentTest
org.apache.uniffle.storage.handler.impl.HadoopHandlerTest ‑ initTest
org.apache.uniffle.storage.handler.impl.HadoopHandlerTest ‑ writeTest
org.apache.uniffle.storage.handler.impl.HadoopShuffleReadHandlerTest ‑ test
org.apache.uniffle.storage.handler.impl.HadoopShuffleReadHandlerTest ‑ testDataInconsistent
org.apache.uniffle.storage.handler.impl.KerberizedHadoopClientReadHandlerTest ‑ test
org.apache.uniffle.storage.handler.impl.KerberizedHadoopShuffleReadHandlerTest ‑ test
org.apache.uniffle.storage.handler.impl.LocalFileHandlerTest ‑ testReadIndex
org.apache.uniffle.storage.handler.impl.LocalFileHandlerTest ‑ writeBigDataTest{File}
org.apache.uniffle.storage.handler.impl.LocalFileHandlerTest ‑ writeTest{File}
org.apache.uniffle.storage.handler.impl.LocalFileServerReadHandlerTest ‑ testDataInconsistent
org.apache.uniffle.storage.handler.impl.PooledHadoopShuffleWriteHandlerTest ‑ concurrentWrite
org.apache.uniffle.storage.handler.impl.PooledHadoopShuffleWriteHandlerTest ‑ lazyInitializeWriterHandlerTest
org.apache.uniffle.storage.handler.impl.PooledHadoopShuffleWriteHandlerTest ‑ writeSameFileWhenNoRaceCondition
org.apache.uniffle.storage.util.ShuffleHadoopStorageUtilsTest ‑ testUploadFile{File}
org.apache.uniffle.storage.util.ShuffleKerberizedHadoopStorageUtilsTest ‑ testUploadFile{File}
org.apache.uniffle.storage.util.ShuffleStorageUtilsTest ‑ getPartitionRangeTest
org.apache.uniffle.storage.util.ShuffleStorageUtilsTest ‑ getShuffleDataPathWithRangeTest
org.apache.uniffle.storage.util.ShuffleStorageUtilsTest ‑ getStorageIndexTest
org.apache.uniffle.storage.util.ShuffleStorageUtilsTest ‑ mergeSegmentsTest
org.apache.uniffle.storage.util.StorageTypeTest ‑ commonTest
org.apache.uniffle.test.AQERepartitionTest ‑ resultCompareTest
org.apache.uniffle.test.AQESkewedJoinTest ‑ resultCompareTest
org.apache.uniffle.test.AQESkewedJoinWithLocalOrderTest ‑ resultCompareTest
org.apache.uniffle.test.AccessCandidatesCheckerHadoopTest ‑ test
org.apache.uniffle.test.AccessCandidatesCheckerKerberizedHadoopTest ‑ test
org.apache.uniffle.test.AccessClusterTest ‑ testUsingCustomExtraProperties
org.apache.uniffle.test.AccessClusterTest ‑ test{File}
org.apache.uniffle.test.AssignmentWithTagsTest ‑ testTags
org.apache.uniffle.test.AutoAccessTest ‑ test
org.apache.uniffle.test.CombineByKeyTest ‑ combineByKeyTest
org.apache.uniffle.test.ContinuousSelectPartitionStrategyTest ‑ resultCompareTest
org.apache.uniffle.test.CoordinatorAdminServiceTest ‑ test
org.apache.uniffle.test.CoordinatorAssignmentTest ‑ testAssignmentServerNodesNumber
org.apache.uniffle.test.CoordinatorAssignmentTest ‑ testGetReShuffleAssignments
org.apache.uniffle.test.CoordinatorAssignmentTest ‑ testReconfigureNodeMax
org.apache.uniffle.test.CoordinatorAssignmentTest ‑ testSilentPeriod
org.apache.uniffle.test.CoordinatorGrpcServerTest ‑ testGrpcConnectionSize
org.apache.uniffle.test.CoordinatorGrpcTest ‑ appHeartbeatTest
org.apache.uniffle.test.CoordinatorGrpcTest ‑ getShuffleAssignmentsTest
org.apache.uniffle.test.CoordinatorGrpcTest ‑ getShuffleRegisterInfoTest
org.apache.uniffle.test.CoordinatorGrpcTest ‑ rpcMetricsTest
org.apache.uniffle.test.CoordinatorGrpcTest ‑ shuffleServerHeartbeatTest
org.apache.uniffle.test.CoordinatorGrpcTest ‑ testGetPartitionToServers
org.apache.uniffle.test.DiskErrorToleranceTest ‑ diskErrorTest
org.apache.uniffle.test.DynamicClientConfServiceHadoopTest ‑ test
org.apache.uniffle.test.DynamicClientConfServiceKerberlizedHadoopTest ‑ testConfInHadoop
org.apache.uniffle.test.DynamicConfTest ‑ dynamicConfTest
org.apache.uniffle.test.DynamicFetchClientConfTest ‑ test
org.apache.uniffle.test.FailingTasksTest ‑ testFailedTasks
org.apache.uniffle.test.FetchClientConfTest ‑ testFetchRemoteStorageByApp{File}
org.apache.uniffle.test.FetchClientConfTest ‑ testFetchRemoteStorageByIO{File}
org.apache.uniffle.test.FetchClientConfTest ‑ test{File}
org.apache.uniffle.test.GetReaderTest ‑ test
org.apache.uniffle.test.GetShuffleReportForMultiPartTest ‑ resultCompareTest
org.apache.uniffle.test.GroupByKeyTest ‑ groupByTest
org.apache.uniffle.test.HadoopConfTest ‑ hadoopConfTest
org.apache.uniffle.test.HealthCheckCoordinatorGrpcTest ‑ healthCheckTest
org.apache.uniffle.test.HealthCheckTest ‑ buildInCheckerTest
org.apache.uniffle.test.HealthCheckTest ‑ checkTest
org.apache.uniffle.test.HybridStorageHadoopFallbackTest ‑ fallbackTest
org.apache.uniffle.test.HybridStorageLocalFileFallbackTest ‑ fallbackTest
org.apache.uniffle.test.LargeSorterTest ‑ largeSorterTest
org.apache.uniffle.test.NullOfKeyOrValueTest ‑ nullOfKeyOrValueTest
org.apache.uniffle.test.PartitionBalanceCoordinatorGrpcTest ‑ getShuffleAssignmentsTest
org.apache.uniffle.test.QuorumTest ‑ case1
org.apache.uniffle.test.QuorumTest ‑ case10
org.apache.uniffle.test.QuorumTest ‑ case11
org.apache.uniffle.test.QuorumTest ‑ case12
org.apache.uniffle.test.QuorumTest ‑ case2
org.apache.uniffle.test.QuorumTest ‑ case3
org.apache.uniffle.test.QuorumTest ‑ case4
org.apache.uniffle.test.QuorumTest ‑ case5{File}
org.apache.uniffle.test.QuorumTest ‑ case6
org.apache.uniffle.test.QuorumTest ‑ case7
org.apache.uniffle.test.QuorumTest ‑ case8
org.apache.uniffle.test.QuorumTest ‑ case9
org.apache.uniffle.test.QuorumTest ‑ quorumConfigTest
org.apache.uniffle.test.QuorumTest ‑ rpcFailedTest
org.apache.uniffle.test.RSSStageDynamicServerReWriteTest ‑ testRSSStageResubmit
org.apache.uniffle.test.RSSStageResubmitTest ‑ testRSSStageResubmit
org.apache.uniffle.test.RepartitionWithHadoopHybridStorageRssTest ‑ resultCompareTest
org.apache.uniffle.test.RepartitionWithLocalFileRssTest ‑ resultCompareTest
org.apache.uniffle.test.RepartitionWithMemoryHybridStorageRssTest ‑ resultCompareTest
org.apache.uniffle.test.RepartitionWithMemoryRssTest ‑ resultCompareTest
org.apache.uniffle.test.RepartitionWithMemoryRssTest ‑ testMemoryRelease
org.apache.uniffle.test.RssShuffleManagerTest ‑ testRssShuffleManager
org.apache.uniffle.test.SecondarySortTest ‑ secondarySortTest
org.apache.uniffle.test.ServletTest ‑ testDecommissionServlet
org.apache.uniffle.test.ServletTest ‑ testDecommissionSingleNode

Check notice on line 0 in .github

See this annotation in the file changed.

@github-actions github-actions / Test Results

823 tests found (test 759 to 823) 

There are 823 tests, see "Raw output" for the list of tests 759 to 823.
Raw output 
org.apache.uniffle.test.ServletTest ‑ testDecommissionedNodeServlet
org.apache.uniffle.test.ServletTest ‑ testGetSingleNode
org.apache.uniffle.test.ServletTest ‑ testLostNodesServlet
org.apache.uniffle.test.ServletTest ‑ testNodesServlet
org.apache.uniffle.test.ServletTest ‑ testUnhealthyNodesServlet
org.apache.uniffle.test.ShuffleServerConcurrentWriteOfHadoopTest ‑ hadoopWriteReadTest
org.apache.uniffle.test.ShuffleServerConcurrentWriteOfHadoopTest ‑ testConcurrentWrite2Hadoop{int, int}[1]
org.apache.uniffle.test.ShuffleServerConcurrentWriteOfHadoopTest ‑ testConcurrentWrite2Hadoop{int, int}[2]
org.apache.uniffle.test.ShuffleServerFaultToleranceTest ‑ testReadFaultTolerance
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ clearResourceTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ multipleShuffleResultTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ registerTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ rpcMetricsTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ sendDataAndRequireBufferTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ sendDataWithoutRegisterTest
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ sendDataWithoutRequirePreAllocation
org.apache.uniffle.test.ShuffleServerGrpcTest ‑ shuffleResultTest
org.apache.uniffle.test.ShuffleServerInternalGrpcTest ‑ decommissionTest
org.apache.uniffle.test.ShuffleServerOnRandomPortTest ‑ startGrpcServerOnRandomPort
org.apache.uniffle.test.ShuffleServerOnRandomPortTest ‑ startStreamServerOnRandomPort
org.apache.uniffle.test.ShuffleServerWithHadoopTest ‑ hadoopWriteReadTest
org.apache.uniffle.test.ShuffleServerWithKerberizedHadoopTest ‑ hadoopWriteReadTest
org.apache.uniffle.test.ShuffleServerWithLocalOfExceptionTest ‑ testReadWhenConnectionFailedShouldThrowException
org.apache.uniffle.test.ShuffleServerWithLocalOfLocalOrderTest ‑ testWriteAndReadWithSpecifiedMapRange
org.apache.uniffle.test.ShuffleServerWithLocalTest ‑ localWriteReadTest
org.apache.uniffle.test.ShuffleServerWithMemLocalHadoopTest ‑ memoryLocalFileHadoopReadWithFilterAndSkipTest
org.apache.uniffle.test.ShuffleServerWithMemLocalHadoopTest ‑ memoryLocalFileHadoopReadWithFilterTest
org.apache.uniffle.test.ShuffleServerWithMemoryTest ‑ memoryAndLocalFileReadWithFilterTest
org.apache.uniffle.test.ShuffleServerWithMemoryTest ‑ memoryWriteReadTest
org.apache.uniffle.test.ShuffleServerWithMemoryTest ‑ memoryWriteReadWithMultiReplicaTest
org.apache.uniffle.test.ShuffleUnregisterWithHadoopTest ‑ unregisterShuffleTest
org.apache.uniffle.test.ShuffleUnregisterWithLocalfileTest ‑ unregisterShuffleTest
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ emptyTaskTest
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ reportBlocksToShuffleServerIfNecessary
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ reportMultipleServerTest
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ rpcFailTest
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ testRetryAssgin
org.apache.uniffle.test.ShuffleWithRssClientTest ‑ writeReadTest
org.apache.uniffle.test.SimpleShuffleServerManagerTest ‑ testClientAndServerConnections
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest1
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest10
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest2
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest3
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest4
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest5
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest6
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest7
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest8
org.apache.uniffle.test.SparkClientWithLocalTest ‑ readTest9
org.apache.uniffle.test.SparkSQLWithDelegationShuffleManagerFallbackTest ‑ resultCompareTest
org.apache.uniffle.test.SparkSQLWithDelegationShuffleManagerTest ‑ resultCompareTest
org.apache.uniffle.test.SparkSQLWithMemoryLocalTest ‑ resultCompareTest
org.apache.uniffle.test.TezCartesianProductTest ‑ cartesianProductTest
org.apache.uniffle.test.TezHashJoinTest ‑ hashJoinDoBroadcastTest
org.apache.uniffle.test.TezHashJoinTest ‑ hashJoinTest
org.apache.uniffle.test.TezOrderedWordCountTest ‑ orderedWordCountTest
org.apache.uniffle.test.TezSimpleSessionExampleTest ‑ simpleSessionExampleTest
org.apache.uniffle.test.TezSortMergeJoinTest ‑ sortMergeJoinTest
org.apache.uniffle.test.TezWordCountTest ‑ wordCountTest
org.apache.uniffle.test.TezWordCountWithFailuresTest ‑ wordCountTestWithNodeUnhealthyWhenAvoidRecomputeDisable
org.apache.uniffle.test.TezWordCountWithFailuresTest ‑ wordCountTestWithNodeUnhealthyWhenAvoidRecomputeEnable
org.apache.uniffle.test.TezWordCountWithFailuresTest ‑ wordCountTestWithTaskFailureWhenAvoidRecomputeDisable
org.apache.uniffle.test.TezWordCountWithFailuresTest ‑ wordCountTestWithTaskFailureWhenAvoidRecomputeEnable
org.apache.uniffle.test.WordCountTest ‑ wordCountTest
org.apache.uniffle.test.WriteAndReadMetricsTest ‑ test
View more details on GitHub Actions