Repository: flink Updated Branches: refs/heads/master 5fc37f8ac -> 06afac21b
[FLINK-6593] [table] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator This closes #3918. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/06afac21 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/06afac21 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/06afac21 Branch: refs/heads/master Commit: 06afac21bca519c50682794fd2610d2f80371897 Parents: 5fc37f8 Author: Xpray <leonxp...@gmail.com> Authored: Tue May 16 16:59:14 2017 +0800 Committer: twalthr <twal...@apache.org> Committed: Tue May 16 14:43:09 2017 +0200 ---------------------------------------------------------------------- .../apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/06afac21/flink-libraries/flink-table/src/main/scala/org/apache/flink/table/plan/nodes/datastream/DataStreamCalc.scala ---------------------------------------------------------------------- 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 f75efc8..67c5782 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,