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)
