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 fb2d690 [FLINK-23558][streaming] Ignoring RejectedExecutionException
during s… (#16653)
add 67dfee0 [FLINK-23619][python] Remove
PythonTimestampsAndWatermarksOperator
add d9721b0 [hotfix][python] Remove unused classes RunnerInputType and
RunnerOutputType
No new revisions were added by this update.
Summary of changes:
flink-python/pyflink/datastream/data_stream.py | 73 +++++----
.../pyflink/fn_execution/datastream/operations.py | 53 +++---
.../pyflink/fn_execution/flink_fn_execution_pb2.py | 40 +++--
.../pyflink/proto/flink-fn-execution.proto | 3 +-
.../apache/flink/python/util/PythonConfigUtil.java | 39 -----
.../python/eventtime/CustomTimestampAssigner.java | 19 +--
.../eventtime/RemoveTimestampMapFunction.java | 22 +--
.../python/OneInputPythonFunctionOperator.java | 180 ++++++++++++---------
.../operators/python/PythonCoProcessOperator.java | 111 ++++++-------
.../python/PythonKeyedCoProcessOperator.java | 109 ++++---------
.../python/PythonKeyedProcessOperator.java | 175 ++++----------------
.../operators/python/PythonProcessOperator.java | 95 +++++------
.../PythonTimestampsAndWatermarksOperator.java | 180 ---------------------
.../python/TwoInputPythonFunctionOperator.java | 154 +++++++++---------
.../streaming/api/utils/PythonOperatorUtils.java | 8 -
.../streaming/api/utils/input/RunnerInputType.java | 31 ----
.../api/utils/output/RunnerOutputType.java | 52 ------
17 files changed, 418 insertions(+), 926 deletions(-)
copy
flink-java/src/main/java/org/apache/flink/api/java/operators/translation/KeyRemovingMapper.java
=>
flink-python/src/main/java/org/apache/flink/streaming/api/functions/python/eventtime/CustomTimestampAssigner.java
(67%)
copy
flink-table/flink-table-runtime/src/main/java/org/apache/flink/table/data/conversion/IdentityConverter.java
=>
flink-python/src/main/java/org/apache/flink/streaming/api/functions/python/eventtime/RemoveTimestampMapFunction.java
(69%)
delete mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/operators/python/PythonTimestampsAndWatermarksOperator.java
delete mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/utils/input/RunnerInputType.java
delete mode 100644
flink-python/src/main/java/org/apache/flink/streaming/api/utils/output/RunnerOutputType.java
