mumu created FLINK-36380:
----------------------------
Summary: Cannot determine simple type name "org"
Key: FLINK-36380
URL: https://issues.apache.org/jira/browse/FLINK-36380
Project: Flink
Issue Type: Bug
Reporter: mumu
Flink SQL task upgraded from 1.13.1 to 1.18.1，with the following error message ：
kafka to kafka
{code:java}
java.lang.RuntimeException: Could not instantiate generated class
'WatermarkGenerator$5'
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:74)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedWatermarkGeneratorSupplier.createWatermarkGenerator(GeneratedWatermarkGeneratorSupplier.java:69)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.api.operators.source.ProgressiveTimestampsAndWatermarks.createMainOutput(ProgressiveTimestampsAndWatermarks.java:109)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.api.operators.SourceOperator.initializeMainOutput(SourceOperator.java:462)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.api.operators.SourceOperator.emitNextNotReading(SourceOperator.java:438)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:414)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:562)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:858)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:807)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:579)
~[flink-dist_2.12-1.18.1.jar:1.18.1]
at java.lang.Thread.run(Thread.java:745) ~[?:1.8.0_66]
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:94)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
~[flink-table-runtime-1.18.1.jar:1.18.1]
... 16 more
Caused by:
org.apache.flink.shaded.guava31.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.guava31.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2055)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache.get(LocalCache.java:3966)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4863)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
~[flink-table-runtime-1.18.1.jar:1.18.1]
... 16 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:107)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4868)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3533)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2282)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2159)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2049)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache.get(LocalCache.java:3966)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4863)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
~[flink-table-runtime-1.18.1.jar:1.18.1]
... 16 more
Caused by: org.codehaus.commons.compiler.CompileException: Line 25, Column 121:
Line 25, Column 121: Cannot determine simple type name "org"
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:7007)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6886)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6857)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$14800(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6755)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6752)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$ReferenceType.accept(Java.java:4289)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6752)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7532)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$17300(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$25.visitNewClassInstance(UnitCompiler.java:6799)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$25.visitNewClassInstance(UnitCompiler.java:6773)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$NewClassInstance.accept(Java.java:5587)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6773)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9621)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9506)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9422)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5263)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$9300(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4766)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4742)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5470)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4742)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5885)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:4121)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:4096)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:4071)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5470)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:4071)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2524)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1581)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1576)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:3209)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1576)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1662)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3665)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3330)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1448)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1421)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:830)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:443)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:423)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:419)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1688)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:419)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:393)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:364)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:362)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:371)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:362)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:273)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:526)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook2(SimpleCompiler.java:250)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:229)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:219)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:77)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4868)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3533)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2282)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2159)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2049)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache.get(LocalCache.java:3966)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4863)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:68)
~[flink-table-runtime-1.18.1.jar:1.18.1]
... 16 more
Caused by: org.codehaus.commons.compiler.CompileException: Line 25, Column 121:
Cannot determine simple type name "org"
at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:13080)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getRawReferenceType(UnitCompiler.java:7175)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:7005)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6886)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6899)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6857)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$14800(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6755)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$24.visitReferenceType(UnitCompiler.java:6752)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$ReferenceType.accept(Java.java:4289)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6752)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7532)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$17300(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$25.visitNewClassInstance(UnitCompiler.java:6799)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$25.visitNewClassInstance(UnitCompiler.java:6773)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$NewClassInstance.accept(Java.java:5587)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6773)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9621)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9506)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9422)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5263)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$9300(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4766)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4742)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5470)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4742)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5885)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:4121)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$6100(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:4096)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$13.visitMethodInvocation(UnitCompiler.java:4071)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5470)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:4071)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2524)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$1800(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1581)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$6.visitExpressionStatement(UnitCompiler.java:1576)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$ExpressionStatement.accept(Java.java:3209)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:1576)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileStatements(UnitCompiler.java:1662)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:3665)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:3330)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1448)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler.compileDeclaredMethods(UnitCompiler.java:1421)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:830)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:443)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$400(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:423)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$3.visitPackageMemberClassDeclaration(UnitCompiler.java:419)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.Java$PackageMemberClassDeclaration.accept(Java.java:1688)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile(UnitCompiler.java:419)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:393)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.access$000(UnitCompiler.java:237)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:364)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.UnitCompiler$2.visitCompilationUnit(UnitCompiler.java:362)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.Java$CompilationUnit.accept(Java.java:371)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.UnitCompiler.compileUnit(UnitCompiler.java:362)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:273)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.codehaus.janino.SimpleCompiler.compileToClassLoader(SimpleCompiler.java:526)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook2(SimpleCompiler.java:250)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:229)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:219)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:82)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:77)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:104)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$0(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4868)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3533)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2282)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2159)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2049)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache.get(LocalCache.java:3966)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.shaded.guava31.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4863)
~[flink-cdc-pipeline-connector-mysql-3.0.1.jar:3.0.1]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:92)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:101)
~[flink-table-runtime-1.18.1.jar:1.18.1]
at org.apache.flink.table.runtime.generated.GeneratedCla{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
