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.
---
|