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 26bac51 [FLINK-10358] fix NPE when running flink-kinesis connector
against dynamodb streams
new 3bc7bc2 [FLINK-8660][ha] Enable user to provide custom HAServices
implementation
new 324d7be [FLINK-8660][ha] Add InstantiationUtil#instantiate to create
instance from class name
new ab3aabf [hotfix] Add JavaDoc to
HighAvailabilityServicesUtils#AddressResolution
new 5d29196 [hotfix] Add ExceptionUtils#stripException
new 6522f17 [hotfix] Unstrip UndeclaredThrowableExceptions from
entrypoints
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/_includes/generated/common_section.html | 2 +-
.../generated/high_availability_configuration.html | 2 +-
docs/ops/jobmanager_high_availability.md | 1 +
.../org/apache/flink/client/cli/CliFrontend.java | 6 +-
.../configuration/HighAvailabilityOptions.java | 4 +-
.../java/org/apache/flink/util/ExceptionUtils.java | 24 ++++--
.../org/apache/flink/util/InstantiationUtil.java | 19 +++++
.../org/apache/flink/util/ExceptionUtilsTest.java | 18 +++++
.../mesos/entrypoint/MesosTaskExecutorRunner.java | 15 ++--
.../runtime/webmonitor/history/HistoryServer.java | 13 ++--
.../org/apache/flink/runtime/blob/BlobUtils.java | 8 +-
.../runtime/entrypoint/ClusterEntrypoint.java | 6 +-
.../HighAvailabilityServicesFactory.java | 26 +++----
.../HighAvailabilityServicesUtils.java | 48 +++++++++++-
.../runtime/jobmanager/HighAvailabilityMode.java | 29 +++++---
.../runtime/taskexecutor/TaskManagerRunner.java | 4 +-
.../HighAvailabilityServicesUtilsTest.java | 86 ++++++++++++++++++++++
.../jobmanager/HighAvailabilityModeTest.java | 33 ++++++++-
.../apache/flink/yarn/YarnTaskExecutorRunner.java | 14 ++--
.../apache/flink/yarn/cli/FlinkYarnSessionCli.java | 13 ++--
20 files changed, 291 insertions(+), 80 deletions(-)
copy
flink-clients/src/test/java/org/apache/flink/client/cli/util/MockedCliFrontend.java
=>
flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/HighAvailabilityServicesFactory.java
(59%)
create mode 100644
flink-runtime/src/test/java/org/apache/flink/runtime/highavailability/HighAvailabilityServicesUtilsTest.java
