吉春
06/12/2023, 9:27 AMorg.apache.flink.util.FlinkRuntimeException: org.apache.flink.api.common.InvalidProgramException: Table program cannot be compiled. This is a bug. Please file an issue.
at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:94) ~[flink-table-runtime-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:97) ~[flink-table-runtime-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.runtime.generated.GeneratedClass.getClass(GeneratedClass.java:120) ~[flink-table-runtime-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.getStreamOperatorClass(CodeGenOperatorFactory.java:51) ~[flink-table-runtime-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.preValidate(StreamingJobGraphGenerator.java:528) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:236) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:160) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.streaming.api.graph.StreamGraph.getJobGraph(StreamGraph.java:1028) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.StreamGraphTranslator.translateToJobGraph(StreamGraphTranslator.java:56) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.FlinkPipelineTranslationUtil.getJobGraph(FlinkPipelineTranslationUtil.java:43) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.deployment.executors.PipelineExecutorUtils.getJobGraph(PipelineExecutorUtils.java:61) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:123) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:2197) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:189) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.planner.delegation.DefaultExecutor.executeAsync(DefaultExecutor.java:121) ~[?:?]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:921) ~[flink-table-api-java-uber-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:883) ~[flink-table-api-java-uber-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.table.api.internal.StatementSetImpl.execute(StatementSetImpl.java:109) ~[flink-table-api-java-uber-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at com.dlink.executor.Executor.executeStatementSet(Executor.java:351) ~[dlink-app-1.17-0.7.0-jar-with-dependencies.jar:?]
at com.dlink.executor.Executor.submitStatementSet(Executor.java:367) ~[dlink-app-1.17-0.7.0-jar-with-dependencies.jar:?]
at com.dlink.app.flinksql.Submitter.submit(Submitter.java:143) ~[dlink-app-1.17-0.7.0-jar-with-dependencies.jar:?]
at com.dlink.app.MainApp.main(MainApp.java:34) ~[dlink-app-1.17-0.7.0-jar-with-dependencies.jar:?]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_121]
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_121]
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_121]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_121]
at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:105) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:303) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$2(ApplicationDispatcherBootstrap.java:256) ~[flink-dist-1.17.0-xxx-RELEASE.jar:1.17.0-xxx-RELEASE]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) ~[?:1.8.0_121]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) ~[?:1.8.0_121]
at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:171) ~[flink-rpc-akka_33a72385-51d3-4f53-84cc-668970eb251f.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68) ~[flink-rpc-akka_33a72385-51d3-4f53-84cc-668970eb251f.jar:1.17.0-xxx-RELEASE]
at org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.lambda$withContextClassLoader$0(ClassLoadingUtils.java:41) ~[flink-rpc-akka_33a72385-51d3-4f53-84cc-668970eb251f.jar:1.17.0-xxx-RELEASE]
at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:49) [flink-rpc-akka_33a72385-51d3-4f53-84cc-668970eb251f.jar:1.17.0-xxx-RELEASE]
at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:48) [flink-rpc-akka_33a72385-51d3-4f53-84cc-668970eb251f.jar:1.17.0-xxx-RELEASE]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289) [?:1.8.0_121]
at java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056) [?:1.8.0_121]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692) [?:1.8.0_121]
at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:157) [?:1.8.0_121]