Shengkai Fang created FLINK-23671: ------------------------------------- Summary: Failed to inference type in correlate Key: FLINK-23671 URL: https://issues.apache.org/jira/browse/FLINK-23671 Project: Flink Issue Type: Bug Components: Table SQL / Planner Affects Versions: 1.13.2 Reporter: Shengkai Fang
{code:java} CREATE TABLE side( `id2` VARCHAR, PRIMARY KEY (`id2`) NOT ENFORCED ) WITH ( 'connector' = 'values' ); !info CREATE TABLE main( `id` VARCHAR, `proctime` as proctime() ) WITH ( 'connector' = 'datagen', 'number-of-rows' = '10' ); CREATE TABLE blackhole( `id` VARCHAR ) WITH ( 'connector' = 'blackhole' ); INSERT INTO blackhole SELECT `id` FROM main JOIN side FOR SYSTEM_TIME AS OF main.`proctime` ON main.`id` = side.`id2` INNER join lateral table(func111(side.`id2`)) as T(`is_match`, `match_bizline`, `match_page_id`, `source_type`) ON 1 = 1; {code} The exception stack as follows. {code:java} org.apache.flink.table.planner.codegen.CodeGenException: Mismatch of function's argument data type 'STRING NOT NULL' and actual argument type 'STRING'. at org.apache.flink.table.planner.codegen.calls.BridgingFunctionGenUtil$$anonfun$verifyArgumentTypes$1.apply(BridgingFunctionGenUtil.scala:323) at org.apache.flink.table.planner.codegen.calls.BridgingFunctionGenUtil$$anonfun$verifyArgumentTypes$1.apply(BridgingFunctionGenUtil.scala:320) at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59) at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:48) at org.apache.flink.table.planner.codegen.calls.BridgingFunctionGenUtil$.verifyArgumentTypes(BridgingFunctionGenUtil.scala:320) at org.apache.flink.table.planner.codegen.calls.BridgingFunctionGenUtil$.generateFunctionAwareCallWithDataType(BridgingFunctionGenUtil.scala:95) at org.apache.flink.table.planner.codegen.calls.BridgingFunctionGenUtil$.generateFunctionAwareCall(BridgingFunctionGenUtil.scala:65) at org.apache.flink.table.planner.codegen.calls.BridgingSqlFunctionCallGen.generate(BridgingSqlFunctionCallGen.scala:73) at org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateCallExpression(ExprCodeGenerator.scala:861) at org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:537) at org.apache.flink.table.planner.codegen.ExprCodeGenerator.visitCall(ExprCodeGenerator.scala:57) at org.apache.calcite.rex.RexCall.accept(RexCall.java:174) at org.apache.flink.table.planner.codegen.ExprCodeGenerator.generateExpression(ExprCodeGenerator.scala:157) at org.apache.flink.table.planner.codegen.CorrelateCodeGenerator$.generateOperator(CorrelateCodeGenerator.scala:127) at org.apache.flink.table.planner.codegen.CorrelateCodeGenerator$.generateCorrelateTransformation(CorrelateCodeGenerator.scala:75) at org.apache.flink.table.planner.codegen.CorrelateCodeGenerator.generateCorrelateTransformation(CorrelateCodeGenerator.scala) at org.apache.flink.table.planner.plan.nodes.exec.common.CommonExecCorrelate.translateToPlanInternal(CommonExecCorrelate.java:102) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.translateToPlan(ExecNodeBase.java:210) at org.apache.flink.table.planner.plan.nodes.exec.ExecEdge.translateToPlan(ExecEdge.java:289) at org.apache.flink.table.planner.plan.nodes.exec.ExecNodeBase.lambda$translateInputToPlan$5(ExecNodeBase.java:244) {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)