Hi, Guillermo.
Additional, if there is an 'ORDER BY' clause, a Sort node should theoretically
appear in the execution plan.
However, according to CALCITE-2798[1], it is possible for the inner 'ORDER BY'
to be ignored during SQL parsing.
[1] https://issues.apache.org/jira/browse/CALCITE-279
Hi Guillermo
> "When is this ordering done, and until when?"
Assuming the current watermark is 10:00
1. Currently, data before 10:00 will be sorted.
2. If data after 10:00 arrives at this time, the record will be stored in
the state, waiting for the watermark to become 10:01 before sorting and
ou
I am running several queries in FlinkSQL, and in a final step before
inserting into Kafka, I perform an ORDER BY eventTime. When I look at the
execution plan, I see Exchange(distribution=[single]). Does this mean that
all the data is going to a single node and getting reordered there? I
haven't bee
