[jira] [Created] (FLINK-6542) Non-keyed, non-windowed aggregation fails

["Timo Walther (JIRA)" <ji...@apache.org>]

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)