[ https://issues.apache.org/jira/browse/FLINK-24408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17435141#comment-17435141 ]
Caizhi Weng commented on FLINK-24408: ------------------------------------- Hi! Thanks for raising this issue. This is because Java code splitter currently does not deal with {{switch}} statements which is used by {{VALUES}}. I'll fix this in a couple of days. > 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 > Priority: Major > Attachments: HudiBenchS3.java, sql.txt > > > I build a large SQL in application, and meet the issue "Code of method method > grows beyond 64 KB". This bug should be fixed refer to #FLINK-22903. > > {quote}{{ 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}} > {quote} > -- This message was sent by Atlassian Jira (v8.3.4#803005)