[flink] branch master updated (b41ea22 -> fa2739d)

[di...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

dianfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from b41ea22  [FLINK-18553][table-api-java] Update set operations to new type system
     add fa2739d  [FLINK-18948][python][e2e] Add E2E test for Python DataStream API

No new revisions were added by this update.

Summary of changes:
 .../python/datastream}/__init__.py                 |   0
 .../python/datastream/data_stream_job.py           |  59 +++++++
 .../python/datastream/functions.py                 |  30 ++--
 flink-end-to-end-tests/run-nightly-tests.sh        |   3 +-
 .../test-scripts/test_pyflink_datastream.sh        | 179 +++++++++++++++++++++
 .../{test_pyflink.sh => test_pyflink_table.sh}     |   0
 6 files changed, 256 insertions(+), 15 deletions(-)
 copy {flink-python/pyflink/util => flink-end-to-end-tests/flink-python-test/python/datastream}/__init__.py (100%)
 create mode 100644 flink-end-to-end-tests/flink-python-test/python/datastream/data_stream_job.py
 copy flink-dist/src/test/bin/runExtractLoggingOutputs.sh => flink-end-to-end-tests/flink-python-test/python/datastream/functions.py (69%)
 mode change 100755 => 100644
 create mode 100755 flink-end-to-end-tests/test-scripts/test_pyflink_datastream.sh
 rename flink-end-to-end-tests/test-scripts/{test_pyflink.sh => test_pyflink_table.sh} (100%)