Github user xccui commented on a diff in the pull request:
https://github.com/apache/flink/pull/5025#discussion_r151604024
--- Diff:
flink-libraries/flink-table/src/test/scala/org/apache/flink/table/runtime/stream/TimeAttributesITCase.scala
---
@@ -179,6 +179,32 @@ class TimeAttributesITCase extends
StreamingMultipleProgramsTestBase {
}
@Test
+ def testCalcMaterialization3(): Unit = {
+ val env = StreamExecutionEnvironment.getExecutionEnvironment
+ env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime)
+ val tEnv = TableEnvironment.getTableEnvironment(env)
+ MemoryTableSinkUtil.clear
+
+ val stream = env
+ .fromCollection(data)
+ .assignTimestampsAndWatermarks(new TimestampWithEqualWatermark())
+ val table = stream.toTable(tEnv, 'rowtime.rowtime, 'int, 'double,
'float, 'bigdec, 'string)
+
+ val t = table
--- End diff --
The t seems to be useless here.
---
