[jira] [Created] (FLINK-19567) JoinITCase.testInnerJoinOutputWithPk is unstable for POJO type inference

["Danny Chen (Jira)" <ji...@apache.org>]

Danny Chen created FLINK-19567:
----------------------------------

             Summary: 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


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)