Timo Walther created FLINK-6542: ----------------------------------- Summary: Non-keyed, non-windowed aggregation fails Key: FLINK-6542 URL: https://issues.apache.org/jira/browse/FLINK-6542 Project: Flink Issue Type: Bug Components: Table API & SQL Reporter: Timo Walther
The following query produces an empty result: {code} val data = List( (1L, 1, 1d, 1f, new BigDecimal("1"), "Hi"), (2L, 2, 2d, 2f, new BigDecimal("2"), "Hallo"), (3L, 2, 2d, 2f, new BigDecimal("2"), "Hello"), (4L, 5, 5d, 5f, new BigDecimal("5"), "Hello"), (7L, 3, 3d, 3f, new BigDecimal("3"), "Hello"), (8L, 3, 3d, 3f, new BigDecimal("3"), "Hello world"), (16L, 4, 4d, 4f, new BigDecimal("4"), "Hello world")) @Test def testMin(): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment env.setStreamTimeCharacteristic(TimeCharacteristic.EventTime) val tEnv = TableEnvironment.getTableEnvironment(env) StreamITCase.testResults = mutable.MutableList() val stream = env .fromCollection(data) .assignTimestampsAndWatermarks(new TimestampWithEqualWatermark()) val table = stream.toTable(tEnv, 'rowtime.rowtime, 'int, 'double, 'float, 'bigdec, 'string) tEnv.registerTable("MyTable", table) val t = tEnv.sql("SELECT MIN(`int`) FROM MyTable") t.toRetractStream[Row].print() } {code} -- This message was sent by Atlassian JIRA (v6.3.15#6346)