This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bf58725 Revert [FLINK-15670]
add cfeaedd [FLINK-17791][table][streaming] Support collecting query
results under all execution and network environments
No new revisions were added by this update.
Summary of changes:
.../streaming/api/datastream/DataStreamUtils.java | 85 ++++++----------------
.../collect/CollectSinkOperatorFactory.java | 17 +++--
.../api/operators/collect/CollectStreamSink.java | 84 +++++++++++++++++++++
.../table/planner/sinks/BatchSelectTableSink.java | 77 +-------------------
...lectTableSink.java => SelectTableSinkBase.java} | 59 +++++++--------
.../table/planner/sinks/StreamSelectTableSink.java | 58 +--------------
.../runtime/batch/sql/join/ScalarQueryITCase.scala | 4 +-
.../flink/table/sinks/StreamSelectTableSink.java | 37 +++++-----
.../apache/flink/table/planner/StreamPlanner.scala | 1 +
9 files changed, 173 insertions(+), 249 deletions(-)
create mode 100644
flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/collect/CollectStreamSink.java
copy
flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/sinks/{StreamSelectTableSink.java
=> SelectTableSinkBase.java} (53%)
