This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from b644af8 [FLINK-21890][table-planner-blink] Rename DAGProcessor to
ExecNodeGraphProcessor
add a33e6bd [FLINK-21814][datastream] Add host and port information in
exception when CollectSink can't connect to the client
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/flink/streaming/experimental/CollectSink.java | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)