This is an automated email from the ASF dual-hosted git repository.
hxb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4e9fa33 [FLINK-23283][table-planner] Fix unstable case
GroupWindowITCase#testWindowAggregateOnUpsertSource
add 4bcdfa2 [FLINK-23165][python] Add
StreamExecutionEnvironment#registerSlotSharingGroup to PyFlink and Scala
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/__init__.py | 4 +-
flink-python/pyflink/datastream/data_stream.py | 25 +-
.../pyflink/datastream/slot_sharing_group.py | 293 +++++++++++++++++++++
.../datastream/stream_execution_environment.py | 19 ++
.../pyflink/datastream/tests/test_data_stream.py | 7 +-
.../datastream/tests/test_slot_sharing_group.py | 66 +++++
.../tests/test_stream_execution_environment.py | 35 ++-
...st_stream_execution_environment_completeness.py | 3 +-
.../api/datastream/SingleOutputStreamOperator.java | 2 +-
.../flink/streaming/api/scala/DataStream.scala | 25 +-
10 files changed, 463 insertions(+), 16 deletions(-)
create mode 100644 flink-python/pyflink/datastream/slot_sharing_group.py
create mode 100644
flink-python/pyflink/datastream/tests/test_slot_sharing_group.py
