From d94cdf027a14512314c3f58baee996d345d3b2d7 Mon Sep 17 00:00:00 2001 From: Xpray Date: Tue, 16 May 2017 16:59:14 +0800 Subject: [PATCH] [FLINK-6593] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator --- .../flink/table/plan/nodes/datastream/DataStreamCalc.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala index f75efc80f074a..67c578276b06b 100644 --- a/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala +++ b/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala @@ -92,9 +92,8 @@ class DataStreamCalc( val inputDataStream = getInput.asInstanceOf[DataStreamRel].translateToPlan(tableEnv, queryConfig) - val inputRowType = inputDataStream.getType.asInstanceOf[CRowTypeInfo].rowType - val generator = new CodeGenerator(config, false, inputRowType) + val generator = new CodeGenerator(config, false, inputSchema.physicalTypeInfo) val genFunction = generateFunction( generator,