You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by di...@apache.org on 2021/03/26 12:09:32 UTC
[flink] branch master updated (cd02aff -> 186a086)

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 cd02aff  [FLINK-21387][tests] Remove test timeout from DispatcherTest.testNonBlockingJobSubmission and .testInvalidCallDuringInitialization
     add 9404d464 [FLINK-21939][python] Support batch mode in Python DataStream API for process operation and reduce operation
     add 465393b  [hotfix][python] Rename the parameter from result_type to output_type for flat_map
     add 186a086  [hotfix][python] Rename the parameter from key_type_info to key_type for key_by

No new revisions were added by this update.

Summary of changes:
 .../docs/dev/datastream/operators/overview.md      |   6 +-
 .../docs/dev/python/datastream/data_types.md       |   2 +-
 .../docs/dev/datastream/operators/overview.md      |   8 +-
 .../docs/dev/python/datastream/data_types.md       |   2 +-
 .../python/datastream/data_stream_job.py           |   2 +-
 flink-python/pyflink/datastream/data_stream.py     | 120 ++++++++---
 flink-python/pyflink/datastream/functions.py       |   6 +-
 .../pyflink/datastream/tests/test_data_stream.py   | 232 ++++++++++++---------
 .../tests/test_stream_execution_environment.py     |   2 +-
 .../pyflink/fn_execution/flink_fn_execution_pb2.py | 141 +++++++------
 flink-python/pyflink/fn_execution/operations.py    |  10 +-
 .../pyflink/proto/flink-fn-execution.proto         |   1 +
 .../python/AbstractPythonFunctionOperator.java     |  49 +++++
 .../python/OneInputPythonFunctionOperator.java     |   6 +-
 .../python/PythonKeyedCoProcessOperator.java       |   9 +-
 .../python/PythonKeyedProcessOperator.java         |  23 +-
 .../python/TwoInputPythonFunctionOperator.java     |   6 +-
 .../python/beam/BeamPythonFunctionRunner.java      |  11 +-
 .../streaming/api/utils/PythonOperatorUtils.java   |  26 ++-
 .../state/BatchExecutionKeyedStateBackend.java     |   2 +-
 20 files changed, 424 insertions(+), 240 deletions(-)