[
https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566112#comment-17566112
]
luoyuxia commented on FLINK-28525:
----------------------------------
Thanks for reporting it. I'll fix it as soon as possible.
The reason is it will read any path first, but the test assumes it'll always
read the specific path first, thus cause the unstable test.
> HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with
> AssertJMultipleFailuresError
> ---------------------------------------------------------------------------------------------
>
> Key: FLINK-28525
> URL: https://issues.apache.org/jira/browse/FLINK-28525
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Hive
> Affects Versions: 1.16.0
> Reporter: Huang Xingbo
> Assignee: luoyuxia
> Priority: Critical
> Labels: pull-request-available, test-stability
>
> {code:java}
> 2022-07-12T04:20:27.9597185Z Jul 12 04:20:27 [ERROR]
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir
> Time elapsed: 16.31 s <<< FAILURE!
> 2022-07-12T04:20:27.9598238Z Jul 12 04:20:27
> org.assertj.core.error.AssertJMultipleFailuresError:
> 2022-07-12T04:20:27.9598978Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9599419Z Jul 12 04:20:27 Multiple Failures (1 failure)
> 2022-07-12T04:20:27.9600269Z Jul 12 04:20:27 -- failure 1 --
> 2022-07-12T04:20:27.9601093Z Jul 12 04:20:27 [Any cause contains message 'Not
> a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2']
> 2022-07-12T04:20:27.9602679Z Jul 12 04:20:27 Expecting any element of:
> 2022-07-12T04:20:27.9603145Z Jul 12 04:20:27
> [org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:20:27.9603766Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:20:27.9604403Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:20:27.9605039Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:20:27.9605902Z Jul 12 04:20:27 ...(75 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:20:27.9606408Z Jul 12 04:20:27 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:20:27.9606952Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:20:27.9607777Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:20:27.9608438Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:20:27.9609261Z Jul 12 04:20:27 ...(79 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:20:27.9609899Z Jul 12 04:20:27
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9610503Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:20:27.9610998Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:20:27.9611574Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:20:27.9612390Z Jul 12 04:20:27 ...(81 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:20:27.9612953Z Jul 12 04:20:27 java.io.IOException: Not a
> file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9613522Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:27.9614119Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:27.9614731Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:27.9615535Z Jul 12 04:20:27 ...(4 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)]
> 2022-07-12T04:20:27.9616042Z Jul 12 04:20:27 to satisfy the given assertions
> requirements but none did:
> 2022-07-12T04:20:27.9616381Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9616795Z Jul 12 04:20:27
> org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:20:27.9617407Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:20:27.9618034Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:20:27.9618650Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:20:27.9619455Z Jul 12 04:20:27 ...(75 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:20:27.9619961Z Jul 12 04:20:27 error:
> 2022-07-12T04:20:27.9620268Z Jul 12 04:20:27 Expecting throwable message:
> 2022-07-12T04:20:27.9620642Z Jul 12 04:20:27 "java.io.IOException: Fail to
> create input splits."
> 2022-07-12T04:20:27.9620989Z Jul 12 04:20:27 to contain:
> 2022-07-12T04:20:27.9621387Z Jul 12 04:20:27 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:20:27.9621777Z Jul 12 04:20:27 but did not.
> 2022-07-12T04:20:27.9622042Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9622345Z Jul 12 04:20:27 Throwable that failed the check:
> 2022-07-12T04:20:27.9622644Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9623052Z Jul 12 04:20:27
> org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:20:27.9623647Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:20:27.9624275Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:20:27.9624882Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:20:27.9625599Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:20:27.9626485Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:20:27.9627210Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9627963Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9628640Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:20:27.9629328Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9629957Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9630612Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:20:27.9631296Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9631965Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:20:27.9632584Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9633096Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:20:27.9633587Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:20:27.9634077Z Jul 12 04:20:27 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:20:27.9634589Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:20:27.9635099Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:20:27.9635608Z Jul 12 04:20:27 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:20:27.9636121Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9636639Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:20:27.9637466Z Jul 12 04:20:27 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:20:27.9638064Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:20:27.9638770Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:20:27.9639397Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:20:27.9640061Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:20:27.9640741Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:20:27.9641395Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:20:27.9642086Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:20:27.9642733Z Jul 12 04:20:27 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:20:27.9643331Z Jul 12 04:20:27 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:20:27.9643915Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:20:27.9644449Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:20:27.9645140Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:20:27.9645726Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:20:27.9646233Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:20:27.9646817Z Jul 12 04:20:27 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:20:27.9647352Z Jul 12 04:20:27 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:20:27.9647880Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:20:27.9648472Z Jul 12 04:20:27 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:20:27.9649053Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:20:27.9649639Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:20:27.9650200Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:20:27.9650750Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:20:27.9651289Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9651847Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:20:27.9652401Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:20:27.9652948Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:20:27.9653527Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:20:27.9654071Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:20:27.9654580Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:20:27.9655098Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:20:27.9655614Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:20:27.9656131Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:20:27.9656712Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9657210Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:20:27.9722967Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:20:27.9723517Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:20:27.9724476Z Jul 12 04:20:27 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:20:27.9725099Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:20:27.9725699Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:20:27.9726331Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:20:27.9727009Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:20:27.9727704Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:20:27.9728566Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:20:27.9729451Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:20:27.9730088Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:20:27.9730690Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:20:27.9731347Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:20:27.9732038Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:20:27.9732705Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:20:27.9733390Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:20:27.9734061Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:20:27.9734703Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:20:27.9735293Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:20:27.9735860Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:20:27.9736414Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:20:27.9736910Z Jul 12 04:20:27 Caused by: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:20:27.9737458Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:20:27.9738173Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:20:27.9738855Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:20:27.9739527Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:20:27.9740200Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:20:27.9740672Z Jul 12 04:20:27 ... 77 more
> 2022-07-12T04:20:27.9741253Z Jul 12 04:20:27 Caused by:
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9741862Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:20:27.9742357Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:20:27.9742928Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:20:27.9743400Z Jul 12 04:20:27 ... 81 more
> 2022-07-12T04:20:27.9743836Z Jul 12 04:20:27 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9744404Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:27.9744989Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:27.9745591Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:27.9746145Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:20:27.9746675Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:20:27.9747316Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:20:27.9747803Z Jul 12 04:20:27 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:20:27.9748139Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9748386Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9748715Z Jul 12 04:20:27 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:20:27.9749249Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:20:27.9749929Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:20:27.9750603Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:20:27.9751758Z Jul 12 04:20:27 ...(79 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:20:27.9752175Z Jul 12 04:20:27 error:
> 2022-07-12T04:20:27.9752495Z Jul 12 04:20:27 Expecting throwable message:
> 2022-07-12T04:20:27.9752841Z Jul 12 04:20:27 "Fail to create input splits."
> 2022-07-12T04:20:27.9753166Z Jul 12 04:20:27 to contain:
> 2022-07-12T04:20:27.9753564Z Jul 12 04:20:27 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:20:27.9753955Z Jul 12 04:20:27 but did not.
> 2022-07-12T04:20:27.9754216Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9754524Z Jul 12 04:20:27 Throwable that failed the check:
> 2022-07-12T04:20:27.9754828Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9755164Z Jul 12 04:20:27 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:20:27.9755709Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:20:27.9756384Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:20:27.9757050Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:20:27.9757908Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:20:27.9758572Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:20:27.9759203Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:20:27.9759822Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:20:27.9760640Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:20:27.9761443Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:20:27.9762173Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9762815Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9763491Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:20:27.9764166Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9764806Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9765472Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:20:27.9766148Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9766881Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:20:27.9767512Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9768037Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:20:27.9768523Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:20:27.9769024Z Jul 12 04:20:27 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:20:27.9769542Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:20:27.9770044Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:20:27.9770553Z Jul 12 04:20:27 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:20:27.9771063Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9771580Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:20:27.9772093Z Jul 12 04:20:27 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:20:27.9772667Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:20:27.9773281Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:20:27.9773908Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:20:27.9774579Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:20:27.9775254Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:20:27.9775912Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:20:27.9776617Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:20:27.9777275Z Jul 12 04:20:27 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:20:27.9777862Z Jul 12 04:20:27 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:20:27.9778525Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:20:27.9779072Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:20:27.9779706Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:20:27.9780296Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:20:27.9780807Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:20:27.9781391Z Jul 12 04:20:27 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:20:27.9781907Z Jul 12 04:20:27 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:20:27.9782524Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:20:27.9783120Z Jul 12 04:20:27 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:20:27.9783704Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:20:27.9784279Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:20:27.9784944Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:20:27.9785490Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:20:27.9786026Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9786585Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:20:27.9787132Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:20:27.9787690Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:20:27.9788275Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:20:27.9788816Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:20:27.9789316Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:20:27.9789838Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:20:27.9790363Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:20:27.9790877Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:20:27.9791399Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9791901Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:20:27.9792377Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:20:27.9792839Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:20:27.9793360Z Jul 12 04:20:27 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:20:27.9793956Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:20:27.9794543Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:20:27.9795168Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:20:27.9795836Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:20:27.9796519Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:20:27.9797397Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:20:27.9798108Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:20:27.9798739Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:20:27.9799324Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:20:27.9799964Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:20:27.9800645Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:20:27.9801294Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:20:27.9801978Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:20:27.9802649Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:20:27.9803369Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:20:27.9803953Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:20:27.9804509Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:20:27.9805056Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:20:27.9805680Z Jul 12 04:20:27 Caused by:
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9806293Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:20:27.9806789Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:20:27.9807358Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:20:27.9807830Z Jul 12 04:20:27 ... 81 more
> 2022-07-12T04:20:27.9808264Z Jul 12 04:20:27 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9808826Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:27.9809412Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:27.9810020Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:27.9810574Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:20:27.9811101Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:20:27.9811668Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:20:27.9812156Z Jul 12 04:20:27 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:20:27.9812487Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9812743Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9813208Z Jul 12 04:20:27
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9813791Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:20:27.9814285Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:20:27.9814846Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:20:27.9815836Z Jul 12 04:20:27 ...(81 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:20:27.9816265Z Jul 12 04:20:27 error:
> 2022-07-12T04:20:27.9816580Z Jul 12 04:20:27 Expecting throwable message:
> 2022-07-12T04:20:27.9817029Z Jul 12 04:20:27 "java.io.IOException: Not a
> file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1"
> 2022-07-12T04:20:27.9817457Z Jul 12 04:20:27 to contain:
> 2022-07-12T04:20:27.9817840Z Jul 12 04:20:27 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:20:27.9818229Z Jul 12 04:20:27 but did not.
> 2022-07-12T04:20:27.9818500Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9818802Z Jul 12 04:20:27 Throwable that failed the check:
> 2022-07-12T04:20:27.9819103Z Jul 12 04:20:27
> 2022-07-12T04:20:27.9819563Z Jul 12 04:20:27
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9820148Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:20:27.9820648Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:20:27.9821221Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:20:27.9821978Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:20:27.9822648Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:20:27.9823329Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:20:27.9823988Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:20:27.9824614Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:20:27.9825236Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:20:27.9825950Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:20:27.9826762Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:20:27.9827488Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9828118Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9828783Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:20:27.9829448Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9830080Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:20:27.9830742Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:20:27.9831416Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:20:27.9832074Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:20:27.9832689Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9833281Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:20:27.9833749Z Jul 12 04:20:27 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:20:27.9834242Z Jul 12 04:20:27 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:20:27.9834755Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:20:27.9835265Z Jul 12 04:20:27 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:20:27.9835774Z Jul 12 04:20:27 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:20:27.9836281Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:20:27.9836791Z Jul 12 04:20:27 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:20:27.9837308Z Jul 12 04:20:27 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:20:27.9878683Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:20:27.9879361Z Jul 12 04:20:27 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:20:27.9880007Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:20:27.9880992Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:20:27.9881689Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:20:27.9882343Z Jul 12 04:20:27 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:20:27.9883042Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:20:27.9883708Z Jul 12 04:20:27 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:20:27.9884312Z Jul 12 04:20:27 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:20:27.9884898Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:20:27.9885452Z Jul 12 04:20:27 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:20:27.9886078Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:20:27.9886667Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:20:27.9887185Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:20:27.9887783Z Jul 12 04:20:27 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:20:27.9888328Z Jul 12 04:20:27 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:20:27.9888861Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:20:27.9889461Z Jul 12 04:20:27 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:20:27.9890038Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:20:27.9890627Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:20:27.9891205Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:20:27.9891767Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:20:27.9892302Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9892954Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:20:27.9893499Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:20:27.9894038Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:20:27.9894619Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:20:27.9895166Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:20:27.9895671Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:20:27.9896190Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:20:27.9896702Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:20:27.9897205Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:20:27.9897720Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:27.9898220Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:20:27.9898697Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:20:27.9899162Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:20:27.9899737Z Jul 12 04:20:27 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:20:27.9900321Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:20:27.9900916Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:20:27.9901535Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:20:27.9902218Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:20:27.9902915Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:20:27.9903631Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:20:27.9904328Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:20:27.9904956Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:20:27.9905537Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:20:27.9906176Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:20:27.9906872Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:20:27.9907535Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:20:27.9908206Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:20:27.9908884Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:20:27.9909506Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:20:27.9934332Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:20:27.9935034Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:20:27.9935850Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:20:27.9936432Z Jul 12 04:20:27 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:27.9937008Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:28.7230243Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:28.7230961Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:28.7231529Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:20:28.7232062Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:20:28.7232641Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:20:28.7233171Z Jul 12 04:20:27 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:20:28.7233510Z Jul 12 04:20:27
> 2022-07-12T04:20:28.7233772Z Jul 12 04:20:27
> 2022-07-12T04:20:28.7234182Z Jul 12 04:20:27 java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:28.7234741Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:28.7235657Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:28.7236274Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:28.7237640Z Jul 12 04:20:27 ...(4 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:20:28.7238085Z Jul 12 04:20:27 error:
> 2022-07-12T04:20:28.7238400Z Jul 12 04:20:27 Expecting throwable message:
> 2022-07-12T04:20:28.7238827Z Jul 12 04:20:27 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1"
> 2022-07-12T04:20:28.7239227Z Jul 12 04:20:27 to contain:
> 2022-07-12T04:20:28.7239617Z Jul 12 04:20:27 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:20:28.7240010Z Jul 12 04:20:27 but did not.
> 2022-07-12T04:20:28.7240288Z Jul 12 04:20:27
> 2022-07-12T04:20:28.7240585Z Jul 12 04:20:27 Throwable that failed the check:
> 2022-07-12T04:20:28.7240889Z Jul 12 04:20:27
> 2022-07-12T04:20:28.7241300Z Jul 12 04:20:27 java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:20:28.7241859Z Jul 12 04:20:27 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:20:28.7242447Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:20:28.7243063Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:20:28.7243611Z Jul 12 04:20:27 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:20:28.7244140Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:20:28.7244726Z Jul 12 04:20:27 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:20:28.7245219Z Jul 12 04:20:27 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:20:28.7245692Z Jul 12 04:20:27 at
> FlinkAssertions.lambda$anyCauseMatches$5(FlinkAssertions.java:106)
> 2022-07-12T04:20:28.7246209Z Jul 12 04:20:27 at
> sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method)
> 2022-07-12T04:20:28.7246769Z Jul 12 04:20:27 at
> sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)
> 2022-07-12T04:20:28.7247411Z Jul 12 04:20:27 at
> sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
> 2022-07-12T04:20:28.7248230Z Jul 12 04:20:27 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:597)
> 2022-07-12T04:20:28.7248805Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:20:28.7249320Z Jul 12 04:20:27 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:20:28.7249915Z Jul 12 04:20:27 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:20:28.7250452Z Jul 12 04:20:27 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:20:28.7250974Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:20:28.7251564Z Jul 12 04:20:27 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:20:28.7252146Z Jul 12 04:20:27 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:20:28.7252732Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:20:28.7253299Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:20:28.7253855Z Jul 12 04:20:27 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:20:28.7254446Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:28.7255001Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:20:28.7255548Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:20:28.7256098Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:20:28.7256673Z Jul 12 04:20:27 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:20:28.7257223Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:20:28.7257726Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:20:28.7258233Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:20:28.7258749Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:20:28.7259266Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:20:28.7259785Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:20:28.7260282Z Jul 12 04:20:27 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:20:28.7260767Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:20:28.7261220Z Jul 12 04:20:27 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:20:28.7261749Z Jul 12 04:20:27 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:20:28.7262348Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:20:28.7262934Z Jul 12 04:20:27 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:20:28.7263557Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:20:28.7264243Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:20:28.7264934Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:20:28.7265650Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:20:28.7266415Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:20:28.7267051Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:20:28.7267638Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:20:28.7268289Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:20:28.7268973Z Jul 12 04:20:27 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:20:28.7269643Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:20:28.7270312Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:20:28.7270981Z Jul 12 04:20:27 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:20:28.7271612Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:20:28.7272191Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:20:28.7272809Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:20:28.7273356Z Jul 12 04:20:27 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:20:28.7273758Z Jul 12 04:20:27
> 2022-07-12T04:20:30.2231809Z Jul 12 04:20:29 [ERROR] Picked up
> JAVA_TOOL_OPTIONS: -XX:+HeapDumpOnOutOfMemoryError
> 2022-07-12T04:20:31.4694903Z Jul 12 04:20:31 [INFO] Running
> org.apache.flink.table.catalog.hive.HiveCatalogITCase
> 2022-07-12T04:21:11.2730557Z Jul 12 04:21:11 [WARNING] Tests run: 17,
> Failures: 0, Errors: 0, Skipped: 3, Time elapsed: 168.97 s - in
> org.apache.flink.connectors.hive.TableEnvHiveConnectorITCase
> 2022-07-12T04:21:12.4779976Z Jul 12 04:21:12 [ERROR] Picked up
> JAVA_TOOL_OPTIONS: -XX:+HeapDumpOnOutOfMemoryError
> 2022-07-12T04:21:14.4325471Z Jul 12 04:21:14 [INFO] Running
> org.apache.flink.table.catalog.hive.HiveCatalogUdfITCase
> 2022-07-12T04:21:37.8028634Z Jul 12 04:21:37 [INFO] Tests run: 14, Failures:
> 0, Errors: 0, Skipped: 0, Time elapsed: 66.271 s - in
> org.apache.flink.table.catalog.hive.HiveCatalogITCase
> 2022-07-12T04:21:44.7479437Z Jul 12 04:21:44 [INFO] Tests run: 3, Failures:
> 0, Errors: 0, Skipped: 0, Time elapsed: 30.298 s - in
> org.apache.flink.table.catalog.hive.HiveCatalogUdfITCase
> 2022-07-12T04:21:45.1103445Z Jul 12 04:21:45 [INFO]
> 2022-07-12T04:21:45.1104396Z Jul 12 04:21:45 [INFO] Results:
> 2022-07-12T04:21:45.1104941Z Jul 12 04:21:45 [INFO]
> 2022-07-12T04:21:45.1109327Z Jul 12 04:21:45 [ERROR] Failures:
> 2022-07-12T04:21:45.1114586Z Jul 12 04:21:45 [ERROR]
> HiveDialectITCase.testTableWithSubDirsInPartitionDir:597
> 2022-07-12T04:21:45.1115440Z Jul 12 04:21:45 Multiple Failures (1 failure)
> 2022-07-12T04:21:45.1116520Z Jul 12 04:21:45 -- failure 1 --
> 2022-07-12T04:21:45.1117948Z Jul 12 04:21:45 [Any cause contains message 'Not
> a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2']
> 2022-07-12T04:21:45.1164459Z Jul 12 04:21:45 Expecting any element of:
> 2022-07-12T04:21:45.1165322Z Jul 12 04:21:45
> [org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:21:45.1169910Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:21:45.1171238Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:21:45.1172885Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:21:45.1174617Z Jul 12 04:21:45 ...(75 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:21:45.1175568Z Jul 12 04:21:45 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:21:45.1176551Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:21:45.1177691Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:21:45.1179025Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:21:45.1180609Z Jul 12 04:21:45 ...(79 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:21:45.1181829Z Jul 12 04:21:45
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1183614Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:21:45.1184567Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:21:45.1185713Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:21:45.1187373Z Jul 12 04:21:45 ...(81 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed),
> 2022-07-12T04:21:45.1188746Z Jul 12 04:21:45 java.io.IOException: Not a
> file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1189885Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1191052Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1192243Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1193984Z Jul 12 04:21:45 ...(4 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)]
> 2022-07-12T04:21:45.1194951Z Jul 12 04:21:45 to satisfy the given assertions
> requirements but none did:
> 2022-07-12T04:21:45.1195546Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1196295Z Jul 12 04:21:45
> org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:21:45.1197109Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:21:45.1206332Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:21:45.1207287Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:21:45.1208609Z Jul 12 04:21:45 ...(75 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:21:45.1209119Z Jul 12 04:21:45 error:
> 2022-07-12T04:21:45.1209475Z Jul 12 04:21:45 Expecting throwable message:
> 2022-07-12T04:21:45.1209894Z Jul 12 04:21:45 "java.io.IOException: Fail to
> create input splits."
> 2022-07-12T04:21:45.1210290Z Jul 12 04:21:45 to contain:
> 2022-07-12T04:21:45.1210719Z Jul 12 04:21:45 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:21:45.1211164Z Jul 12 04:21:45 but did not.
> 2022-07-12T04:21:45.1211465Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1211803Z Jul 12 04:21:45 Throwable that failed the check:
> 2022-07-12T04:21:45.1214141Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1214598Z Jul 12 04:21:45
> org.apache.flink.connectors.hive.FlinkHiveException: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:21:45.1215300Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:98)
> 2022-07-12T04:21:45.1216027Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:21:45.1216931Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:21:45.1217774Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:21:45.1218721Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:21:45.1220057Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1220779Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1221550Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:21:45.1222353Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1223080Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1223845Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:21:45.1224716Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1225484Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:21:45.1226184Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1226770Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:21:45.1227321Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:21:45.1227885Z Jul 12 04:21:45 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:21:45.1228466Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:21:45.1229041Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:21:45.1229612Z Jul 12 04:21:45 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:21:45.1230191Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1230779Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:21:45.1231364Z Jul 12 04:21:45 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:21:45.1232013Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:21:45.1232725Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:21:45.1233441Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:21:45.1234205Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:21:45.1234997Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:21:45.1235754Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:21:45.1236549Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:21:45.1237303Z Jul 12 04:21:45 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:21:45.1238162Z Jul 12 04:21:45 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:21:45.1238831Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:21:45.1239441Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:21:45.1240167Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:21:45.1240837Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:21:45.1241419Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:21:45.1242098Z Jul 12 04:21:45 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:21:45.1242717Z Jul 12 04:21:45 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:21:45.1243315Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:21:45.1243995Z Jul 12 04:21:45 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:21:45.1244672Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:21:45.1245398Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:21:45.1246054Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:21:45.1246696Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:21:45.1247309Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1247934Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:21:45.1248573Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:21:45.1249199Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:21:45.1249872Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:21:45.1250496Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:21:45.1251073Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:21:45.1251651Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:21:45.1252239Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:21:45.1252824Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:21:45.1253411Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1253983Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:21:45.1254523Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:21:45.1255038Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:21:45.1255633Z Jul 12 04:21:45 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:21:45.1256329Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:21:45.1257001Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:21:45.1257716Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:21:45.1258497Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:21:45.1259355Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:21:45.1260182Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:21:45.1261005Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:21:45.1261740Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:21:45.1262408Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:21:45.1263151Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:21:45.1263944Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:21:45.1264708Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:21:45.1265478Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:21:45.1266304Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:21:45.1267029Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:21:45.1267701Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:21:45.1268333Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:21:45.1268960Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:21:45.1269520Z Jul 12 04:21:45 Caused by: java.io.IOException:
> Fail to create input splits.
> 2022-07-12T04:21:45.1270134Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:21:45.1270913Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:21:45.1271683Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:21:45.1272453Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:21:45.1273222Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:21:45.1273756Z Jul 12 04:21:45 ... 77 more
> 2022-07-12T04:21:45.1274313Z Jul 12 04:21:45 Caused by:
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1274998Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:21:45.1275556Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:21:45.1276205Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:21:45.1276748Z Jul 12 04:21:45 ... 81 more
> 2022-07-12T04:21:45.1277237Z Jul 12 04:21:45 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1280605Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1281285Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1281989Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1282727Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:21:45.1283330Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:21:45.1283990Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:21:45.1284555Z Jul 12 04:21:45 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:21:45.1284930Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1285205Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1285569Z Jul 12 04:21:45 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:21:45.1286176Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:21:45.1286954Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:21:45.1287727Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:21:45.1288795Z Jul 12 04:21:45 ...(79 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:21:45.1289279Z Jul 12 04:21:45 error:
> 2022-07-12T04:21:45.1289625Z Jul 12 04:21:45 Expecting throwable message:
> 2022-07-12T04:21:45.1290077Z Jul 12 04:21:45 "Fail to create input splits."
> 2022-07-12T04:21:45.1290430Z Jul 12 04:21:45 to contain:
> 2022-07-12T04:21:45.1297758Z Jul 12 04:21:45 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:21:45.1298208Z Jul 12 04:21:45 but did not.
> 2022-07-12T04:21:45.1298510Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1298845Z Jul 12 04:21:45 Throwable that failed the check:
> 2022-07-12T04:21:45.1299180Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1299551Z Jul 12 04:21:45 java.io.IOException: Fail to
> create input splits.
> 2022-07-12T04:21:45.1300164Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:84)
> 2022-07-12T04:21:45.1300955Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:21:45.1301855Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:21:45.1302639Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:21:45.1303495Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:21:45.1304232Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:21:45.1304952Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:21:45.1305863Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:21:45.1306812Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:21:45.1307747Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1308485Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1309343Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:21:45.1310135Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1310872Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1311875Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:21:45.1312643Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1313493Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:21:45.1314287Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1314882Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:21:45.1315530Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:21:45.1316104Z Jul 12 04:21:45 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:21:45.1316719Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:21:45.1317298Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:21:45.1318086Z Jul 12 04:21:45 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:21:45.1318676Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1319352Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:21:45.1320028Z Jul 12 04:21:45 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:21:45.1320675Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:21:45.1321393Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:21:45.1322201Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:21:45.1322986Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:21:45.1323783Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:21:45.1324543Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:21:45.1326914Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:21:45.1333950Z Jul 12 04:21:45 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:21:45.1334661Z Jul 12 04:21:45 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:21:45.1335343Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:21:45.1335981Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:21:45.1336712Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:21:45.1337873Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:21:45.1338473Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:21:45.1339141Z Jul 12 04:21:45 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:21:45.1339753Z Jul 12 04:21:45 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:21:45.1340457Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:21:45.1341151Z Jul 12 04:21:45 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:21:45.1341936Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:21:45.1342615Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:21:45.1343275Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:21:45.1343911Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:21:45.1344655Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1345791Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:21:45.1348562Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:21:45.1349893Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:21:45.1350958Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:21:45.1351785Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:21:45.1352945Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:21:45.1353939Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:21:45.1354928Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:21:45.1355531Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:21:45.1356127Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1356688Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:21:45.1357231Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:21:45.1357933Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:21:45.1358645Z Jul 12 04:21:45 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:21:45.1359775Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:21:45.1361251Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:21:45.1362006Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:21:45.1363351Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:21:45.1364799Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:21:45.1366301Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:21:45.1367158Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:21:45.1368527Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:21:45.1369798Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:21:45.1370757Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:21:45.1371989Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:21:45.1373338Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:21:45.1374888Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:21:45.1375890Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:21:45.1377089Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:21:45.1378344Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:21:45.1379375Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:21:45.1380320Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:21:45.1381577Z Jul 12 04:21:45 Caused by:
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1382937Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:21:45.1383883Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:21:45.1384769Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:21:45.1385323Z Jul 12 04:21:45 ... 81 more
> 2022-07-12T04:21:45.1385899Z Jul 12 04:21:45 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1386561Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1387241Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1387947Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1388578Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:21:45.1389191Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:21:45.1389852Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:21:45.1390975Z Jul 12 04:21:45 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:21:45.1391385Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1391680Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1392211Z Jul 12 04:21:45
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1395911Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:21:45.1396951Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:21:45.1398285Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:21:45.1400980Z Jul 12 04:21:45 ...(81 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:21:45.1402240Z Jul 12 04:21:45 error:
> 2022-07-12T04:21:45.1403021Z Jul 12 04:21:45 Expecting throwable message:
> 2022-07-12T04:21:45.1404120Z Jul 12 04:21:45 "java.io.IOException: Not a
> file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1"
> 2022-07-12T04:21:45.1404837Z Jul 12 04:21:45 to contain:
> 2022-07-12T04:21:45.1405642Z Jul 12 04:21:45 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:21:45.1410624Z Jul 12 04:21:45 but did not.
> 2022-07-12T04:21:45.1411207Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1411752Z Jul 12 04:21:45 Throwable that failed the check:
> 2022-07-12T04:21:45.1412578Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1413115Z Jul 12 04:21:45
> java.util.concurrent.ExecutionException: java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1414559Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.report(FutureTask.java:122)
> 2022-07-12T04:21:45.1415593Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.get(FutureTask.java:192)
> 2022-07-12T04:21:45.1416710Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter.getHiveTablePartitionMRSplits(MRSplitsGetter.java:79)
> 2022-07-12T04:21:45.1417988Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveSourceFileEnumerator.createInputSplits(HiveSourceFileEnumerator.java:69)
> 2022-07-12T04:21:45.1419359Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.lambda$getDataStream$1(HiveTableSource.java:158)
> 2022-07-12T04:21:45.1420383Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.logRunningTime(HiveParallelismInference.java:107)
> 2022-07-12T04:21:45.1421618Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveParallelismInference.infer(HiveParallelismInference.java:95)
> 2022-07-12T04:21:45.1422780Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource.getDataStream(HiveTableSource.java:153)
> 2022-07-12T04:21:45.1423885Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveTableSource$1.produceDataStream(HiveTableSource.java:117)
> 2022-07-12T04:21:45.1425187Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecTableSourceScan.translateToPlanInternal(CommonExecTableSourceScan.java:139)
> 2022-07-12T04:21:45.1426702Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecTableSourceScan.translateToPlanInternal(BatchExecTableSourceScan.java:63)
> 2022-07-12T04:21:45.1427775Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1429100Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1430140Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCalc.translateToPlanInternal(CommonExecCalc.java:94)
> 2022-07-12T04:21:45.1431275Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1432271Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:249)
> 2022-07-12T04:21:45.1433302Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.batch.BatchExecSink.translateToPlanInternal(BatchExecSink.java:65)
> 2022-07-12T04:21:45.1434569Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:148)
> 2022-07-12T04:21:45.1435867Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.$anonfun$translateToPlan$1(BatchPlanner.scala:88)
> 2022-07-12T04:21:45.1436847Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1450452Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach(Iterator.scala:937)
> 2022-07-12T04:21:45.1456329Z Jul 12 04:21:45 at
> scala.collection.Iterator.foreach$(Iterator.scala:937)
> 2022-07-12T04:21:45.1457063Z Jul 12 04:21:45 at
> scala.collection.AbstractIterator.foreach(Iterator.scala:1425)
> 2022-07-12T04:21:45.1457657Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach(IterableLike.scala:70)
> 2022-07-12T04:21:45.1458245Z Jul 12 04:21:45 at
> scala.collection.IterableLike.foreach$(IterableLike.scala:69)
> 2022-07-12T04:21:45.1458840Z Jul 12 04:21:45 at
> scala.collection.AbstractIterable.foreach(Iterable.scala:54)
> 2022-07-12T04:21:45.1459409Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map(TraversableLike.scala:233)
> 2022-07-12T04:21:45.1460006Z Jul 12 04:21:45 at
> scala.collection.TraversableLike.map$(TraversableLike.scala:226)
> 2022-07-12T04:21:45.1460602Z Jul 12 04:21:45 at
> scala.collection.AbstractTraversable.map(Traversable.scala:104)
> 2022-07-12T04:21:45.1462100Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.BatchPlanner.translateToPlan(BatchPlanner.scala:87)
> 2022-07-12T04:21:45.1466655Z Jul 12 04:21:45 at
> org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:182)
> 2022-07-12T04:21:45.1467395Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.translate(TableEnvironmentImpl.java:1651)
> 2022-07-12T04:21:45.1468177Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeQueryOperation(TableEnvironmentImpl.java:823)
> 2022-07-12T04:21:45.1469061Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:1312)
> 2022-07-12T04:21:45.1469831Z Jul 12 04:21:45 at
> org.apache.flink.table.api.internal.TableEnvironmentImpl.executeSql(TableEnvironmentImpl.java:696)
> 2022-07-12T04:21:45.1472878Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.lambda$testTableWithSubDirsInPartitionDir$0(HiveDialectITCase.java:595)
> 2022-07-12T04:21:45.1477862Z Jul 12 04:21:45 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> 2022-07-12T04:21:45.1478585Z Jul 12 04:21:45 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> 2022-07-12T04:21:45.1479268Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> 2022-07-12T04:21:45.1479897Z Jul 12 04:21:45 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> 2022-07-12T04:21:45.1480748Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.HiveDialectITCase.testTableWithSubDirsInPartitionDir(HiveDialectITCase.java:592)
> 2022-07-12T04:21:45.1481429Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2022-07-12T04:21:45.1482018Z Jul 12 04:21:45 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2022-07-12T04:21:45.1482702Z Jul 12 04:21:45 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2022-07-12T04:21:45.1483318Z Jul 12 04:21:45 at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2022-07-12T04:21:45.1483924Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
> 2022-07-12T04:21:45.1484607Z Jul 12 04:21:45 at
> org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
> 2022-07-12T04:21:45.1485272Z Jul 12 04:21:45 at
> org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
> 2022-07-12T04:21:45.1485948Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
> 2022-07-12T04:21:45.1486608Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
> 2022-07-12T04:21:45.1487262Z Jul 12 04:21:45 at
> org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
> 2022-07-12T04:21:45.1487879Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1488520Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
> 2022-07-12T04:21:45.1489142Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
> 2022-07-12T04:21:45.1489773Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
> 2022-07-12T04:21:45.1490449Z Jul 12 04:21:45 at
> org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
> 2022-07-12T04:21:45.1491075Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
> 2022-07-12T04:21:45.1491654Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
> 2022-07-12T04:21:45.1492245Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
> 2022-07-12T04:21:45.1492826Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
> 2022-07-12T04:21:45.1495285Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
> 2022-07-12T04:21:45.1497986Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
> 2022-07-12T04:21:45.1500206Z Jul 12 04:21:45 at
> org.junit.runners.ParentRunner.run(ParentRunner.java:413)
> 2022-07-12T04:21:45.1500764Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:137)
> 2022-07-12T04:21:45.1501293Z Jul 12 04:21:45 at
> org.junit.runner.JUnitCore.run(JUnitCore.java:115)
> 2022-07-12T04:21:45.1508220Z Jul 12 04:21:45 at
> org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
> 2022-07-12T04:21:45.1509438Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
> 2022-07-12T04:21:45.1511339Z Jul 12 04:21:45 at
> org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
> 2022-07-12T04:21:45.1558574Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:107)
> 2022-07-12T04:21:45.1559403Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:88)
> 2022-07-12T04:21:45.1560236Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:54)
> 2022-07-12T04:21:45.1561086Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:67)
> 2022-07-12T04:21:45.1562106Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:52)
> 2022-07-12T04:21:45.1562844Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
> 2022-07-12T04:21:45.1563528Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
> 2022-07-12T04:21:45.1564281Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
> 2022-07-12T04:21:45.1565084Z Jul 12 04:21:45 at
> org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
> 2022-07-12T04:21:45.1565859Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:188)
> 2022-07-12T04:21:45.1566830Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
> 2022-07-12T04:21:45.1567622Z Jul 12 04:21:45 at
> org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:124)
> 2022-07-12T04:21:45.1568344Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
> 2022-07-12T04:21:45.1569023Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
> 2022-07-12T04:21:45.1569670Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
> 2022-07-12T04:21:45.1573398Z Jul 12 04:21:45 at
> org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
> 2022-07-12T04:21:45.1574129Z Jul 12 04:21:45 Caused by: java.io.IOException:
> Not a file: file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1574716Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1575306Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1575932Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1576491Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:21:45.1577041Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:21:45.1577624Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:21:45.1578123Z Jul 12 04:21:45 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:21:45.1578660Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1578911Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1579329Z Jul 12 04:21:45 java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1579909Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1580511Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1581135Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1582315Z Jul 12 04:21:45 ...(4 remaining lines not
> displayed - this can be changed with
> Assertions.setMaxStackTraceElementsDisplayed)
> 2022-07-12T04:21:45.1582895Z Jul 12 04:21:45 error:
> 2022-07-12T04:21:45.1583204Z Jul 12 04:21:45 Expecting throwable message:
> 2022-07-12T04:21:45.1583637Z Jul 12 04:21:45 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1"
> 2022-07-12T04:21:45.1584056Z Jul 12 04:21:45 to contain:
> 2022-07-12T04:21:45.1584453Z Jul 12 04:21:45 "Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=2"
> 2022-07-12T04:21:45.1584858Z Jul 12 04:21:45 but did not.
> 2022-07-12T04:21:45.1585141Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1585434Z Jul 12 04:21:45 Throwable that failed the check:
> 2022-07-12T04:21:45.1585840Z Jul 12 04:21:45
> 2022-07-12T04:21:45.1586246Z Jul 12 04:21:45 java.io.IOException: Not a file:
> file:/tmp/junit297605250552556431/hive_warehouse/fact_tz/ds=1/hr=1
> 2022-07-12T04:21:45.1586810Z Jul 12 04:21:45 at
> org.apache.hadoop.mapred.FileInputFormat.getSplits(FileInputFormat.java:322)
> 2022-07-12T04:21:45.1587413Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:134)
> 2022-07-12T04:21:45.1588028Z Jul 12 04:21:45 at
> org.apache.flink.connectors.hive.MRSplitsGetter$MRSplitter.call(MRSplitsGetter.java:96)
> 2022-07-12T04:21:45.1588573Z Jul 12 04:21:45 at
> java.util.concurrent.FutureTask.run(FutureTask.java:266)
> 2022-07-12T04:21:45.1589125Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
> 2022-07-12T04:21:45.1589710Z Jul 12 04:21:45 at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
> 2022-07-12T04:21:45.1590211Z Jul 12 04:21:45 at
> java.lang.Thread.run(Thread.java:748)
> 2022-07-12T04:21:45.1590705Z Jul 12 04:21:45 at
> FlinkAssertions.lambda$anyCauseMatches$5(FlinkAssertions.java:106)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=38057&view=logs&j=5cae8624-c7eb-5c51-92d3-4d2dacedd221&t=5acec1b4-945b-59ca-34f8-168928ce5199
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
