[
https://issues.apache.org/jira/browse/HUDI-8548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jonathan Vexler updated HUDI-8548:
----------------------------------
Status: Patch Available (was: In Progress)
> fix structuredStreamingTestRunner
> ---------------------------------
>
> Key: HUDI-8548
> URL: https://issues.apache.org/jira/browse/HUDI-8548
> Project: Apache Hudi
> Issue Type: Task
> Components: tests-ci
> Reporter: Jonathan Vexler
> Assignee: Jonathan Vexler
> Priority: Blocker
> Labels: pull-request-available
> Fix For: 1.0.0
>
>
> test is disabled because it is flakey
>
> {code:java}
> java.util.NoSuchElementException: No value present in Option
> 7007 at org.apache.hudi.common.util.Option.get(Option.java:93)
> 7008 at
> org.apache.hudi.common.table.HoodieTableMetaClient.lambda$new$0(HoodieTableMetaClient.java:180)
> 7009 at org.apache.hudi.common.util.Option.orElseGet(Option.java:153)
> 7010 at
> org.apache.hudi.common.table.HoodieTableMetaClient.<init>(HoodieTableMetaClient.java:180)
> 7011 at
> org.apache.hudi.common.table.HoodieTableMetaClient.newMetaClient(HoodieTableMetaClient.java:770)
> 7012 at
> org.apache.hudi.common.table.HoodieTableMetaClient.access$100(HoodieTableMetaClient.java:106)
> 7013 at
> org.apache.hudi.common.table.HoodieTableMetaClient$Builder.build(HoodieTableMetaClient.java:878)
> 7014 at
> org.apache.hudi.HoodieDataSourceHelpers.allCompletedCommitsCompactions(HoodieDataSourceHelpers.java:126)
> 7015 at
> org.apache.hudi.functional.TestStructuredStreaming.waitTillAtleastNCommits(TestStructuredStreaming.scala:224)
> 7016 at
> org.apache.hudi.functional.TestStructuredStreaming.$anonfun$structuredStreamingTestRunner$1(TestStructuredStreaming.scala:146)
> 7017 at
> scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:23)
> 7018 at scala.concurrent.Future$.$anonfun$apply$1(Future.scala:659)
> 7019 at scala.util.Success.$anonfun$map$1(Try.scala:255)
> 7020 at scala.util.Success.map(Try.scala:213)
> 7021 at scala.concurrent.Future.$anonfun$map$1(Future.scala:292)
> 7022 at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:33)
> 7023 at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:33)
> 7024 at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:64)
> 7025 at
> java.base/java.util.concurrent.ForkJoinTask$RunnableExecuteAction.exec(ForkJoinTask.java:1395)
> 7026 at
> java.base/java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:373)
> 7027 at
> java.base/java.util.concurrent.ForkJoinPool$WorkQueue.topLevelExec(ForkJoinPool.java:1182)
> 7028 at
> java.base/java.util.concurrent.ForkJoinPool.scan(ForkJoinPool.java:1655)
> 7029 at
> java.base/java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1622)
> 7030 at
> java.base/java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:165)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
