You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Huang Xingbo (Jira)" <ji...@apache.org> on 2022/07/13 02:15:00 UTC
[jira] [Commented] (FLINK-28525) HiveDialectITCase.testTableWithSubDirsInPartitionDir failed with AssertJMultipleFailuresError
[ https://issues.apache.org/jira/browse/FLINK-28525?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17566100#comment-17566100 ]
Huang Xingbo commented on FLINK-28525:
--------------------------------------
Hi [~luoyuxia] , could you help take a look?
> 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
> Priority: Critical
> Labels: 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)