flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From twal...@apache.org
Subject flink git commit: [FLINK-6593] [table] Fix Bug in ProctimeAttribute or RowtimeAttribute with CodeGenerator
Date Tue, 16 May 2017 12:45:39 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.3 a827c540e -> fc2012702


[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/fc201270
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fc201270
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fc201270

Branch: refs/heads/release-1.3
Commit: fc2012702b03989a15b2198b1988ca99de7f4889
Parents: a827c54
Author: Xpray <leonxpray@gmail.com>
Authored: Tue May 16 16:59:14 2017 +0800
Committer: twalthr <twalthr@apache.org>
Committed: Tue May 16 14:45:15 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/fc201270/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,


Mime
View raw message