You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tw...@apache.org on 2017/05/16 12:43:39 UTC
flink git commit: [FLINK-6593] [table] Fix Bug in ProctimeAttribute
or RowtimeAttribute with CodeGenerator
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 <le...@gmail.com>
Authored: Tue May 16 16:59:14 2017 +0800
Committer: twalthr <tw...@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,