[
https://issues.apache.org/jira/browse/FLINK-20556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17247307#comment-17247307
]
Jark Wu commented on FLINK-20556:
---------------------------------
It fails to compile this line:
{code:java}
/* 33 */ org.apache.flink.table.data.RowData in1 =
(org.apache.flink.table.data.RowData) (org.apache.flink.table.data.RowData)
converter$0.toInternal((com.snmi.flink.pojo.package.H5Log) element.getValue());
{code}
And the exception:
{code}
java.lang.RuntimeException: Could not instantiate generated class
'SourceConversion$10'
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:67)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.operators.CodeGenOperatorFactory.createStreamOperator(CodeGenOperatorFactory.java:40)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.api.operators.StreamOperatorFactoryUtil.createOperator(StreamOperatorFactoryUtil.java:70)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:470)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:393)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:459)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:393)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createChainedOperator(OperatorChain.java:459)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.createOutputCollector(OperatorChain.java:393)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.OperatorChain.<init>(OperatorChain.java:155)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:459)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:528)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
[flink-dist_2.12-1.11.2.jar:1.11.2]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
[flink-dist_2.12-1.11.2.jar:1.11.2]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_201]
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:68)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:65)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
... 14 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)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:66)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:65)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
... 14 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)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:66)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:65)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
... 14 more
Caused by: org.codehaus.commons.compiler.CompileException: Line 33, Column 180:
Unexpected selector 'package' after "."
at org.codehaus.janino.Parser.compileException(Parser.java:3482)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseSelector(Parser.java:3147)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseUnaryExpression(Parser.java:2761)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseMultiplicativeExpression(Parser.java:2717)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAdditiveExpression(Parser.java:2696)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseShiftExpression(Parser.java:2675)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseRelationalExpression(Parser.java:2599)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseEqualityExpression(Parser.java:2573)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAndExpression(Parser.java:2552)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseExclusiveOrExpression(Parser.java:2531)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseInclusiveOrExpression(Parser.java:2510)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalAndExpression(Parser.java:2489)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalOrExpression(Parser.java:2468)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalExpression(Parser.java:2449)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseAssignmentExpression(Parser.java:2428)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseExpression(Parser.java:2413)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parsePrimary(Parser.java:2828)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseUnaryExpression(Parser.java:2758)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseMultiplicativeExpression(Parser.java:2717)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAdditiveExpression(Parser.java:2696)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseShiftExpression(Parser.java:2675)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseRelationalExpression(Parser.java:2599)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseEqualityExpression(Parser.java:2573)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAndExpression(Parser.java:2552)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseExclusiveOrExpression(Parser.java:2531)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseInclusiveOrExpression(Parser.java:2510)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalAndExpression(Parser.java:2489)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalOrExpression(Parser.java:2468)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalExpression(Parser.java:2449)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseAssignmentExpression(Parser.java:2428)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseExpression(Parser.java:2413)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseArgumentList(Parser.java:3214)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseArguments(Parser.java:3200)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parsePrimary(Parser.java:2868)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseUnaryExpression(Parser.java:2758)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parsePrimary(Parser.java:2841)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseUnaryExpression(Parser.java:2758)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parsePrimary(Parser.java:2841)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseUnaryExpression(Parser.java:2758)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseMultiplicativeExpression(Parser.java:2717)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAdditiveExpression(Parser.java:2696)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseShiftExpression(Parser.java:2675)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseRelationalExpression(Parser.java:2599)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseEqualityExpression(Parser.java:2573)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseAndExpression(Parser.java:2552)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseExclusiveOrExpression(Parser.java:2531)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseInclusiveOrExpression(Parser.java:2510)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalAndExpression(Parser.java:2489)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalOrExpression(Parser.java:2468)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseConditionalExpression(Parser.java:2449)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseAssignmentExpression(Parser.java:2428)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseExpression(Parser.java:2413)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseVariableInitializer(Parser.java:1412)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseVariableDeclaratorRest(Parser.java:1695)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseVariableDeclarator(Parser.java:1678)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseVariableDeclarators(Parser.java:1640)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseBlockStatement(Parser.java:1625)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseBlockStatements(Parser.java:1544)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseMethodDeclarationRest(Parser.java:1381)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseClassBodyDeclaration(Parser.java:834)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseClassBody(Parser.java:732)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parseClassDeclarationRest(Parser.java:638)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.codehaus.janino.Parser.parsePackageMemberTypeDeclarationRest(Parser.java:366)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.Parser.parseCompilationUnit(Parser.java:237)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:216)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.janino.SimpleCompiler.cook(SimpleCompiler.java:207)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:80)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at org.codehaus.commons.compiler.Cookable.cook(Cookable.java:75)
~[flink-table_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.doCompile(CompileUtils.java:78)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.lambda$compile$1(CompileUtils.java:66)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache$1.load(LocalCache.java:4742)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2319)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2282)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$Segment.get(LocalCache.java:2197)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache.get(LocalCache.java:3937)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.shaded.guava18.com.google.common.cache.LocalCache$LocalManualCache.get(LocalCache.java:4739)
~[flink-dist_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.CompileUtils.compile(CompileUtils.java:66)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.compile(GeneratedClass.java:78)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
at
org.apache.flink.table.runtime.generated.GeneratedClass.newInstance(GeneratedClass.java:65)
~[flink-table-blink_2.12-1.11.2.jar:1.11.2]
... 14 more
{code}
> org.apache.flink.api.common.InvalidProgramException: Table program cannot be
> compiled. This is a bug. Please file an issue.
> ----------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-20556
> URL: https://issues.apache.org/jira/browse/FLINK-20556
> Project: Flink
> Issue Type: Bug
> Components: API / Scala, Client / Job Submission, Table SQL / Runtime
> Affects Versions: 1.11.2
> Environment: flink-1.11.2
> IntelliJ IDEA 2019.2 x64
> window10
> scala
> Reporter: Zezheng Qin
> Priority: Major
> Attachments: bug-log.log, flink-datahub-bug.zip
>
>
> if i defined a pojo class in a package object, the job excute failly.
> but the job can excute successfully what if i defined a pojo class in the
> package
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
