This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 4fddcb2 [hotfix][table-api] Add environment pre-condition to
fromXXStream() methods
add 4a3e6d6 [FLINK-11103][runtime] Set a configurable uncaught exception
handler for all entrypoints
No new revisions were added by this update.
Summary of changes:
.../generated/expert_cluster_section.html | 6 +
.../apache/flink/configuration/ClusterOptions.java | 18 +++
.../runtime/entrypoint/ClusterEntrypoint.java | 1 +
.../runtime/entrypoint/ClusterEntrypointUtils.java | 12 ++
.../runtime/taskexecutor/TaskManagerRunner.java | 2 +
.../util/ClusterUncaughtExceptionHandler.java | 53 ++++++++
.../ClusterUncaughtExceptionHandlerITCase.java | 137 +++++++++++++++++++++
7 files changed, 229 insertions(+)
create mode 100644
flink-runtime/src/main/java/org/apache/flink/runtime/util/ClusterUncaughtExceptionHandler.java
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/entrypoint/ClusterUncaughtExceptionHandlerITCase.java
