This is an automated email from the ASF dual-hosted git repository. hequn pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from 6d72cc0 [FLINK-18688][table-planner-blink] Fix binary row writing with incorrect order in ProjectionCodeGenerator by removing for loop optimization add b8d2ed7 [FLINK-18766][python] Support add_sink() for Python DataStream API. (#13094) No new revisions were added by this update. Summary of changes: flink-python/pyflink/datastream/data_stream.py | 87 +++++++++++++++++++++- flink-python/pyflink/datastream/functions.py | 32 ++++++++ .../pyflink/datastream/tests/test_data_stream.py | 67 +++++++++-------- .../tests/test_stream_execution_environment.py | 14 ++-- flink-python/pyflink/datastream/tests/test_util.py | 27 ++----- .../python/util/DataStreamTestCollectSink.java | 18 +++-- 6 files changed, 176 insertions(+), 69 deletions(-)