[
https://issues.apache.org/jira/browse/HUDI-8699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
voon updated HUDI-8699:
-----------------------
Fix Version/s: 1.1.0
(was: 1.0.2)
> TestStructuredStreaming#testStructuredStreamingWithCompaction is flaky
> ----------------------------------------------------------------------
>
> Key: HUDI-8699
> URL: https://issues.apache.org/jira/browse/HUDI-8699
> Project: Apache Hudi
> Issue Type: Sub-task
> Components: tests-ci
> Reporter: Y Ethan Guo
> Assignee: sivabalan narayanan
> Priority: Blocker
> Fix For: 1.1.0
>
> Original Estimate: 2h
> Remaining Estimate: 2h
>
> {code:java}
> Error: Tests run: 16, Failures: 0, Errors: 1, Skipped: 0, Time elapsed:
> 194.173 s <<< FAILURE! - in org.apache.hudi.functional.TestStructuredStreaming
> 16710Error: testStructuredStreamingWithCompaction{boolean}[1] Time elapsed:
> 6.669 s <<< ERROR!
> 16711java.util.concurrent.ExecutionException: Boxed Error
> 16712 at scala.concurrent.impl.Promise$.resolver(Promise.scala:87)
> 16713 at
> scala.concurrent.impl.Promise$.scala$concurrent$impl$Promise$$resolveTry(Promise.scala:79)
> 16714 at
> scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284)
> 16715 at scala.concurrent.Promise.complete(Promise.scala:53)
> 16716 at scala.concurrent.Promise.complete$(Promise.scala:52)
> 16717 at
> scala.concurrent.impl.Promise$DefaultPromise.complete(Promise.scala:187)
> 16718 at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
> 16719 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
> 16720 at
> java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1395)
> 16721 at
> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
> 16722 at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
> 16723 at
> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
> 16724 at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
> 16725 at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
> 16726Caused by: java.lang.AssertionError: assertion failed
> 16727 at scala.Predef$.assert(Predef.scala:208)
> 16728 at
> org.apache.hudi.functional.TestStructuredStreaming.$anonfun$structuredStreamingTestRunner$1(TestStructuredStreaming.scala:151)
> 16729 at
> scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
> 16730 at scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
> 16731 at scala.util.Success.$anonfun$map$1(Try.scala:255)
> 16732 at scala.util.Success.map(Try.scala:213)
> 16733 at scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
> 16734 at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
> 16735 ... 8 more {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
