You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "shengkui leng (Jira)" <ji...@apache.org> on 2021/09/30 07:24:00 UTC
[jira] [Created] (FLINK-24408)
org.codehaus.janino.InternalCompilerException: Compiling
"StreamExecValues$200": Code of method
"nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class
"StreamExecValues$200" grows beyond 64 KB
shengkui leng created FLINK-24408:
-------------------------------------
Summary: org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB
Key: FLINK-24408
URL: https://issues.apache.org/jira/browse/FLINK-24408
Project: Flink
Issue Type: Bug
Components: Table SQL / Runtime
Affects Versions: 1.14.0
Environment: * Flink v1.14.0
* Hudi trunk(v0.10.0 snapshot)
* Hadoop v2.9.2
Reporter: shengkui leng
I build a large SQL in application, and meet the issue "Code of method method grows beyond 64 KB". This bug should be fixed in refer to [#FLINK-22903].
{code:java}
//代码占位符
{code}
java.lang.RuntimeException: Could not instantiate generated class 'StreamExecValues$200' at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:75) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.operators.values.ValuesInputFormat.open(ValuesInputFormat.java:60) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.operators.values.ValuesInputFormat.open(ValuesInputFormat.java:35) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.streaming.api.functions.source.InputFormatSourceFunction.run(InputFormatSourceFunction.java:84) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:116) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:73) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:323) ~[flink-dist_2.11-1.14.0.jar:1.14.0]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) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:102) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:69) ~[flink-table_2.11-1.14.0.jar:1.14.0] ... 6 moreCaused 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. at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2051) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:102) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:69) ~[flink-table_2.11-1.14.0.jar:1.14.0] ... 6 moreCaused 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) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:102) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:69) ~[flink-table_2.11-1.14.0.jar:1.14.0] ... 6 moreCaused by: org.codehaus.janino.InternalCompilerException: Compiling "StreamExecValues$200": Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:382) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:102) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:69) ~[flink-table_2.11-1.14.0.jar:1.14.0] ... 6 moreCaused by: org.codehaus.janino.InternalCompilerException: Code of method "nextRecord(Ljava/lang/Object;)Ljava/lang/Object;" of class "StreamExecValues$200" grows beyond 64 KB at org.codehaus.janino.CodeContext.makeSpace(CodeContext.java:1048) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.CodeContext.write(CodeContext.java:925) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.writeOpcode(UnitCompiler.java:12291) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.referenceThis(UnitCompiler.java:10103) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:4488) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$10000(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$16.visitQualifiedThisReference(UnitCompiler.java:4437) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$16.visitQualifiedThisReference(UnitCompiler.java:4396) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$QualifiedThisReference.accept(Java.java:4407) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileContext2(UnitCompiler.java:4336) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$6900(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$15$1.visitFieldAccess(UnitCompiler.java:4273) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$15$1.visitFieldAccess(UnitCompiler.java:4268) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$FieldAccess.accept(Java.java:4310) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4268) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$15.visitLvalue(UnitCompiler.java:4264) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$Lvalue.accept(Java.java:4148) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileContext(UnitCompiler.java:4264) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5661) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5145) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4423) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4396) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4396) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5662) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3783) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$5900(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:3762) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:3734) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5073) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3734) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2360) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1494) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:2874) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:1553) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$1700(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1493) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitBlock(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$Block.accept(Java.java:2779) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.fakeCompile(UnitCompiler.java:1529) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2434) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$1900(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1495) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitIfStatement(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$IfStatement.accept(Java.java:2950) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2181) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$2400(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitSwitchStatement(UnitCompiler.java:1500) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$6.visitSwitchStatement(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$SwitchStatement.accept(Java.java:3391) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1487) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1567) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3388) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1357) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1330) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:822) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:432) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:215) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:411) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler$2.visitPackageMemberClassDeclaration(UnitCompiler.java:406) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1414) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:406) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:378) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:237) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:465) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:86) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4864) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3529) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2278) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2155) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2045) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache.get(LocalCache.java:3962) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.shaded.guava30.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4859) ~[flink-dist_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:74) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:102) ~[flink-table_2.11-1.14.0.jar:1.14.0] at org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:69) ~[flink-table_2.11-1.14.0.jar:1.14.0] ... 6 more
--
This message was sent by Atlassian Jira
(v8.3.4#803005)