[
https://issues.apache.org/jira/browse/FLINK-29829?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yubin Li updated FLINK-29829:
-----------------------------
Description:
Delete last line separator during explain results generation in design, but in
fact, just delete the last character, it will result in the outputs in Windows
has one more line than Linux. It will confuse users, and block test cases in
platforms differ from Linux.
{code:java}
//Windows
LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
fields=[a, b])
+- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$, rowtime,
6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
+- Exchange(distribution=[hash[id1]])
+- Calc(select=[id1, rowtime, text, '*' AS $f3])
+- Reused(reference_id=[1])
{code}
{code:java}
//linux
LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
fields=[a, b])
+- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$, rowtime,
6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
+- Exchange(distribution=[hash[id1]])
+- Calc(select=[id1, rowtime, text, '*' AS $f3])
+- Reused(reference_id=[1])
{code}
was:
Delete last line separator during explain results generation in design, but in
fact, just delete the last character, it will result in the outputs in Windows
has one more line than Linux.
{code:java}
//Windows
LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
fields=[a, b])
+- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$, rowtime,
6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
+- Exchange(distribution=[hash[id1]])
+- Calc(select=[id1, rowtime, text, '*' AS $f3])
+- Reused(reference_id=[1])
{code}
{code:java}
//linux
LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
fields=[a, b])
+- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$, rowtime,
6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
+- Exchange(distribution=[hash[id1]])
+- Calc(select=[id1, rowtime, text, '*' AS $f3])
+- Reused(reference_id=[1])
{code}
> align explain results in different platforms
> --------------------------------------------
>
> Key: FLINK-29829
> URL: https://issues.apache.org/jira/browse/FLINK-29829
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Reporter: Yubin Li
> Priority: Major
>
> Delete last line separator during explain results generation in design, but
> in fact, just delete the last character, it will result in the outputs in
> Windows has one more line than Linux. It will confuse users, and block test
> cases in platforms differ from Linux.
>
> {code:java}
> //Windows
> LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
> fields=[a, b])
> +- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$,
> rowtime, 6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
> +- Exchange(distribution=[hash[id1]])
> +- Calc(select=[id1, rowtime, text, '*' AS $f3])
> +- Reused(reference_id=[1])
> {code}
>
>
> {code:java}
> //linux
> LegacySink(name=[`default_catalog`.`default_database`.`appendSink2`],
> fields=[a, b])
> +- GroupWindowAggregate(groupBy=[id1], window=[SlidingGroupWindow('w$,
> rowtime, 6000, 12000)], select=[id1, LISTAGG(text, $f3) AS EXPR$1])
> +- Exchange(distribution=[hash[id1]])
> +- Calc(select=[id1, rowtime, text, '*' AS $f3])
> +- Reused(reference_id=[1])
> {code}
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
