Hi!

In Flink 1.14 we've introduced the new code splitting mechanism which will
solve this issue. Please consider upgrading to Flink 1.14.

Schmid Christian <christian.sch...@cler.ch> 于2021年11月16日周二 上午12:43写道:

> Hi all
>
>
>
> I ran into an exception while trying to execute a large sql query, which
> basically runs "over aggregations" over many columns (batchjob /
> jdbc-connector):
>
>
>
> "Code of method
> "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V"
> of class "BatchExecCalc$7746" grows beyond 64 KB"
>
>
>
> Further it is written:
>
>
>
> "org.apache.flink.api.common.InvalidProgramException: Table program cannot
> be compiled. This is a bug. Please file an issue."
>
>
>
> Flink-Version 1.13.2
>
>
>
> Is there a workaround to solve this issue?
>
>
>
> Any suggestion is highly appreciated.
>
>
>
> Regards
>
>
>
> Christian
>
>
>
>
>
> Traceback:
>
>
>
> Traceback (most recent call last):
>
>   File "sci_produkt_featurestores.py", line 1436, in <module>
>
>     main()
>
>   File "sci_produkt_featurestores.py", line 1425, in main
>
>     stmt_set.execute().wait()
>
>   File
> "C:\flink1_13_3\opt\python\pyflink.zip\pyflink\table\table_result.py", line
> 76, in wait
>
>   File
> "C:\flink1_13_3\opt\python\py4j-0.10.8.1-src.zip\py4j\java_gateway.py",
> line 1286, in __call__
>
>   File "C:\flink1_13_3\opt\python\pyflink.zip\pyflink\util\exceptions.py",
> line 146, in deco
>
>   File "C:\flink1_13_3\opt\python\py4j-0.10.8.1-src.zip\py4j\protocol.py",
> line 328, in get_return_value
>
> py4j.protocol.Py4JJavaError: An error occurred while calling o364.await.
>
> : java.util.concurrent.ExecutionException:
> org.apache.flink.table.api.TableException: Failed to wait job finish
>
>
>
>         at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
>
>
>
>         at
> org.apache.flink.table.api.internal.TableResultImpl.awaitInternal(TableResultImpl.java:129)
>
>
>
>         at
> org.apache.flink.table.api.internal.TableResultImpl.await(TableResultImpl.java:92)
>
>
>
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>
>
>
>         at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>
>
>
>         at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>
>
>
>         at java.lang.reflect.Method.invoke(Method.java:498)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
>
>
>
>         at
> org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
>
>
>
>         at java.lang.Thread.run(Thread.java:748)
>
>
>
> Caused by: org.apache.flink.table.api.TableException: Failed to wait job
> finish
>
>
>
>         at
> org.apache.flink.table.api.internal.InsertResultIterator.hasNext(InsertResultIterator.java:56)
>
>
>
>         at
> org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.hasNext(TableResultImpl.java:370)
>
>
>
>         at
> org.apache.flink.table.api.internal.TableResultImpl$CloseableRowIteratorWrapper.isFirstRowReady(TableResultImpl.java:383)
>
>
>
>         at
> org.apache.flink.table.api.internal.TableResultImpl.lambda$awaitInternal$1(TableResultImpl.java:116)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$AsyncRun.run(CompletableFuture.java:1640)
>
>
>
>         at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
>
>
>
>         at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
>
>
>
>         ... 1 more
>
>
>
> Caused by: java.util.concurrent.ExecutionException:
> org.apache.flink.client.program.ProgramInvocationException: Job failed
> (JobID: 60627f4d8763c3989dc53128247dcfbe)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
>
>
>
>         at
> org.apache.flink.table.api.internal.InsertResultIterator.hasNext(InsertResultIterator.java:54)
>
>
>
>         ... 7 more
>
>
>
> Caused by: org.apache.flink.client.program.ProgramInvocationException: Job
> failed (JobID: 60627f4d8763c3989dc53128247dcfbe)
>
>
>
>         at
> org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:125)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:616)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:591)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
>
>
>
>         at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:394)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
>
>
>
>         at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$pollResourceAsync$24(RestClusterClient.java:670)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1975)
>
>
>
>         at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$9(FutureUtils.java:394)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
>
>
>
>         at
> java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:575)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:943)
>
>
>
>         at
> java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456)
>
>
>
>         ... 3 more
>
>
>
> Caused by: org.apache.flink.runtime.client.JobExecutionException: Job
> execution failed.
>
>
>
>         at
> org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144)
>
>
>
>         at
> org.apache.flink.client.deployment.ClusterClientJobClientAdapter.lambda$null$6(ClusterClientJobClientAdapter.java:123)
>
>
>
>        ... 24 more
>
>
>
> Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed
> by NoRestartBackoffTimeStrategy
>
>
>
>         at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
>
>
>
>         at
> org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
>
>
>
>         at
> org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:216)
>
>
>
>         at
> org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:206)
>
>
>
>         at
> org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:197)
>
>
>
>         at
> org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:682)
>
>
>
>         at
> org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
>
>
>
>         at
> org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435)
>
>
>
>         at sun.reflect.GeneratedMethodAccessor162.invoke(Unknown Source)
>
>
>
>         at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>
>
>
>         at java.lang.reflect.Method.invoke(Method.java:498)
>
>
>
>         at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
>
>
>
>         at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
>
>
>
>         at
> org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
>
>
>
>         at
> org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
>
>
>
>         at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26)
>
>
>
>         at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21)
>
>
>
>         at
> scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123)
>
>
>
>         at
> akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21)
>
>
>
>         at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170)
>
>
>
>         at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
>
>
>
>         at
> scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
>
>
>
>         at akka.actor.Actor$class.aroundReceive(Actor.scala:517)
>
>
>
>         at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225)
>
>
>
>         at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592)
>
>
>
>         at akka.actor.ActorCell.invoke(ActorCell.scala:561)
>
>
>
>         at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258)
>
>
>
>         at akka.dispatch.Mailbox.run(Mailbox.scala:225)
>
>
>
>         at akka.dispatch.Mailbox.exec(Mailbox.scala:235)
>
>
>
>         at
> akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
>
>
>
>         at
> akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
>
>
>
>         at
> akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
>
>
>
>         at
> akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)
>
>
>
> Caused by: java.lang.RuntimeException: Could not instantiate generated
> class 'BatchExecCalc$7746'
>
>
>
>         at
> org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:66)
>
>
>
>         at
> org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40)
>
>
>
>         at
> org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:80)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperator(OperatorChain.java:655)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:629)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:569)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:619)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:569)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:619)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:569)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOperatorChain(OperatorChain.java:619)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:569)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:186)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.StreamTask.executeRestore(StreamTask.java:551)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
>
>
>
>         at
> org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:540)
>
>
>
>         at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
>
>
>
>         at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
>
>
>
>         at java.lang.Thread.run(Thread.java:748)
>
>
>
> 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.
>
>
>
>         at
> org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:76)
>
>
>
>         at
> org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:77)
>
>
>
>         at
> org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:64)
>
>
>
>         ... 18 more
>
>
>
> Caused by:
> org.apache.flink.shaded.guava18.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.
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2203)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
>
>
>
>         at
> org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74)
>
>
>
>         ... 20 more
>
>
>
> Caused by: 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.doCompile(CompileUtils.java:89)
>
>
>
>         at
> org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
>
>
>
>         at
> org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
>
>
>
>         ... 23 more
>
>
>
> Caused by: org.codehaus.janino.InternalCompilerException: Compiling
> "BatchExecCalc$7746": Code of method
> "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V"
> of class "BatchExecCalc$7746" grows beyond 64 KB
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382)
>
>
>
>         at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237)
>
>
>
>         at
> org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465)
>
>
>
>         at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
>
>
>
>         at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
>
>
>
>         at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
>
>
>
>         at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
>
>
>
>         at
> org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86)
>
>
>
>         ... 29 more
>
>
>
> Caused by: org.codehaus.janino.InternalCompilerException: Code of method
> "processElement(Lorg/apache/flink/streaming/runtime/streamrecord/StreamRecord;)V"
> of class "BatchExecCalc$7746" grows beyond 64 KB
>
>
>
>         at org.codehaus.janino.CodeContext.makeSpace(CodeContext.java:1048)
>
>
>
>         at org.codehaus.janino.CodeContext.write(CodeContext.java:925)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.writeOpcode(UnitCompiler.java:12291)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4449)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5004)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$8500(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$16.visitBinaryOperation(UnitCompiler.java:4417)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$16.visitBinaryOperation(UnitCompiler.java:4396)
>
>
>
>         at org.codehaus.janino.Java$BinaryOperation.accept(Java.java:4864)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3792)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3754)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$13.visitAssignment(UnitCompiler.java:3734)
>
>
>
>         at org.codehaus.janino.Java$Assignment.accept(Java.java:4477)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3734)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487)
>
>
>
>         at
> org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2874)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1553)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1493)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1487)
>
>
>
>         at org.codehaus.janino.Java$Block.accept(Java.java:2779)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2486)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487)
>
>
>
>         at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406)
>
>
>
>         at
> org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414)
>
>
>
>         at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406)
>
>
>
>         at
> org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378)
>
>
>
>         ... 36 more
>
>
>
>
>
> org.apache.flink.client.program.ProgramAbortException:
> java.lang.RuntimeException: Python process exits with code: 1
>
>         at
> org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:140)
>
>         at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>
>         at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
>
>         at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>
>         at java.lang.reflect.Method.invoke(Method.java:498)
>
>         at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:355)
>
>         at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:222)
>
>         at
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114)
>
>         at
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:812)
>
>         at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:246)
>
>         at
> org.apache.flink.client.cli.CliFrontend.parseAndRun(CliFrontend.java:1054)
>
>         at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:1132)
>
>         at
> org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28)
>
>         at
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:1132)
>
> Caused by: java.lang.RuntimeException: Python process exits with code: 1
>
>         at
> org.apache.flink.client.python.PythonDriver.main(PythonDriver.java:130)
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> *Diese E-Mail ist ausschliesslich für den Adressaten bestimmt. Sollten Sie
> diese E-Mail irrtümlich erhalten haben oder wünschen Sie künftig keine
> Kontakte mehr per E-Mail, bitten wir Sie, die Bank Cler hierüber sofort zu
> orientieren. Die irrtümlich erhaltene E-Mail ist mit allen Anhängen
> unwiderruflich zu löschen, allfällige Ausdrucke sind zu vernichten und auf
> die Verwendung des Inhalts ist zu verzichten. Der Versand unverschlüsselter
> E-Mail birgt erhebliche Risiken in sich (mangelnde Vertraulichkeit,
> Manipulation von Inhalt/Absender, Fehlleitung, Viren etc.). Bank Cler lehnt
> jede Haftung für Schäden hieraus ab. Bank Cler akzeptiert grundsätzlich
> keine per E-Mail übermittelten Aufträge, Widerrufe von Aufträgen oder
> sonstige Weisungen etc., ohne verpflichtet zu sein, diese ausdrücklich
> zurück zu weisen. Kündigungen von Verträgen per E-Mail sind nicht
> rechtswirksam. *
>

Reply via email to