You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "hudi-bot (via GitHub)" <gi...@apache.org> on 2025/11/30 08:59:13 UTC

[I] Fix Flaky testAsyncClusteringServiceWithConflicts [hudi]

hudi-bot opened a new issue, #16226:
URL: https://github.com/apache/hudi/issues/16226

   Ref link:
   
   [https://dev.azure.com/apache-hudi-ci-org/785b6ef4-2f42-4a89-8f0e-5f0d7039a0cc/_apis/build/builds/19769/logs/44]
   
    
   {code:java}
   2023-09-09T09:20:36.7626999Z [ERROR] Tests run: 122, Failures: 2, Errors: 0, Skipped: 2, Time elapsed: 1,341.327 s <<< FAILURE! - in org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer
   2023-09-09T09:20:36.7628020Z [ERROR] testAsyncClusteringServiceWithConflicts{HoodieRecordType}[1]  Time elapsed: 28.782 s  <<< FAILURE!
   2023-09-09T09:20:36.7628834Z org.opentest4j.AssertionFailedError: expected: <1900> but was: <2000>
   2023-09-09T09:20:36.7629369Z 	at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55)
   2023-09-09T09:20:36.7630061Z 	at org.junit.jupiter.api.AssertionUtils.failNotEqual(AssertionUtils.java:62)
   2023-09-09T09:20:36.7707940Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:166)
   2023-09-09T09:20:36.7708794Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:161)
   2023-09-09T09:20:36.7710586Z 	at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:611)
   2023-09-09T09:20:36.7711270Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer$TestHelpers.assertDistinctRecordCount(TestHoodieDeltaStreamer.java:337)
   2023-09-09T09:20:36.7711828Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer.testAsyncClusteringServiceWithConflicts(TestHoodieDeltaStreamer.java:1407)
   2023-09-09T09:20:36.7712936Z 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   2023-09-09T09:20:36.7713245Z 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
   2023-09-09T09:20:36.7713849Z 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   2023-09-09T09:20:36.7714914Z 	at java.lang.reflect.Method.invoke(Method.java:498)
   2023-09-09T09:20:36.7715242Z 	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
   2023-09-09T09:20:36.7715628Z 	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
   2023-09-09T09:20:36.7716064Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
   2023-09-09T09:20:36.7716493Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
   2023-09-09T09:20:36.7716897Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
   2023-09-09T09:20:36.7717332Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
   2023-09-09T09:20:36.7717780Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
   2023-09-09T09:20:36.7718232Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
   2023-09-09T09:20:36.7718675Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
   2023-09-09T09:20:36.7719112Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
   2023-09-09T09:20:36.7719560Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
   2023-09-09T09:20:36.7720000Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
   2023-09-09T09:20:36.7721950Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
   2023-09-09T09:20:36.7722350Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
   2023-09-09T09:20:36.7722779Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
   2023-09-09T09:20:36.7723224Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7723649Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
   2023-09-09T09:20:36.7724085Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
   2023-09-09T09:20:36.7724671Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
   2023-09-09T09:20:36.7725089Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7725526Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7725958Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7726329Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7726721Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7727152Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7727548Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7727949Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7728461Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
   2023-09-09T09:20:36.7728960Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:212)
   2023-09-09T09:20:36.7729409Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:192)
   2023-09-09T09:20:36.7729854Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
   2023-09-09T09:20:36.7730307Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7730692Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7731032Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7731370Z 	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
   2023-09-09T09:20:36.7731696Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7732033Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7732379Z 	at java.util.stream.ReferencePipeline$11$1.accept(ReferencePipeline.java:440)
   2023-09-09T09:20:36.7732706Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7733047Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7733384Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7733700Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7734036Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7734350Z 	at java.util.Iterator.forEachRemaining(Iterator.java:116)
   2023-09-09T09:20:36.7734740Z 	at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
   2023-09-09T09:20:36.7735089Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7735425Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7738473Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7738938Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7739289Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7739608Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7739945Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7740486Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7740809Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7741156Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7741504Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7741832Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7758854Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7759899Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7760289Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7760641Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7760986Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7764275Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7764686Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7765034Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7765359Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7765708Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7766068Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7766403Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7766735Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7767130Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7767551Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
   2023-09-09T09:20:36.7767994Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7768419Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7768828Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7769220Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7769606Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7770017Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7770439Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7770836Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7771414Z 	at java.util.ArrayList.forEach(ArrayList.java:1259)
   2023-09-09T09:20:36.7771813Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
   2023-09-09T09:20:36.7772313Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
   2023-09-09T09:20:36.7772740Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7773153Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7773542Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7774022Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7774428Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7774845Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7775240Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7775551Z 	at java.util.ArrayList.forEach(ArrayList.java:1259)
   2023-09-09T09:20:36.7775966Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
   2023-09-09T09:20:36.7776463Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
   2023-09-09T09:20:36.7776874Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7777657Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7778066Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7778457Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7778865Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7779278Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7779673Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7780122Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
   2023-09-09T09:20:36.7780620Z 	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
   2023-09-09T09:20:36.7786432Z 	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
   2023-09-09T09:20:36.7786885Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
   2023-09-09T09:20:36.7787324Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
   2023-09-09T09:20:36.7787771Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
   2023-09-09T09:20:36.7788214Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
   2023-09-09T09:20:36.7788663Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
   2023-09-09T09:20:36.7789060Z 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96)
   2023-09-09T09:20:36.7789423Z 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75)
   2023-09-09T09:20:36.7790014Z 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
   2023-09-09T09:20:36.7790441Z 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
   2023-09-09T09:20:36.7790858Z 	at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
   2023-09-09T09:20:36.7791238Z 	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
   2023-09-09T09:20:36.7791601Z 	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
   2023-09-09T09:20:36.7791947Z 	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
   2023-09-09T09:20:36.7792188Z 
   2023-09-09T09:20:36.7792432Z [ERROR] testAsyncClusteringServiceWithConflicts{HoodieRecordType}[2]  Time elapsed: 10.861 s  <<< FAILURE!
   2023-09-09T09:20:36.7792720Z org.opentest4j.AssertionFailedError: expected: <1900> but was: <3000>
   2023-09-09T09:20:36.7793023Z 	at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55)
   2023-09-09T09:20:36.7793354Z 	at org.junit.jupiter.api.AssertionUtils.failNotEqual(AssertionUtils.java:62)
   2023-09-09T09:20:36.7793676Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:166)
   2023-09-09T09:20:36.7794013Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:161)
   2023-09-09T09:20:36.7794340Z 	at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:611)
   2023-09-09T09:20:36.7794745Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer$TestHelpers.assertDistinctRecordCount(TestHoodieDeltaStreamer.java:337)
   2023-09-09T09:20:36.7795265Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer.testAsyncClusteringServiceWithConflicts(TestHoodieDeltaStreamer.java:1407)
   2023-09-09T09:20:36.7795661Z 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   2023-09-09T09:20:36.7798357Z 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
   2023-09-09T09:20:36.7798821Z 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   2023-09-09T09:20:36.7799151Z 	at java.lang.reflect.Method.invoke(Method.java:498)
   2023-09-09T09:20:36.7799463Z 	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
   2023-09-09T09:20:36.7799845Z 	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
   2023-09-09T09:20:36.7800280Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
   2023-09-09T09:20:36.7800704Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
   2023-09-09T09:20:36.7801117Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
   2023-09-09T09:20:36.7801544Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
   2023-09-09T09:20:36.7801995Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
   2023-09-09T09:20:36.7802441Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
   2023-09-09T09:20:36.7802891Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
   2023-09-09T09:20:36.7803334Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
   2023-09-09T09:20:36.7803777Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
   2023-09-09T09:20:36.7804219Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
   2023-09-09T09:20:36.7804617Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
   2023-09-09T09:20:36.7805144Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
   2023-09-09T09:20:36.7805573Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
   2023-09-09T09:20:36.7806021Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7806437Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
   2023-09-09T09:20:36.7806874Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
   2023-09-09T09:20:36.7807293Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
   2023-09-09T09:20:36.7807776Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7808204Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7808633Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7809006Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7809398Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7809826Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7810226Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7810627Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7811091Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
   2023-09-09T09:20:36.7811597Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:212)
   2023-09-09T09:20:36.7812039Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:192)
   2023-09-09T09:20:36.7812483Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
   2023-09-09T09:20:36.7812926Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7813307Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7813648Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7813996Z 	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
   2023-09-09T09:20:36.7814317Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7814658Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7815001Z 	at java.util.stream.ReferencePipeline$11$1.accept(ReferencePipeline.java:440)
   2023-09-09T09:20:36.7815326Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7815664Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816001Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816319Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7816655Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816969Z 	at java.util.Iterator.forEachRemaining(Iterator.java:116)
   2023-09-09T09:20:36.7817285Z 	at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
   2023-09-09T09:20:36.7817630Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7818085Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7818421Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7818777Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7819125Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7819439Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7819776Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7820113Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7820501Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7820840Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7821186Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7821512Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7821849Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7823108Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7823466Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7823813Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7824147Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7824473Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7824822Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7825163Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7825488Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7825836Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7826197Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7826526Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7826858Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7827242Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7827660Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
   2023-09-09T09:20:36.7828097Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7828530Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7828943Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7829332Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7829720Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7830178Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7830578Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7830978Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7831311Z 	at java.util.ArrayList.forEach(ArrayList.java:1259)
   2023-09-09T09:20:36.7831848Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExec {code}
    
   
    
   
   ## JIRA info
   
   - Link: https://issues.apache.org/jira/browse/HUDI-6840
   - Type: Test
   - Epic: https://issues.apache.org/jira/browse/HUDI-4302
   
   
   ---
   
   
   ## Comments
   
   10/Sep/23 17:56;shivnarayan;{code:java}
   2023-09-09T09:20:36.7792432Z [ERROR] testAsyncClusteringServiceWithConflicts{HoodieRecordType}[2]  Time elapsed: 10.861 s  <<< FAILURE!
   2023-09-09T09:20:36.7792720Z org.opentest4j.AssertionFailedError: expected: <1900> but was: <3000>
   2023-09-09T09:20:36.7793023Z 	at org.junit.jupiter.api.AssertionUtils.fail(AssertionUtils.java:55)
   2023-09-09T09:20:36.7793354Z 	at org.junit.jupiter.api.AssertionUtils.failNotEqual(AssertionUtils.java:62)
   2023-09-09T09:20:36.7793676Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:166)
   2023-09-09T09:20:36.7794013Z 	at org.junit.jupiter.api.AssertEquals.assertEquals(AssertEquals.java:161)
   2023-09-09T09:20:36.7794340Z 	at org.junit.jupiter.api.Assertions.assertEquals(Assertions.java:611)
   2023-09-09T09:20:36.7794745Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer$TestHelpers.assertDistinctRecordCount(TestHoodieDeltaStreamer.java:337)
   2023-09-09T09:20:36.7795265Z 	at org.apache.hudi.utilities.deltastreamer.TestHoodieDeltaStreamer.testAsyncClusteringServiceWithConflicts(TestHoodieDeltaStreamer.java:1407)
   2023-09-09T09:20:36.7795661Z 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
   2023-09-09T09:20:36.7798357Z 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
   2023-09-09T09:20:36.7798821Z 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
   2023-09-09T09:20:36.7799151Z 	at java.lang.reflect.Method.invoke(Method.java:498)
   2023-09-09T09:20:36.7799463Z 	at org.junit.platform.commons.util.ReflectionUtils.invokeMethod(ReflectionUtils.java:688)
   2023-09-09T09:20:36.7799845Z 	at org.junit.jupiter.engine.execution.MethodInvocation.proceed(MethodInvocation.java:60)
   2023-09-09T09:20:36.7800280Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$ValidatingInvocation.proceed(InvocationInterceptorChain.java:131)
   2023-09-09T09:20:36.7800704Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.intercept(TimeoutExtension.java:149)
   2023-09-09T09:20:36.7801117Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestableMethod(TimeoutExtension.java:140)
   2023-09-09T09:20:36.7801544Z 	at org.junit.jupiter.engine.extension.TimeoutExtension.interceptTestTemplateMethod(TimeoutExtension.java:92)
   2023-09-09T09:20:36.7801995Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker$ReflectiveInterceptorCall.lambda$ofVoidMethod$0(ExecutableInvoker.java:115)
   2023-09-09T09:20:36.7802441Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.lambda$invoke$0(ExecutableInvoker.java:105)
   2023-09-09T09:20:36.7802891Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain$InterceptedInvocation.proceed(InvocationInterceptorChain.java:106)
   2023-09-09T09:20:36.7803334Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.proceed(InvocationInterceptorChain.java:64)
   2023-09-09T09:20:36.7803777Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.chainAndInvoke(InvocationInterceptorChain.java:45)
   2023-09-09T09:20:36.7804219Z 	at org.junit.jupiter.engine.execution.InvocationInterceptorChain.invoke(InvocationInterceptorChain.java:37)
   2023-09-09T09:20:36.7804617Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:104)
   2023-09-09T09:20:36.7805144Z 	at org.junit.jupiter.engine.execution.ExecutableInvoker.invoke(ExecutableInvoker.java:98)
   2023-09-09T09:20:36.7805573Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.lambda$invokeTestMethod$6(TestMethodTestDescriptor.java:210)
   2023-09-09T09:20:36.7806021Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7806437Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.invokeTestMethod(TestMethodTestDescriptor.java:206)
   2023-09-09T09:20:36.7806874Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:131)
   2023-09-09T09:20:36.7807293Z 	at org.junit.jupiter.engine.descriptor.TestMethodTestDescriptor.execute(TestMethodTestDescriptor.java:65)
   2023-09-09T09:20:36.7807776Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7808204Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7808633Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7809006Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7809398Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7809826Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7810226Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7810627Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7811091Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
   2023-09-09T09:20:36.7811597Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:212)
   2023-09-09T09:20:36.7812039Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask$DefaultDynamicTestExecutor.execute(NodeTestTask.java:192)
   2023-09-09T09:20:36.7812483Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:139)
   2023-09-09T09:20:36.7812926Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.lambda$execute$2(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7813307Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7813648Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7813996Z 	at java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
   2023-09-09T09:20:36.7814317Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7814658Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7815001Z 	at java.util.stream.ReferencePipeline$11$1.accept(ReferencePipeline.java:440)
   2023-09-09T09:20:36.7815326Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7815664Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816001Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816319Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.accept(ForEachOps.java:183)
   2023-09-09T09:20:36.7816655Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7816969Z 	at java.util.Iterator.forEachRemaining(Iterator.java:116)
   2023-09-09T09:20:36.7817285Z 	at java.util.Spliterators$IteratorSpliterator.forEachRemaining(Spliterators.java:1801)
   2023-09-09T09:20:36.7817630Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7818085Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7818421Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7818777Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7819125Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7819439Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7819776Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7820113Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7820501Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7820840Z 	at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
   2023-09-09T09:20:36.7821186Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7821512Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7821849Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7823108Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7823466Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7823813Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7824147Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7824473Z 	at java.util.stream.ReferencePipeline$7$1.accept(ReferencePipeline.java:272)
   2023-09-09T09:20:36.7824822Z 	at java.util.ArrayList$ArrayListSpliterator.forEachRemaining(ArrayList.java:1384)
   2023-09-09T09:20:36.7825163Z 	at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
   2023-09-09T09:20:36.7825488Z 	at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
   2023-09-09T09:20:36.7825836Z 	at java.util.stream.ForEachOps$ForEachOp.evaluateSequential(ForEachOps.java:150)
   2023-09-09T09:20:36.7826197Z 	at java.util.stream.ForEachOps$ForEachOp$OfRef.evaluateSequential(ForEachOps.java:173)
   2023-09-09T09:20:36.7826526Z 	at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
   2023-09-09T09:20:36.7826858Z 	at java.util.stream.ReferencePipeline.forEach(ReferencePipeline.java:485)
   2023-09-09T09:20:36.7827242Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:107)
   2023-09-09T09:20:36.7827660Z 	at org.junit.jupiter.engine.descriptor.TestTemplateTestDescriptor.execute(TestTemplateTestDescriptor.java:42)
   2023-09-09T09:20:36.7828097Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:139)
   2023-09-09T09:20:36.7828530Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7828943Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7829332Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7829720Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7830178Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7830578Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7830978Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7831311Z 	at java.util.ArrayList.forEach(ArrayList.java:1259)
   2023-09-09T09:20:36.7831848Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
   2023-09-09T09:20:36.7832342Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
   2023-09-09T09:20:36.7833349Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7833769Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7834166Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7834841Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7835373Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7835793Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7836196Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7836509Z 	at java.util.ArrayList.forEach(ArrayList.java:1259)
   2023-09-09T09:20:36.7836929Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.invokeAll(SameThreadHierarchicalTestExecutorService.java:38)
   2023-09-09T09:20:36.7837423Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$5(NodeTestTask.java:143)
   2023-09-09T09:20:36.7837834Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7838262Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$7(NodeTestTask.java:129)
   2023-09-09T09:20:36.7838651Z 	at org.junit.platform.engine.support.hierarchical.Node.around(Node.java:137)
   2023-09-09T09:20:36.7839043Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.lambda$executeRecursively$8(NodeTestTask.java:127)
   2023-09-09T09:20:36.7839451Z 	at org.junit.platform.engine.support.hierarchical.ThrowableCollector.execute(ThrowableCollector.java:73)
   2023-09-09T09:20:36.7839864Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.executeRecursively(NodeTestTask.java:126)
   2023-09-09T09:20:36.7840260Z 	at org.junit.platform.engine.support.hierarchical.NodeTestTask.execute(NodeTestTask.java:84)
   2023-09-09T09:20:36.7840710Z 	at org.junit.platform.engine.support.hierarchical.SameThreadHierarchicalTestExecutorService.submit(SameThreadHierarchicalTestExecutorService.java:32)
   2023-09-09T09:20:36.7841207Z 	at org.junit.platform.engine.support.hierarchical.HierarchicalTestExecutor.execute(HierarchicalTestExecutor.java:57)
   2023-09-09T09:20:36.7841649Z 	at org.junit.platform.engine.support.hierarchical.HierarchicalTestEngine.execute(HierarchicalTestEngine.java:51)
   2023-09-09T09:20:36.7842069Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:108)
   2023-09-09T09:20:36.7842497Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
   2023-09-09T09:20:36.7842936Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
   2023-09-09T09:20:36.7843378Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
   2023-09-09T09:20:36.7843823Z 	at org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
   2023-09-09T09:20:36.7844214Z 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:96)
   2023-09-09T09:20:36.7844578Z 	at org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:75)
   2023-09-09T09:20:36.7844963Z 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:150)
   2023-09-09T09:20:36.7845462Z 	at org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
   2023-09-09T09:20:36.7845876Z 	at org.apache.maven.surefire.booter.ForkedBooter.invokeProviderInSameClassLoader(ForkedBooter.java:384)
   2023-09-09T09:20:36.7846258Z 	at org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:345)
   2023-09-09T09:20:36.7846622Z 	at org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:126)
   2023-09-09T09:20:36.7851039Z 	at org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:418)
   2023-09-09T09:20:36.7851211Z 
   2023-09-09T09:20:36.7851436Z [INFO] Running org.apache.hudi.utilities.deltastreamer.TestSourceFormatAdapter {code};;;


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


Re: [I] Fix Flaky testAsyncClusteringServiceWithConflicts [hudi]

Posted by "rangareddy (via GitHub)" <gi...@apache.org>.
rangareddy commented on issue #16226:
URL: https://github.com/apache/hudi/issues/16226#issuecomment-5434648604

   This issue was reviewed as part of the JIRA-migrated backlog triage (HUDI-6840).
   
   **Findings: still open.**
   
   No commit on `master` references HUDI-6840, so nothing has landed under this ticket's key.
   
   The description is substantive and self-describing, so this is workable as written - what is missing is an owner rather than a specification.
   
   Keeping this open.
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@hudi.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org