Hi Niklas,
The workaround that you described should work fine.
However, you don't need a custom sink.
Converting the Table into a DataSet and registering the DataSet again as a
Table is currently the way to solve this issue.
Best, Fabian
Am Di., 20. Nov. 2018 um 17:13 Uhr schrieb Niklas Teichman
Hi everybody,
I have a question concerning the Flink Table API, more precisely the
way the results of tables statements are evaluated. In the following
code example, the statement defining the table t1 is evaluated twice,
an effect that leads to some issues of performance and logic in the
