This is an automated email from the ASF dual-hosted git repository.
dianfu pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 57cabdccf88 [FLINK-29852][Runtime] Fix AdaptiveScheduler add operator
repeatedly in json plan.
add 8713b176abc [FLINK-31185][python] Support side-output in broadcast
processing
No new revisions were added by this update.
Summary of changes:
.../pyflink/datastream/tests/test_data_stream.py | 77 +++++++++++++
.../fn_execution/datastream/embedded/operations.py | 25 ++--
.../chain/PythonOperatorChainingOptimizer.java | 7 ++
.../apache/flink/python/util/PythonConfigUtil.java | 9 ++
.../python/DelegateOperatorTransformation.java | 128 +++++++++++++++++++++
.../python/PythonBroadcastStateTransformation.java | 10 +-
.../PythonKeyedBroadcastStateTransformation.java | 11 +-
...thonBroadcastStateTransformationTranslator.java | 11 +-
...eyedBroadcastStateTransformationTranslator.java | 11 +-
9 files changed, 269 insertions(+), 20 deletions(-)
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/transformations/python/DelegateOperatorTransformation.java
