Github user yanghua commented on the issue:
https://github.com/apache/flink/pull/6334
hi @tillrohrmann I tried to fix this issue based on your suggestion in the
jira. But there seems a little question, I want to consult you.
The question is about the ActorSystem, you suggested add the uncaught
exception handler for the `ActorSystem`. To do this, we should extend the
`ActorSystemImpl` (the default implementation). This class's constructor has
[many
parameters](https://github.com/akka/akka/blob/master/akka-actor/src/main/scala/akka/actor/ActorSystem.scala#L651).
I am not very familiar with it. So I tried fill the ["default"
params](https://github.com/yanghua/flink/blob/27dec5d60d2e799aeea66013b3da904cec137408/flink-runtime/src/main/scala/org/apache/flink/runtime/akka/RobustActorSystem.scala#L33).
I ran the test case, they always failed because of the fifth parameter.
So the question is the `ActorSystemImpl` is marked as `InternalApi `, it
may be changed in the future, shall we extend a actor system based with it? If
yes, what's the correct value for these parameter?
I saw some similar customized case, such as
[this](https://gist.github.com/aarondav/ca1f0cdcd50727f89c0d#file-exceptioncatchingactorsystemimpl-scala-L14)
and
[this](https://gist.github.com/Kayrnt/9082178#file-rebootactorsystem-scala-L28).
However, it seems their version are both lower.
So hope for your idea and suggestion.
---