Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-17561

Table program cannot be compiled

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Duplicate
    • Affects Version/s: 1.10.0
    • Fix Version/s: None
    • Component/s: Table SQL / Runtime
    • Labels:
      None

      Description

      Exception info is:

       

      /* 1 */
      /* 2 */ public class SourceConversion$136 extends org.apache.flink.table.runtime.operators.AbstractProcessStreamOperator
      /* 3 */ implements org.apache.flink.streaming.api.operators.OneInputStreamOperator {
      /* 4 */
      /* 5 */ private final Object[] references;
      /* 6 */ private transient org.apache.flink.table.dataformat.DataFormatConverters.PojoConverter converter$135;
      /* 7 */ private final org.apache.flink.streaming.runtime.streamrecord.StreamRecord outElement = new org.apache.flink.streaming.runtime.streamrecord.StreamRecord(null);
      /* 8 */
      /* 9 */ public SourceConversion$136(
      /* 10 */ Object[] references,
      /* 11 */ org.apache.flink.streaming.runtime.tasks.StreamTask task,
      /* 12 */ org.apache.flink.streaming.api.graph.StreamConfig config,
      /* 13 */ org.apache.flink.streaming.api.operators.Output output) throws Exception

      { /* 14 */ this.references = references; /* 15 */ converter$135 = (((org.apache.flink.table.dataformat.DataFormatConverters.PojoConverter) references[0])); /* 16 */ this.setup(task, config, output); /* 17 */ }

      /* 18 */
      /* 19 */ @Override
      /* 20 */ public void open() throws Exception

      { /* 21 */ super.open(); /* 22 */ /* 23 */ }

      /* 24 */
      /* 25 */ @Override
      /* 26 */ public void processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord element) throws Exception

      { /* 27 */ org.apache.flink.table.dataformat.BaseRow in1 = (org.apache.flink.table.dataformat.BaseRow) (org.apache.flink.table.dataformat.BaseRow) converter$135.toInternal((com.xxx.flink.bean.RegisterBean) element.getValue()); /* 28 */ /* 29 */ /* 30 */ /* 31 */ output.collect(outElement.replace(in1)); /* 32 */ }

      /* 33 */
      /* 34 */
      /* 35 */
      /* 36 */ @Override
      /* 37 */ public void close() throws Exception

      { /* 38 */ super.close(); /* 39 */ /* 40 */ }

      /* 41 */
      /* 42 */
      /* 43 */ }
      /* 44 */

      2020-05-08 10:35:24,144 ERROR org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler - Unhandled exception.
      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:68)
      at org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
      at org.apache.flink.table.runtime.generated.GeneratedClass.getClass(GeneratedClass.java:96)
      at org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.getStreamOperatorClass(CodeGenOperatorFactory.java:62)
      at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.preValidate(StreamingJobGraphGenerator.java:214)
      at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:149)
      at org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator.createJobGraph(StreamingJobGraphGenerator.java:104)
      at org.apache.flink.streaming.api.graph.StreamGraph.getJobGraph(StreamGraph.java:777)
      at org.apache.flink.streaming.api.graph.StreamGraphTranslator.translateToJobGraph(StreamGraphTranslator.java:52)
      at org.apache.flink.client.FlinkPipelineTranslationUtil.getJobGraph(FlinkPipelineTranslationUtil.java:43)
      at org.apache.flink.client.program.PackagedProgramUtils.createJobGraph(PackagedProgramUtils.java:57)
      at org.apache.flink.runtime.webmonitor.handlers.utils.JarHandlerUtils$JarHandlerContext.toJobGraph(JarHandlerUtils.java:128)
      at org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler.lambda$handleRequest$1(JarPlanHandler.java:100)
      at java.util.concurrent.CompletableFuture$AsyncSupply.run(CompletableFuture.java:1590)
      at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
      at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
      at java.lang.Thread.run(Thread.java:748)
      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:66)
      ... 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:81)
      at org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
      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)
      ... 19 more
      Caused by: org.codehaus.commons.compiler.CompileException: Line 27, Column 176: Cannot determine simple type name "com"
      at org.codehaus.janino.UnitCompiler.compileError(UnitCompiler.java:12124)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6746)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6507)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getReferenceType(UnitCompiler.java:6520)
      at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:6486)
      at org.codehaus.janino.UnitCompiler.access$13800(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$21$1.visitReferenceType(UnitCompiler.java:6394)
      at org.codehaus.janino.UnitCompiler$21$1.visitReferenceType(UnitCompiler.java:6389)
      at org.codehaus.janino.Java$ReferenceType.accept(Java.java:3917)
      at org.codehaus.janino.UnitCompiler$21.visitType(UnitCompiler.java:6389)
      at org.codehaus.janino.UnitCompiler$21.visitType(UnitCompiler.java:6382)
      at org.codehaus.janino.Java$ReferenceType.accept(Java.java:3916)
      at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6382)
      at org.codehaus.janino.UnitCompiler.getType2(UnitCompiler.java:7009)
      at org.codehaus.janino.UnitCompiler.access$15200(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$21$2.visitCast(UnitCompiler.java:6425)
      at org.codehaus.janino.UnitCompiler$21$2.visitCast(UnitCompiler.java:6403)
      at org.codehaus.janino.Java$Cast.accept(Java.java:4887)
      at org.codehaus.janino.UnitCompiler$21.visitRvalue(UnitCompiler.java:6403)
      at org.codehaus.janino.UnitCompiler$21.visitRvalue(UnitCompiler.java:6382)
      at org.codehaus.janino.Java$Rvalue.accept(Java.java:4105)
      at org.codehaus.janino.UnitCompiler.getType(UnitCompiler.java:6382)
      at org.codehaus.janino.UnitCompiler.findMostSpecificIInvocable(UnitCompiler.java:9150)
      at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:9036)
      at org.codehaus.janino.UnitCompiler.findIMethod(UnitCompiler.java:8938)
      at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5060)
      at org.codehaus.janino.UnitCompiler.access$9100(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4421)
      at org.codehaus.janino.UnitCompiler$16.visitMethodInvocation(UnitCompiler.java:4394)
      at org.codehaus.janino.Java$MethodInvocation.accept(Java.java:5062)
      at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
      at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
      at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5019)
      at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4416)
      at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4394)
      at org.codehaus.janino.Java$Cast.accept(Java.java:4887)
      at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
      at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
      at org.codehaus.janino.UnitCompiler.compileGet2(UnitCompiler.java:5019)
      at org.codehaus.janino.UnitCompiler.access$8600(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4416)
      at org.codehaus.janino.UnitCompiler$16.visitCast(UnitCompiler.java:4394)
      at org.codehaus.janino.Java$Cast.accept(Java.java:4887)
      at org.codehaus.janino.UnitCompiler.compileGet(UnitCompiler.java:4394)
      at org.codehaus.janino.UnitCompiler.compileGetValue(UnitCompiler.java:5575)
      at org.codehaus.janino.UnitCompiler.compile2(UnitCompiler.java:2580)
      at org.codehaus.janino.UnitCompiler.access$2700(UnitCompiler.java:215)
      at org.codehaus.janino.UnitCompiler$6.visitLocalVariableDeclarationStatement(UnitCompiler.java:1503)
      at org.codehaus.janino.UnitCompiler$6.visitLocalVariableDeclarationStatement(UnitCompiler.java:1487)
      at org.codehaus.janino.Java$LocalVariableDeclarationStatement.accept(Java.java:3511)
      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)
      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:78)
      ... 25 more

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                leen linweijiang
              • Votes:
                0 Vote for this issue
                Watchers:
                3 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: