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 913b041 [FLINK-7205] [table] Add UUID() for Table API & SQL
add 93fa1dc [FLINK-10056] [test] Add
JobMasterTest#testRequestNextInputSplit
add 859fc6f [FLINK-9859] [runtime] More Akka config
add fb4eb93 [FLINK-5232] Add a Thread default uncaught exception handler
to the ActorSystem
add 6fdeb5d [FLINK-5232] Introduce RobustActorSystem
add e307f92 [FLINK-10123] Use ExecutorThreadFactory instead of
DefaultThreadFactory in RestServer/Client
No new revisions were added by this update.
Summary of changes:
docs/_includes/generated/akka_configuration.html | 45 ++++++
.../apache/flink/configuration/AkkaOptions.java | 77 +++++++++
.../runtime/clusterframework/BootstrapTools.java | 9 +-
.../apache/flink/runtime/jobmaster/JobMaster.java | 5 +
.../org/apache/flink/runtime/rest/RestClient.java | 4 +-
.../flink/runtime/rest/RestServerEndpoint.java | 6 +-
.../runtime/rpc/akka/AkkaRpcServiceUtils.java | 4 +-
.../main/scala/akka/actor/RobustActorSystem.scala | 98 ++++++++++++
.../org/apache/flink/runtime/akka/AkkaUtils.scala | 69 +++++++--
.../flink/runtime/jobmanager/JobManager.scala | 1 -
.../flink/runtime/akka/FlinkUntypedActorTest.java | 6 +-
.../executiongraph/ExecutionGraphTestUtils.java | 51 +++++-
.../runtime/instance/InstanceManagerTest.java | 6 +-
.../flink/runtime/jobmaster/JobMasterTest.java | 172 ++++++++++++++++++++-
.../JobManagerLeaderElectionTest.java | 5 +-
.../scala/akka/actor/RobustActorSystemTest.scala | 98 ++++++++++++
.../JobManagerHACheckpointRecoveryITCase.java | 3 +-
.../minicluster/LocalFlinkMiniClusterITCase.java | 3 +-
18 files changed, 618 insertions(+), 44 deletions(-)
create mode 100644
flink-runtime/src/main/scala/akka/actor/RobustActorSystem.scala
create mode 100644
flink-runtime/src/test/scala/akka/actor/RobustActorSystemTest.scala
