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 3a9bae57445 [hotfix][network] Modify the log level of "Failed to read
shuffle data." to DEBUG
add d966c10eaa3 [FLINK-28745][python] Support DataStream
PythonCoProcessOperator and PythonKeyedCoProcessOperator in Thread Mode
No new revisions were added by this update.
Summary of changes:
flink-python/dev/dev-requirements.txt | 2 +-
flink-python/pom.xml | 2 +-
flink-python/pyflink/datastream/data_stream.py | 15 ++-
.../pyflink/datastream/tests/test_data_stream.py | 128 ++++++++++-----------
.../fn_execution/datastream/embedded/operations.py | 71 ++++++++++++
.../datastream/embedded/process_function.py | 13 ++-
.../fn_execution/embedded/operation_utils.py | 31 ++++-
.../pyflink/fn_execution/embedded/operations.py | 83 ++++++++++---
flink-python/setup.py | 2 +-
.../chain/PythonOperatorChainingOptimizer.java | 8 +-
...ctEmbeddedDataStreamPythonFunctionOperator.java | 16 +++
...ractOneInputEmbeddedPythonFunctionOperator.java | 10 --
...actTwoInputEmbeddedPythonFunctionOperator.java} | 113 ++++++++++++------
...r.java => EmbeddedPythonCoProcessOperator.java} | 22 ++--
...a => EmbeddedPythonKeyedCoProcessOperator.java} | 28 +++--
.../embedded/EmbeddedPythonProcessOperator.java | 3 +-
flink-python/src/main/resources/META-INF/NOTICE | 2 +-
17 files changed, 390 insertions(+), 159 deletions(-)
copy
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/{AbstractOneInputEmbeddedPythonFunctionOperator.java
=> AbstractTwoInputEmbeddedPythonFunctionOperator.java} (61%)
copy
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/{EmbeddedPythonProcessOperator.java
=> EmbeddedPythonCoProcessOperator.java} (87%)
copy
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/embedded/{EmbeddedPythonKeyedProcessOperator.java
=> EmbeddedPythonKeyedCoProcessOperator.java} (87%)
