[
https://issues.apache.org/jira/browse/FLINK-29427?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17626607#comment-17626607
]
Robert Metzger commented on FLINK-29427:
----------------------------------------
Another instance:
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42642&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4
I'm including the entire stack trace here again for better discoverability of
the ticket
{code}
2022-10-31T10:36:52.5727692Z Oct 31 10:36:52 [ERROR]
LookupJoinITCase.testJoinTemporalTableWithComputedColumnAndPushDown Time
elapsed: 0.259 s <<< ERROR!
2022-10-31T10:36:52.5728256Z Oct 31 10:36:52 java.lang.RuntimeException: Failed
to fetch next result
2022-10-31T10:36:52.5729008Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-10-31T10:36:52.5729945Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-10-31T10:36:52.5730765Z Oct 31 10:36:52 at
org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222)
2022-10-31T10:36:52.5731457Z Oct 31 10:36:52 at
java.util.Iterator.forEachRemaining(Iterator.java:115)
2022-10-31T10:36:52.5732046Z Oct 31 10:36:52 at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:115)
2022-10-31T10:36:52.5732709Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308)
2022-10-31T10:36:52.5733412Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:144)
2022-10-31T10:36:52.5734111Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:108)
2022-10-31T10:36:52.5734927Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.batch.sql.join.LookupJoinITCase.testJoinTemporalTableWithComputedColumnAndPushDown(LookupJoinITCase.scala:350)
2022-10-31T10:36:52.5735660Z Oct 31 10:36:52 at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-10-31T10:36:52.5736232Z Oct 31 10:36:52 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-10-31T10:36:52.5736871Z Oct 31 10:36:52 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-10-31T10:36:52.5737463Z Oct 31 10:36:52 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-10-31T10:36:52.5738053Z Oct 31 10:36:52 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-10-31T10:36:52.5738698Z Oct 31 10:36:52 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-10-31T10:36:52.5739454Z Oct 31 10:36:52 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-10-31T10:36:52.5740160Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-10-31T10:36:52.5740803Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-10-31T10:36:52.5741416Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-10-31T10:36:52.5742038Z Oct 31 10:36:52 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-10-31T10:36:52.5742704Z Oct 31 10:36:52 at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-10-31T10:36:52.5743255Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-10-31T10:36:52.5743882Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-10-31T10:36:52.5744496Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-10-31T10:36:52.5745093Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-10-31T10:36:52.5745755Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-10-31T10:36:52.5746353Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-10-31T10:36:52.5746901Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-10-31T10:36:52.5747477Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-10-31T10:36:52.5748061Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-10-31T10:36:52.5748617Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-10-31T10:36:52.5749257Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-10-31T10:36:52.5749783Z Oct 31 10:36:52 at
org.junit.runners.Suite.runChild(Suite.java:128)
2022-10-31T10:36:52.5750313Z Oct 31 10:36:52 at
org.junit.runners.Suite.runChild(Suite.java:27)
2022-10-31T10:36:52.5750938Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-10-31T10:36:52.5751498Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-10-31T10:36:52.5752060Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-10-31T10:36:52.5752638Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-10-31T10:36:52.5753215Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-10-31T10:36:52.5753783Z Oct 31 10:36:52 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-10-31T10:36:52.5754384Z Oct 31 10:36:52 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-10-31T10:36:52.5754943Z Oct 31 10:36:52 at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2022-10-31T10:36:52.5755475Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-10-31T10:36:52.5756039Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-10-31T10:36:52.5756566Z Oct 31 10:36:52 at
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-10-31T10:36:52.5757065Z Oct 31 10:36:52 at
org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-10-31T10:36:52.5757642Z Oct 31 10:36:52 at
org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-10-31T10:36:52.5758322Z Oct 31 10:36:52 at
org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-10-31T10:36:52.5759047Z Oct 31 10:36:52 at
org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-10-31T10:36:52.5759749Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:147)
2022-10-31T10:36:52.5760564Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:127)
2022-10-31T10:36:52.5761314Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:90)
2022-10-31T10:36:52.5762093Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:55)
2022-10-31T10:36:52.5762908Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:102)
2022-10-31T10:36:52.5763770Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:54)
2022-10-31T10:36:52.5764459Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-10-31T10:36:52.5765113Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-10-31T10:36:52.5765833Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-10-31T10:36:52.5766596Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-10-31T10:36:52.5767359Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.lambda$execute$1(JUnitPlatformProvider.java:199)
2022-10-31T10:36:52.5768022Z Oct 31 10:36:52 at
java.util.Iterator.forEachRemaining(Iterator.java:116)
2022-10-31T10:36:52.5768649Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:193)
2022-10-31T10:36:52.5769488Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-10-31T10:36:52.5770294Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:120)
2022-10-31T10:36:52.5771012Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-10-31T10:36:52.5771721Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-10-31T10:36:52.5772347Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-10-31T10:36:52.5772962Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-10-31T10:36:52.5773513Z Oct 31 10:36:52 Caused by: java.io.IOException:
Failed to fetch job execution result
2022-10-31T10:36:52.5774190Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2022-10-31T10:36:52.5774987Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2022-10-31T10:36:52.5775774Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2022-10-31T10:36:52.5776354Z Oct 31 10:36:52 ... 67 more
2022-10-31T10:36:52.5776877Z Oct 31 10:36:52 Caused by:
java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-10-31T10:36:52.5777540Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-10-31T10:36:52.5778162Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-10-31T10:36:52.5778960Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2022-10-31T10:36:52.5779537Z Oct 31 10:36:52 ... 69 more
2022-10-31T10:36:52.5780017Z Oct 31 10:36:52 Caused by:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-10-31T10:36:52.5780646Z Oct 31 10:36:52 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-10-31T10:36:52.5781393Z Oct 31 10:36:52 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-10-31T10:36:52.5782101Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-10-31T10:36:52.5782734Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
2022-10-31T10:36:52.5783372Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
2022-10-31T10:36:52.5784133Z Oct 31 10:36:52 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138)
2022-10-31T10:36:52.5784939Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181)
2022-10-31T10:36:52.5785508Z Oct 31 10:36:52 ... 69 more
2022-10-31T10:36:52.5785968Z Oct 31 10:36:52 Caused by:
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
2022-10-31T10:36:52.5786717Z Oct 31 10:36:52 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)
2022-10-31T10:36:52.5787595Z Oct 31 10:36:52 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83)
2022-10-31T10:36:52.5788391Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256)
2022-10-31T10:36:52.5789199Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
2022-10-31T10:36:52.5789962Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
2022-10-31T10:36:52.5790681Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:739)
2022-10-31T10:36:52.5791463Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-10-31T10:36:52.5792172Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:80)
2022-10-31T10:36:52.5792867Z Oct 31 10:36:52 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:479)
2022-10-31T10:36:52.5793446Z Oct 31 10:36:52 at
sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
2022-10-31T10:36:52.5794040Z Oct 31 10:36:52 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-10-31T10:36:52.5794630Z Oct 31 10:36:52 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-10-31T10:36:52.5795234Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
2022-10-31T10:36:52.5795989Z Oct 31 10:36:52 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-10-31T10:36:52.5796729Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
2022-10-31T10:36:52.5797394Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
2022-10-31T10:36:52.5798089Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
2022-10-31T10:36:52.5798780Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
2022-10-31T10:36:52.5799461Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-10-31T10:36:52.5800100Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-10-31T10:36:52.5800659Z Oct 31 10:36:52 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-10-31T10:36:52.5801204Z Oct 31 10:36:52 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-10-31T10:36:52.5801782Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-10-31T10:36:52.5802373Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-10-31T10:36:52.5802960Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-10-31T10:36:52.5803531Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-10-31T10:36:52.5804146Z Oct 31 10:36:52 at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-10-31T10:36:52.5804654Z Oct 31 10:36:52 at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-10-31T10:36:52.5805178Z Oct 31 10:36:52 at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-10-31T10:36:52.5805734Z Oct 31 10:36:52 at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-10-31T10:36:52.5806261Z Oct 31 10:36:52 at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-10-31T10:36:52.5806768Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-10-31T10:36:52.5807283Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-10-31T10:36:52.5807757Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-10-31T10:36:52.5808293Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-10-31T10:36:52.5808974Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-10-31T10:36:52.5809591Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-10-31T10:36:52.5810258Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-10-31T10:36:52.5811368Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: java.util.concurrent.CompletionException:
java.lang.RuntimeException: Failed to reload lookup 'FULL' cache.
2022-10-31T10:36:52.5812174Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.LookupFullCache.getIfPresent(LookupFullCache.java:85)
2022-10-31T10:36:52.5813050Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.CachingLookupFunction.lookup(CachingLookupFunction.java:123)
2022-10-31T10:36:52.5813766Z Oct 31 10:36:52 at
org.apache.flink.table.functions.LookupFunction.eval(LookupFunction.java:52)
2022-10-31T10:36:52.5814306Z Oct 31 10:36:52 at
LookupFunction$173622.flatMap(Unknown Source)
2022-10-31T10:36:52.5814897Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.doFetch(LookupJoinRunner.java:92)
2022-10-31T10:36:52.5815974Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:79)
2022-10-31T10:36:52.5817125Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:34)
2022-10-31T10:36:52.5818114Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)
2022-10-31T10:36:52.5818851Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)
2022-10-31T10:36:52.5819688Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)
2022-10-31T10:36:52.5820440Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)
2022-10-31T10:36:52.5821117Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
2022-10-31T10:36:52.5821798Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
2022-10-31T10:36:52.5822579Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
2022-10-31T10:36:52.5823416Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
2022-10-31T10:36:52.5824227Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
2022-10-31T10:36:52.5825006Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:231)
2022-10-31T10:36:52.5825688Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
2022-10-31T10:36:52.5826474Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
2022-10-31T10:36:52.5827203Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:333)
2022-10-31T10:36:52.5828314Z Oct 31 10:36:52 Caused by:
java.util.concurrent.CompletionException: java.lang.RuntimeException: Failed to
reload lookup 'FULL' cache.
2022-10-31T10:36:52.5829081Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
2022-10-31T10:36:52.5829755Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
2022-10-31T10:36:52.5830482Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1643)
2022-10-31T10:36:52.5831117Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.exec(CompletableFuture.java:1632)
2022-10-31T10:36:52.5831732Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-10-31T10:36:52.5832335Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-10-31T10:36:52.5832927Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-10-31T10:36:52.5833542Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-10-31T10:36:52.5834331Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Failed to reload lookup 'FULL' cache.
2022-10-31T10:36:52.5835306Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.CacheLoader.run(CacheLoader.java:121)
2022-10-31T10:36:52.5836012Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-10-31T10:36:52.5836485Z Oct 31 10:36:52 ... 5 more
2022-10-31T10:36:52.5836904Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Failed to create InputFormatCacheLoadTask
2022-10-31T10:36:52.5837668Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.createCacheLoadTask(InputFormatCacheLoader.java:137)
2022-10-31T10:36:52.5838837Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.lambda$reloadCache$0(InputFormatCacheLoader.java:84)
2022-10-31T10:36:52.5839754Z Oct 31 10:36:52 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-10-31T10:36:52.5840466Z Oct 31 10:36:52 at
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
2022-10-31T10:36:52.5841085Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-10-31T10:36:52.5841706Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-10-31T10:36:52.5842320Z Oct 31 10:36:52 at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
2022-10-31T10:36:52.5842941Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-10-31T10:36:52.5843534Z Oct 31 10:36:52 at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
2022-10-31T10:36:52.5844279Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.reloadCache(InputFormatCacheLoader.java:85)
2022-10-31T10:36:52.5845108Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.CacheLoader.run(CacheLoader.java:105)
2022-10-31T10:36:52.5845634Z Oct 31 10:36:52 ... 6 more
2022-10-31T10:36:52.5846343Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Could not instantiate generated class
'KeyProjection$173616'
2022-10-31T10:36:52.5847018Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:74)
2022-10-31T10:36:52.5847875Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.keyselector.GenericRowDataKeySelector.open(GenericRowDataKeySelector.java:50)
2022-10-31T10:36:52.5848704Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputSplitCacheLoadTask.<init>(InputSplitCacheLoadTask.java:60)
2022-10-31T10:36:52.5849736Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.createCacheLoadTask(InputFormatCacheLoader.java:135)
2022-10-31T10:36:52.5850430Z Oct 31 10:36:52 ... 16 more
2022-10-31T10:36:52.5851049Z Oct 31 10:36:52 Caused by:
org.apache.flink.util.FlinkRuntimeException:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.5851820Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:94)
2022-10-31T10:36:52.5852497Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
2022-10-31T10:36:52.5853207Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
2022-10-31T10:36:52.5853713Z Oct 31 10:36:52 ... 19 more
2022-10-31T10:36:52.5854630Z Oct 31 10:36:52 Caused by:
org.apache.flink.shaded.guava30.com.google.common.util.concurrent.UncheckedExecutionException:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.5855559Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2051)
2022-10-31T10:36:52.5856380Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962)
2022-10-31T10:36:52.5857126Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859)
2022-10-31T10:36:52.5857833Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
2022-10-31T10:36:52.5858325Z Oct 31 10:36:52 ... 21 more
2022-10-31T10:36:52.5858848Z Oct 31 10:36:52 Caused by:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.5859653Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:107)
2022-10-31T10:36:52.5860451Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
2022-10-31T10:36:52.5861199Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864)
2022-10-31T10:36:52.5862000Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529)
2022-10-31T10:36:52.5862793Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278)
2022-10-31T10:36:52.5863574Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155)
2022-10-31T10:36:52.5864587Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045)
2022-10-31T10:36:52.5865127Z Oct 31 10:36:52 ... 24 more
2022-10-31T10:36:52.5866599Z Oct 31 10:36:52 Caused by:
org.codehaus.janino.InternalCompilerException: Compiling
"KeyProjection$173616": Trying to access closed classloader. Please check if
you store classloaders directly or indirectly in static fields. If the
stacktrace suggests that the leak occurs in a third party library and cannot be
fixed immediately, you can disable this check with the configuration
'classloader.check-leaked-classloader'.
2022-10-31T10:36:52.5867747Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382)
2022-10-31T10:36:52.5868442Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
2022-10-31T10:36:52.5869169Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
2022-10-31T10:36:52.5869792Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
2022-10-31T10:36:52.5870422Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
2022-10-31T10:36:52.5870977Z Oct 31 10:36:52 at
org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
2022-10-31T10:36:52.5871546Z Oct 31 10:36:52 at
org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
2022-10-31T10:36:52.5872163Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104)
2022-10-31T10:36:52.5872641Z Oct 31 10:36:52 ... 30 more
2022-10-31T10:36:52.5873934Z Oct 31 10:36:52 Caused by:
java.lang.IllegalStateException: Trying to access closed classloader. Please
check if you store classloaders directly or indirectly in static fields. If the
stacktrace suggests that the leak occurs in a third party library and cannot be
fixed immediately, you can disable this check with the configuration
'classloader.check-leaked-classloader'.
2022-10-31T10:36:52.5875109Z Oct 31 10:36:52 at
org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:184)
2022-10-31T10:36:52.5875948Z Oct 31 10:36:52 at
org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
2022-10-31T10:36:52.5876653Z Oct 31 10:36:52 at
java.lang.Class.forName0(Native Method)
2022-10-31T10:36:52.5877103Z Oct 31 10:36:52 at
java.lang.Class.forName(Class.java:348)
2022-10-31T10:36:52.5877678Z Oct 31 10:36:52 at
org.codehaus.janino.ClassLoaderIClassLoader.findIClass(ClassLoaderIClassLoader.java:89)
2022-10-31T10:36:52.5878302Z Oct 31 10:36:52 at
org.codehaus.janino.IClassLoader.loadIClass(IClassLoader.java:312)
2022-10-31T10:36:52.5879007Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.findTypeByName(UnitCompiler.java:8556)
2022-10-31T10:36:52.5879625Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6749)
2022-10-31T10:36:52.5880282Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6594)
2022-10-31T10:36:52.5880881Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6573)
2022-10-31T10:36:52.5881471Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.access$13900(UnitCompiler.java:215)
2022-10-31T10:36:52.5882097Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6481)
2022-10-31T10:36:52.5882731Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6476)
2022-10-31T10:36:52.5883330Z Oct 31 10:36:52 at
org.codehaus.janino.Java$ReferenceType.accept(Java.java:3928)
2022-10-31T10:36:52.5883907Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6476)
2022-10-31T10:36:52.5884494Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6469)
2022-10-31T10:36:52.5885078Z Oct 31 10:36:52 at
org.codehaus.janino.Java$ReferenceType.accept(Java.java:3927)
2022-10-31T10:36:52.5885645Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
2022-10-31T10:36:52.5886223Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.hasAnnotation(UnitCompiler.java:1365)
2022-10-31T10:36:52.5886846Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1349)
2022-10-31T10:36:52.5887487Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
2022-10-31T10:36:52.5888077Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
2022-10-31T10:36:52.5888650Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
2022-10-31T10:36:52.5889393Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
2022-10-31T10:36:52.5890079Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
2022-10-31T10:36:52.5890785Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
2022-10-31T10:36:52.5891462Z Oct 31 10:36:52 at
org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
2022-10-31T10:36:52.5892050Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
2022-10-31T10:36:52.5892642Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
2022-10-31T10:36:52.5893088Z Oct 31 10:36:52 ... 37 more
2022-10-31T10:36:52.5893363Z Oct 31 10:36:52
2022-10-31T10:36:52.5893778Z Oct 31 10:36:52 [ERROR]
LookupJoinITCase.testJoinTemporalTable Time elapsed: 0.149 s <<< ERROR!
2022-10-31T10:36:52.5894285Z Oct 31 10:36:52 java.lang.RuntimeException: Failed
to fetch next result
2022-10-31T10:36:52.5894935Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:109)
2022-10-31T10:36:52.5895747Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.hasNext(CollectResultIterator.java:80)
2022-10-31T10:36:52.5896561Z Oct 31 10:36:52 at
org.apache.flink.table.planner.connectors.CollectDynamicSink$CloseableRowIteratorWrapper.hasNext(CollectDynamicSink.java:222)
2022-10-31T10:36:52.5897343Z Oct 31 10:36:52 at
java.util.Iterator.forEachRemaining(Iterator.java:115)
2022-10-31T10:36:52.5897914Z Oct 31 10:36:52 at
org.apache.flink.util.CollectionUtil.iteratorToList(CollectionUtil.java:115)
2022-10-31T10:36:52.5898589Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.executeQuery(BatchTestBase.scala:308)
2022-10-31T10:36:52.5899401Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.check(BatchTestBase.scala:144)
2022-10-31T10:36:52.5900168Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.utils.BatchTestBase.checkResult(BatchTestBase.scala:108)
2022-10-31T10:36:52.5900938Z Oct 31 10:36:52 at
org.apache.flink.table.planner.runtime.batch.sql.join.LookupJoinITCase.testJoinTemporalTable(LookupJoinITCase.scala:219)
2022-10-31T10:36:52.5901602Z Oct 31 10:36:52 at
sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
2022-10-31T10:36:52.5902154Z Oct 31 10:36:52 at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
2022-10-31T10:36:52.5902809Z Oct 31 10:36:52 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-10-31T10:36:52.5903400Z Oct 31 10:36:52 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-10-31T10:36:52.5903972Z Oct 31 10:36:52 at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
2022-10-31T10:36:52.5904634Z Oct 31 10:36:52 at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
2022-10-31T10:36:52.5905295Z Oct 31 10:36:52 at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
2022-10-31T10:36:52.5905933Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
2022-10-31T10:36:52.5906584Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
2022-10-31T10:36:52.5907216Z Oct 31 10:36:52 at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
2022-10-31T10:36:52.5907831Z Oct 31 10:36:52 at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
2022-10-31T10:36:52.5908421Z Oct 31 10:36:52 at
org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
2022-10-31T10:36:52.5909086Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-10-31T10:36:52.5909700Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
2022-10-31T10:36:52.5910451Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
2022-10-31T10:36:52.5911065Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
2022-10-31T10:36:52.5911725Z Oct 31 10:36:52 at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
2022-10-31T10:36:52.5912316Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-10-31T10:36:52.5912881Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-10-31T10:36:52.5913461Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-10-31T10:36:52.5914021Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-10-31T10:36:52.5914598Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-10-31T10:36:52.5915162Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-10-31T10:36:52.5915672Z Oct 31 10:36:52 at
org.junit.runners.Suite.runChild(Suite.java:128)
2022-10-31T10:36:52.5916182Z Oct 31 10:36:52 at
org.junit.runners.Suite.runChild(Suite.java:27)
2022-10-31T10:36:52.5916704Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
2022-10-31T10:36:52.5917252Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
2022-10-31T10:36:52.5917826Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
2022-10-31T10:36:52.5918469Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
2022-10-31T10:36:52.5919118Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
2022-10-31T10:36:52.5919711Z Oct 31 10:36:52 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-10-31T10:36:52.5920369Z Oct 31 10:36:52 at
org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
2022-10-31T10:36:52.5920921Z Oct 31 10:36:52 at
org.junit.rules.RunRules.evaluate(RunRules.java:20)
2022-10-31T10:36:52.5921471Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
2022-10-31T10:36:52.5922027Z Oct 31 10:36:52 at
org.junit.runners.ParentRunner.run(ParentRunner.java:413)
2022-10-31T10:36:52.5922541Z Oct 31 10:36:52 at
org.junit.runner.JUnitCore.run(JUnitCore.java:137)
2022-10-31T10:36:52.5923057Z Oct 31 10:36:52 at
org.junit.runner.JUnitCore.run(JUnitCore.java:115)
2022-10-31T10:36:52.5923646Z Oct 31 10:36:52 at
org.junit.vintage.engine.execution.RunnerExecutor.execute(RunnerExecutor.java:42)
2022-10-31T10:36:52.5924299Z Oct 31 10:36:52 at
org.junit.vintage.engine.VintageTestEngine.executeAllChildren(VintageTestEngine.java:80)
2022-10-31T10:36:52.5924960Z Oct 31 10:36:52 at
org.junit.vintage.engine.VintageTestEngine.execute(VintageTestEngine.java:72)
2022-10-31T10:36:52.5925655Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:147)
2022-10-31T10:36:52.5926403Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:127)
2022-10-31T10:36:52.5927158Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:90)
2022-10-31T10:36:52.5927933Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.lambda$execute$0(EngineExecutionOrchestrator.java:55)
2022-10-31T10:36:52.5928737Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.withInterceptedStreams(EngineExecutionOrchestrator.java:102)
2022-10-31T10:36:52.5929619Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.EngineExecutionOrchestrator.execute(EngineExecutionOrchestrator.java:54)
2022-10-31T10:36:52.5930373Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:114)
2022-10-31T10:36:52.5931100Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncher.execute(DefaultLauncher.java:86)
2022-10-31T10:36:52.5931809Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.DefaultLauncherSession$DelegatingLauncher.execute(DefaultLauncherSession.java:86)
2022-10-31T10:36:52.5932576Z Oct 31 10:36:52 at
org.junit.platform.launcher.core.SessionPerRequestLauncher.execute(SessionPerRequestLauncher.java:53)
2022-10-31T10:36:52.5933339Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.lambda$execute$1(JUnitPlatformProvider.java:199)
2022-10-31T10:36:52.5933991Z Oct 31 10:36:52 at
java.util.Iterator.forEachRemaining(Iterator.java:116)
2022-10-31T10:36:52.5934631Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.execute(JUnitPlatformProvider.java:193)
2022-10-31T10:36:52.5935386Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invokeAllTests(JUnitPlatformProvider.java:154)
2022-10-31T10:36:52.5936116Z Oct 31 10:36:52 at
org.apache.maven.surefire.junitplatform.JUnitPlatformProvider.invoke(JUnitPlatformProvider.java:120)
2022-10-31T10:36:52.5936818Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.runSuitesInProcess(ForkedBooter.java:428)
2022-10-31T10:36:52.5937478Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.execute(ForkedBooter.java:162)
2022-10-31T10:36:52.5938086Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.run(ForkedBooter.java:562)
2022-10-31T10:36:52.5938703Z Oct 31 10:36:52 at
org.apache.maven.surefire.booter.ForkedBooter.main(ForkedBooter.java:548)
2022-10-31T10:36:52.5939435Z Oct 31 10:36:52 Caused by: java.io.IOException:
Failed to fetch job execution result
2022-10-31T10:36:52.5940153Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:184)
2022-10-31T10:36:52.5940940Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.next(CollectResultFetcher.java:121)
2022-10-31T10:36:52.5941750Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultIterator.nextResultFromFetcher(CollectResultIterator.java:106)
2022-10-31T10:36:52.5942334Z Oct 31 10:36:52 ... 67 more
2022-10-31T10:36:52.5942840Z Oct 31 10:36:52 Caused by:
java.util.concurrent.ExecutionException:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-10-31T10:36:52.5943518Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
2022-10-31T10:36:52.5944140Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
2022-10-31T10:36:52.5944848Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:182)
2022-10-31T10:36:52.5945415Z Oct 31 10:36:52 ... 69 more
2022-10-31T10:36:52.5945864Z Oct 31 10:36:52 Caused by:
org.apache.flink.runtime.client.JobExecutionException: Job execution failed.
2022-10-31T10:36:52.5946478Z Oct 31 10:36:52 at
org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
2022-10-31T10:36:52.5947233Z Oct 31 10:36:52 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:141)
2022-10-31T10:36:52.5947955Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
2022-10-31T10:36:52.5948577Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.uniApplyStage(CompletableFuture.java:628)
2022-10-31T10:36:52.5949307Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.thenApply(CompletableFuture.java:1996)
2022-10-31T10:36:52.5950057Z Oct 31 10:36:52 at
org.apache.flink.runtime.minicluster.MiniClusterJobClient.getJobExecutionResult(MiniClusterJobClient.java:138)
2022-10-31T10:36:52.5950866Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.collect.CollectResultFetcher.getAccumulatorResults(CollectResultFetcher.java:181)
2022-10-31T10:36:52.5951490Z Oct 31 10:36:52 ... 69 more
2022-10-31T10:36:52.5951967Z Oct 31 10:36:52 Caused by:
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
2022-10-31T10:36:52.5952717Z Oct 31 10:36:52 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:139)
2022-10-31T10:36:52.5953584Z Oct 31 10:36:52 at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:83)
2022-10-31T10:36:52.5954396Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.recordTaskFailure(DefaultScheduler.java:256)
2022-10-31T10:36:52.5955108Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:247)
2022-10-31T10:36:52.5955793Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.DefaultScheduler.onTaskFailed(DefaultScheduler.java:240)
2022-10-31T10:36:52.5956514Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerBase.onTaskExecutionStateUpdate(SchedulerBase.java:739)
2022-10-31T10:36:52.5957242Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:716)
2022-10-31T10:36:52.5957934Z Oct 31 10:36:52 at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:80)
2022-10-31T10:36:52.5958631Z Oct 31 10:36:52 at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:479)
2022-10-31T10:36:52.5959378Z Oct 31 10:36:52 at
sun.reflect.GeneratedMethodAccessor16.invoke(Unknown Source)
2022-10-31T10:36:52.5960033Z Oct 31 10:36:52 at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
2022-10-31T10:36:52.5960609Z Oct 31 10:36:52 at
java.lang.reflect.Method.invoke(Method.java:498)
2022-10-31T10:36:52.5961233Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:309)
2022-10-31T10:36:52.5961996Z Oct 31 10:36:52 at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
2022-10-31T10:36:52.5962722Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:307)
2022-10-31T10:36:52.5963405Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:222)
2022-10-31T10:36:52.5964104Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:84)
2022-10-31T10:36:52.5964785Z Oct 31 10:36:52 at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:168)
2022-10-31T10:36:52.5965392Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
2022-10-31T10:36:52.5965956Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
2022-10-31T10:36:52.5966507Z Oct 31 10:36:52 at
scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
2022-10-31T10:36:52.5967067Z Oct 31 10:36:52 at
scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
2022-10-31T10:36:52.5967643Z Oct 31 10:36:52 at
akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
2022-10-31T10:36:52.5968220Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
2022-10-31T10:36:52.5968810Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-10-31T10:36:52.5969483Z Oct 31 10:36:52 at
scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
2022-10-31T10:36:52.5970098Z Oct 31 10:36:52 at
akka.actor.Actor.aroundReceive(Actor.scala:537)
2022-10-31T10:36:52.5970603Z Oct 31 10:36:52 at
akka.actor.Actor.aroundReceive$(Actor.scala:535)
2022-10-31T10:36:52.5971141Z Oct 31 10:36:52 at
akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
2022-10-31T10:36:52.5971753Z Oct 31 10:36:52 at
akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
2022-10-31T10:36:52.5972286Z Oct 31 10:36:52 at
akka.actor.ActorCell.invoke(ActorCell.scala:548)
2022-10-31T10:36:52.5972806Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
2022-10-31T10:36:52.5973303Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.run(Mailbox.scala:231)
2022-10-31T10:36:52.5973789Z Oct 31 10:36:52 at
akka.dispatch.Mailbox.exec(Mailbox.scala:243)
2022-10-31T10:36:52.5974320Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-10-31T10:36:52.5974907Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-10-31T10:36:52.5975515Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-10-31T10:36:52.5976117Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-10-31T10:36:52.5977185Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: java.util.concurrent.CompletionException:
java.lang.RuntimeException: Failed to reload lookup 'FULL' cache.
2022-10-31T10:36:52.5978005Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.LookupFullCache.getIfPresent(LookupFullCache.java:85)
2022-10-31T10:36:52.5978816Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.CachingLookupFunction.lookup(CachingLookupFunction.java:123)
2022-10-31T10:36:52.5979625Z Oct 31 10:36:52 at
org.apache.flink.table.functions.LookupFunction.eval(LookupFunction.java:52)
2022-10-31T10:36:52.5980299Z Oct 31 10:36:52 at
LookupFunction$173667.flatMap(Unknown Source)
2022-10-31T10:36:52.5980902Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.doFetch(LookupJoinRunner.java:92)
2022-10-31T10:36:52.5981665Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:79)
2022-10-31T10:36:52.5982425Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.operators.join.lookup.LookupJoinRunner.processElement(LookupJoinRunner.java:34)
2022-10-31T10:36:52.5983174Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)
2022-10-31T10:36:52.5983887Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.pushToOperator(ChainingOutput.java:99)
2022-10-31T10:36:52.5984564Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:80)
2022-10-31T10:36:52.5985247Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.ChainingOutput.collect(ChainingOutput.java:39)
2022-10-31T10:36:52.5985922Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:56)
2022-10-31T10:36:52.5986585Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:29)
2022-10-31T10:36:52.5987366Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:418)
2022-10-31T10:36:52.5988216Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:513)
2022-10-31T10:36:52.5989111Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103)
2022-10-31T10:36:52.5989941Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.functions.source.FromElementsFunction.run(FromElementsFunction.java:231)
2022-10-31T10:36:52.5990647Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:110)
2022-10-31T10:36:52.5991298Z Oct 31 10:36:52 at
org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:67)
2022-10-31T10:36:52.5992002Z Oct 31 10:36:52 at
org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:333)
2022-10-31T10:36:52.5993055Z Oct 31 10:36:52 Caused by:
java.util.concurrent.CompletionException: java.lang.RuntimeException: Failed to
reload lookup 'FULL' cache.
2022-10-31T10:36:52.5993733Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
2022-10-31T10:36:52.5994378Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
2022-10-31T10:36:52.5995034Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1643)
2022-10-31T10:36:52.5995687Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.exec(CompletableFuture.java:1632)
2022-10-31T10:36:52.5996297Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
2022-10-31T10:36:52.5996884Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
2022-10-31T10:36:52.5997489Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
2022-10-31T10:36:52.5998102Z Oct 31 10:36:52 at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
2022-10-31T10:36:52.5998852Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Failed to reload lookup 'FULL' cache.
2022-10-31T10:36:52.5999594Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.CacheLoader.run(CacheLoader.java:121)
2022-10-31T10:36:52.6000332Z Oct 31 10:36:52 at
java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
2022-10-31T10:36:52.6000882Z Oct 31 10:36:52 ... 5 more
2022-10-31T10:36:52.6001319Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Failed to create InputFormatCacheLoadTask
2022-10-31T10:36:52.6002081Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.createCacheLoadTask(InputFormatCacheLoader.java:137)
2022-10-31T10:36:52.6003036Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.lambda$reloadCache$0(InputFormatCacheLoader.java:84)
2022-10-31T10:36:52.6003830Z Oct 31 10:36:52 at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
2022-10-31T10:36:52.6004461Z Oct 31 10:36:52 at
java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)
2022-10-31T10:36:52.6005063Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
2022-10-31T10:36:52.6005676Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
2022-10-31T10:36:52.6006299Z Oct 31 10:36:52 at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
2022-10-31T10:36:52.6006891Z Oct 31 10:36:52 at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
2022-10-31T10:36:52.6007488Z Oct 31 10:36:52 at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:566)
2022-10-31T10:36:52.6008244Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.reloadCache(InputFormatCacheLoader.java:85)
2022-10-31T10:36:52.6009168Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.CacheLoader.run(CacheLoader.java:105)
2022-10-31T10:36:52.6009680Z Oct 31 10:36:52 ... 6 more
2022-10-31T10:36:52.6010443Z Oct 31 10:36:52 Caused by:
java.lang.RuntimeException: Could not instantiate generated class
'KeyProjection$173661'
2022-10-31T10:36:52.6011113Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:74)
2022-10-31T10:36:52.6011840Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.keyselector.GenericRowDataKeySelector.open(GenericRowDataKeySelector.java:50)
2022-10-31T10:36:52.6012894Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputSplitCacheLoadTask.<init>(InputSplitCacheLoadTask.java:60)
2022-10-31T10:36:52.6013868Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.functions.table.lookup.fullcache.inputformat.InputFormatCacheLoader.createCacheLoadTask(InputFormatCacheLoader.java:135)
2022-10-31T10:36:52.6014599Z Oct 31 10:36:52 ... 16 more
2022-10-31T10:36:52.6015253Z Oct 31 10:36:52 Caused by:
org.apache.flink.util.FlinkRuntimeException:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.6016074Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:94)
2022-10-31T10:36:52.6016782Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
2022-10-31T10:36:52.6017490Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
2022-10-31T10:36:52.6018020Z Oct 31 10:36:52 ... 19 more
2022-10-31T10:36:52.6018749Z Oct 31 10:36:52 Caused by:
org.apache.flink.shaded.guava30.com.google.common.util.concurrent.UncheckedExecutionException:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.6019804Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2051)
2022-10-31T10:36:52.6020718Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962)
2022-10-31T10:36:52.6021576Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859)
2022-10-31T10:36:52.6022650Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
2022-10-31T10:36:52.6023350Z Oct 31 10:36:52 ... 21 more
2022-10-31T10:36:52.6023920Z Oct 31 10:36:52 Caused by:
org.apache.flink.api.common.InvalidProgramException: Table program cannot be
compiled. This is a bug. Please file an issue.
2022-10-31T10:36:52.6024653Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:107)
2022-10-31T10:36:52.6025358Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
2022-10-31T10:36:52.6026139Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864)
2022-10-31T10:36:52.6026984Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529)
2022-10-31T10:36:52.6027822Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278)
2022-10-31T10:36:52.6028608Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155)
2022-10-31T10:36:52.6029500Z Oct 31 10:36:52 at
org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045)
2022-10-31T10:36:52.6030147Z Oct 31 10:36:52 ... 24 more
2022-10-31T10:36:52.6031805Z Oct 31 10:36:52 Caused by:
org.codehaus.janino.InternalCompilerException: Compiling
"KeyProjection$173661": Trying to access closed classloader. Please check if
you store classloaders directly or indirectly in static fields. If the
stacktrace suggests that the leak occurs in a third party library and cannot be
fixed immediately, you can disable this check with the configuration
'classloader.check-leaked-classloader'.
2022-10-31T10:36:52.6032942Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382)
2022-10-31T10:36:52.6033536Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
2022-10-31T10:36:52.6034154Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
2022-10-31T10:36:52.6034754Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
2022-10-31T10:36:52.6035453Z Oct 31 10:36:52 at
org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
2022-10-31T10:36:52.6036031Z Oct 31 10:36:52 at
org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
2022-10-31T10:36:52.6036599Z Oct 31 10:36:52 at
org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
2022-10-31T10:36:52.6037202Z Oct 31 10:36:52 at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104)
2022-10-31T10:36:52.6037701Z Oct 31 10:36:52 ... 30 more
2022-10-31T10:36:52.6039060Z Oct 31 10:36:52 Caused by:
java.lang.IllegalStateException: Trying to access closed classloader. Please
check if you store classloaders directly or indirectly in static fields. If the
stacktrace suggests that the leak occurs in a third party library and cannot be
fixed immediately, you can disable this check with the configuration
'classloader.check-leaked-classloader'.
2022-10-31T10:36:52.6040273Z Oct 31 10:36:52 at
org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:184)
2022-10-31T10:36:52.6041119Z Oct 31 10:36:52 at
org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
2022-10-31T10:36:52.6041755Z Oct 31 10:36:52 at
java.lang.Class.forName0(Native Method)
2022-10-31T10:36:52.6042202Z Oct 31 10:36:52 at
java.lang.Class.forName(Class.java:348)
2022-10-31T10:36:52.6042760Z Oct 31 10:36:52 at
org.codehaus.janino.ClassLoaderIClassLoader.findIClass(ClassLoaderIClassLoader.java:89)
2022-10-31T10:36:52.6043496Z Oct 31 10:36:52 at
org.codehaus.janino.IClassLoader.loadIClass(IClassLoader.java:312)
2022-10-31T10:36:52.6044095Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.findTypeByName(UnitCompiler.java:8556)
2022-10-31T10:36:52.6044695Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6749)
2022-10-31T10:36:52.6045315Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6594)
2022-10-31T10:36:52.6045912Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6573)
2022-10-31T10:36:52.6046485Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.access$13900(UnitCompiler.java:215)
2022-10-31T10:36:52.6047113Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6481)
2022-10-31T10:36:52.6047762Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6476)
2022-10-31T10:36:52.6048349Z Oct 31 10:36:52 at
org.codehaus.janino.Java$ReferenceType.accept(Java.java:3928)
2022-10-31T10:36:52.6049024Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6476)
2022-10-31T10:36:52.6049633Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6469)
2022-10-31T10:36:52.6050298Z Oct 31 10:36:52 at
org.codehaus.janino.Java$ReferenceType.accept(Java.java:3927)
2022-10-31T10:36:52.6050871Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
2022-10-31T10:36:52.6051465Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.hasAnnotation(UnitCompiler.java:1365)
2022-10-31T10:36:52.6052068Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1349)
2022-10-31T10:36:52.6052706Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
2022-10-31T10:36:52.6053313Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
2022-10-31T10:36:52.6053892Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
2022-10-31T10:36:52.6054463Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
2022-10-31T10:36:52.6055106Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
2022-10-31T10:36:52.6055811Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
2022-10-31T10:36:52.6056530Z Oct 31 10:36:52 at
org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
2022-10-31T10:36:52.6057130Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
2022-10-31T10:36:52.6057712Z Oct 31 10:36:52 at
org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
2022-10-31T10:36:52.6058146Z Oct 31 10:36:52 ... 37 more
{code}
> LookupJoinITCase failed with classloader problem
> ------------------------------------------------
>
> Key: FLINK-29427
> URL: https://issues.apache.org/jira/browse/FLINK-29427
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 1.16.0
> Reporter: Huang Xingbo
> Assignee: Alexander Smirnov
> Priority: Critical
> Labels: test-stability
>
> {code:java}
> 2022-09-27T02:49:20.9501313Z Sep 27 02:49:20 Caused by:
> org.codehaus.janino.InternalCompilerException: Compiling
> "KeyProjection$108341": Trying to access closed classloader. Please check if
> you store classloaders directly or indirectly in static fields. If the
> stacktrace suggests that the leak occurs in a third party library and cannot
> be fixed immediately, you can disable this check with the configuration
> 'classloader.check-leaked-classloader'.
> 2022-09-27T02:49:20.9502654Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382)
> 2022-09-27T02:49:20.9503366Z Sep 27 02:49:20 at
> org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
> 2022-09-27T02:49:20.9504044Z Sep 27 02:49:20 at
> org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
> 2022-09-27T02:49:20.9504704Z Sep 27 02:49:20 at
> org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
> 2022-09-27T02:49:20.9505341Z Sep 27 02:49:20 at
> org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
> 2022-09-27T02:49:20.9505965Z Sep 27 02:49:20 at
> org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
> 2022-09-27T02:49:20.9506584Z Sep 27 02:49:20 at
> org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
> 2022-09-27T02:49:20.9507261Z Sep 27 02:49:20 at
> org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104)
> 2022-09-27T02:49:20.9507883Z Sep 27 02:49:20 ... 30 more
> 2022-09-27T02:49:20.9509266Z Sep 27 02:49:20 Caused by:
> java.lang.IllegalStateException: Trying to access closed classloader. Please
> check if you store classloaders directly or indirectly in static fields. If
> the stacktrace suggests that the leak occurs in a third party library and
> cannot be fixed immediately, you can disable this check with the
> configuration 'classloader.check-leaked-classloader'.
> 2022-09-27T02:49:20.9510835Z Sep 27 02:49:20 at
> org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.ensureInner(FlinkUserCodeClassLoaders.java:184)
> 2022-09-27T02:49:20.9511760Z Sep 27 02:49:20 at
> org.apache.flink.util.FlinkUserCodeClassLoaders$SafetyNetWrapperClassLoader.loadClass(FlinkUserCodeClassLoaders.java:192)
> 2022-09-27T02:49:20.9512456Z Sep 27 02:49:20 at
> java.lang.Class.forName0(Native Method)
> 2022-09-27T02:49:20.9513014Z Sep 27 02:49:20 at
> java.lang.Class.forName(Class.java:348)
> 2022-09-27T02:49:20.9513649Z Sep 27 02:49:20 at
> org.codehaus.janino.ClassLoaderIClassLoader.findIClass(ClassLoaderIClassLoader.java:89)
> 2022-09-27T02:49:20.9514339Z Sep 27 02:49:20 at
> org.codehaus.janino.IClassLoader.loadIClass(IClassLoader.java:312)
> 2022-09-27T02:49:20.9514990Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.findTypeByName(UnitCompiler.java:8556)
> 2022-09-27T02:49:20.9515659Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6749)
> 2022-09-27T02:49:20.9516337Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6594)
> 2022-09-27T02:49:20.9516989Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6573)
> 2022-09-27T02:49:20.9517632Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.access$13900(UnitCompiler.java:215)
> 2022-09-27T02:49:20.9518319Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6481)
> 2022-09-27T02:49:20.9519018Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$22$1.visitReferenceType(UnitCompiler.java:6476)
> 2022-09-27T02:49:20.9519680Z Sep 27 02:49:20 at
> org.codehaus.janino.Java$ReferenceType.accept(Java.java:3928)
> 2022-09-27T02:49:20.9520386Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6476)
> 2022-09-27T02:49:20.9521042Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$22.visitType(UnitCompiler.java:6469)
> 2022-09-27T02:49:20.9521677Z Sep 27 02:49:20 at
> org.codehaus.janino.Java$ReferenceType.accept(Java.java:3927)
> 2022-09-27T02:49:20.9522299Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6469)
> 2022-09-27T02:49:20.9522929Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.hasAnnotation(UnitCompiler.java:1365)
> 2022-09-27T02:49:20.9523658Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1349)
> 2022-09-27T02:49:20.9524365Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
> 2022-09-27T02:49:20.9525030Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
> 2022-09-27T02:49:20.9525750Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
> 2022-09-27T02:49:20.9526383Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
> 2022-09-27T02:49:20.9527069Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
> 2022-09-27T02:49:20.9527832Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
> 2022-09-27T02:49:20.9528560Z Sep 27 02:49:20 at
> org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
> 2022-09-27T02:49:20.9529217Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
> 2022-09-27T02:49:20.9529862Z Sep 27 02:49:20 at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
> 2022-09-27T02:49:20.9530427Z Sep 27 02:49:20 ... 37 more
> 2022-09-27T02:49:20.9530852Z Sep 27 02:49:20
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=41369&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a&t=075c2716-8010-5565-fe08-3c4bb45824a4
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
