tillrohrmann commented on a change in pull request #6464:
URL: https://github.com/apache/flink/pull/6464#discussion_r500848130
##########
File path:
flink-mesos/src/main/java/org/apache/flink/mesos/runtime/clusterframework/MesosResourceManager.java
##########
@@ -794,7 +828,7 @@ public void run() {
@Override
public void disconnected(SchedulerDriver driver) {
- runAsync(new Runnable() {
+ runAsyncWithoutFencing(new Runnable() {
Review comment:
I have a suspicion why we did it. If you have time for a quick call,
then we could discuss it and maybe it rings a bell. Just let me know when it
would work for you.
In any case, changing it and running it on `flink-jepsen` sounds like a good
idea to validate the changes. cc @xintongsong.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
