twalthr commented on a change in pull request #18701:
URL: https://github.com/apache/flink/pull/18701#discussion_r803676773
##
File path:
flink-table/flink-table-planner/src/main/scala/org/apache/flink/table/planner/delegation/StreamPlanner.scala
##
@@ -129,14 +134,48 @@ class
twalthr commented on a change in pull request #18701:
URL: https://github.com/apache/flink/pull/18701#discussion_r803652218
##
File path:
flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/CompiledPlan.java
##
@@ -79,25 +79,37 @@ default void writeToFile