[jira] [Created] (FLINK-25199) fromValues does not emit final MAX watermark

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

Timo Walther created FLINK-25199:
------------------------------------

             Summary: fromValues does not emit final MAX watermark
                 Key: FLINK-25199
                 URL: https://issues.apache.org/jira/browse/FLINK-25199
             Project: Flink
          Issue Type: Bug
          Components: Table SQL / Runtime
            Reporter: Timo Walther


It seems {{fromValues}} that generates multiple rows does not emit any watermarks:

{code}
        StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);

        Table inputTable =
                tEnv.fromValues(
                        DataTypes.ROW(
                                DataTypes.FIELD("weight", DataTypes.DOUBLE()),
                                DataTypes.FIELD("f0", DataTypes.STRING()),
                                DataTypes.FIELD("f1", DataTypes.DOUBLE()),
                                DataTypes.FIELD("f2", DataTypes.DOUBLE()),
                                DataTypes.FIELD("f3", DataTypes.DOUBLE()),
                                DataTypes.FIELD("f4", DataTypes.INT()),
                                DataTypes.FIELD("label", DataTypes.STRING())),
                        Row.of(1., "a", 1., 1., 1., 2, "l1"),
                        Row.of(1., "a", 1., 1., 1., 2, "l1"));

        DataStream<Row> input = tEnv.toDataStream(inputTable);
{code}

{{fromValues(1, 2, 3)}} or {{fromValues}} with only 1 row works correctly.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)