This is an automated email from the ASF dual-hosted git repository.
weizhong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 0a122f3 [FLINK-21857] StackOverflow for large parallelism jobs when
processing EndOfChannelStateEvent
add 7e49b1a [FLINK-21294][python] Support state access API for the
map/flat_map operation of Python ConnectedStreams
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/data_stream.py | 90 ++++++--
flink-python/pyflink/datastream/functions.py | 191 +++++++++++-----
.../pyflink/datastream/tests/test_data_stream.py | 106 ++++++++-
.../fn_execution/beam/beam_coder_impl_slow.py | 16 --
.../pyflink/fn_execution/beam/beam_coders.py | 29 +--
.../pyflink/fn_execution/coder_impl_fast.pyx | 13 --
flink-python/pyflink/fn_execution/coders.py | 1 -
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 138 ++++++------
.../pyflink/fn_execution/operation_utils.py | 126 +++++------
flink-python/pyflink/fn_execution/operations.py | 175 ++++++++++-----
.../{util => fn_execution/utils}/__init__.py | 0
.../pyflink/fn_execution/utils/input_handler.py | 159 ++++++++++++++
.../pyflink/proto/flink-fn-execution.proto | 3 +-
flink-python/setup.py | 1 +
.../operators/python/PythonCoFlatMapOperator.java | 48 ++--
.../api/operators/python/PythonCoMapOperator.java | 25 +--
.../python/PythonKeyedCoProcessOperator.java | 242 +++++++++++++++++++++
.../python/PythonKeyedProcessOperator.java | 74 +++----
.../python/TwoInputPythonFunctionOperator.java | 133 ++++++-----
.../streaming/api/utils/PythonOperatorUtils.java | 41 ----
.../input/KeyedTwoInputWithTimerRowFactory.java | 105 +++++++++
.../streaming/api/utils/input/RunnerInputType.java | 23 +-
.../flink/streaming/api/utils/input/TimerType.java | 23 +-
.../utils/output/OutputWithTimerRowHandler.java | 94 ++++++++
.../api/utils/output/TimerOperandType.java | 54 +++++
25 files changed, 1354 insertions(+), 556 deletions(-)
copy flink-python/pyflink/{util => fn_execution/utils}/__init__.py (100%)
create mode 100644 flink-python/pyflink/fn_execution/utils/input_handler.py
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonKeyedCoProcessOperator.java
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/utils/input/KeyedTwoInputWithTimerRowFactory.java
copy
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.less
=>
flink-python/src/main/java/org/apache/flink/streaming/api/utils/input/RunnerInputType.java
(75%)
copy
flink-runtime-web/web-dashboard/src/app/pages/job/checkpoints/job-checkpoints.component.less
=>
flink-python/src/main/java/org/apache/flink/streaming/api/utils/input/TimerType.java
(76%)
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/utils/output/OutputWithTimerRowHandler.java
create mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/utils/output/TimerOperandType.java
