You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by pn...@apache.org on 2019/09/27 06:29:28 UTC

[flink] branch master updated (2b608e3 -> b65370b)

This is an automated email from the ASF dual-hosted git repository.

pnowojski pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 2b608e3  [FLINK-14016][python][flink-table-planner] Introduce DataStreamPythonCalc for Python function execution
     add b65370b  [FLINK-13143][checkpointing] Remove unnecessary CheckpointExceptionHandler class (#9777)

No new revisions were added by this update.

Summary of changes:
 .../runtime/tasks/CheckpointExceptionHandler.java  | 36 ----------
 .../tasks/CheckpointExceptionHandlerFactory.java   | 59 -----------------
 .../flink/streaming/runtime/tasks/StreamTask.java  | 18 +----
 .../tasks/CheckpointExceptionHandlerTest.java      | 77 ----------------------
 .../streaming/runtime/tasks/StreamTaskTest.java    | 28 +++++++-
 5 files changed, 30 insertions(+), 188 deletions(-)
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointExceptionHandler.java
 delete mode 100644 flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/CheckpointExceptionHandlerFactory.java
 delete mode 100644 flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/CheckpointExceptionHandlerTest.java