[
https://issues.apache.org/jira/browse/FLINK-19567?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17213672#comment-17213672
]
godfrey he commented on FLINK-19567:
------------------------------------
do you check whether the plan is changed after the upgrade?
> JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference
> ------------------------------------------------------------------------
>
> Key: FLINK-19567
> URL: https://issues.apache.org/jira/browse/FLINK-19567
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Legacy Planner
> Affects Versions: 1.11.2
> Reporter: Danny Chen
> Priority: Major
>
> The
> {{org.apache.flink.table.runtime.stream.table.JoinITCase.testInnerJoinOutputWithPk}}
> is unstable, it fails randomly in the mvn test but success in the IDEA local
> runner.
> Here is the stacktrace:
> {code:xml}
> [ERROR]
> testInnerJoinOutputWithPk(org.apache.flink.table.runtime.stream.table.JoinITCase)
> Time elapsed: 0.044 s <<< ERROR!
> org.apache.flink.table.codegen.CodeGenException: Incompatible types of
> expression and result type.
> Expression[GeneratedExpression(result$19166,isNull$19167,,GenericType<java.lang.Object>,false)]
> type is [GenericType<java.lang.Object>], result type is
> [GenericType<org.apache.flink.table.runtime.utils.CommonTestData.NonPojo>]
> at
> org.apache.flink.table.codegen.CodeGenerator$$anonfun$generateResultExpression$2.apply(CodeGenerator.scala:379)
> at
> org.apache.flink.table.codegen.CodeGenerator$$anonfun$generateResultExpression$2.apply(CodeGenerator.scala:377)
> at
> scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
> at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48)
> at
> org.apache.flink.table.codegen.CodeGenerator.generateResultExpression(CodeGenerator.scala:377)
> at
> org.apache.flink.table.codegen.CodeGenerator.generateConverterResultExpression(CodeGenerator.scala:295)
> at
> org.apache.flink.table.plan.nodes.datastream.StreamScan$class.generateConversionProcessFunction(StreamScan.scala:115)
> at
> org.apache.flink.table.plan.nodes.datastream.StreamScan$class.convertToInternalRow(StreamScan.scala:74)
> at
> org.apache.flink.table.plan.nodes.datastream.DataStreamScan.convertToInternalRow(DataStreamScan.scala:46)
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
