Update MesosCoarseGrainedSchedulerBackend.scala

apache · Mar 2, 2020 · 84f5105 · 84f5105
1 parent 082f590
commit 84f5105
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...n/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala b/...n/scala/org/apache/spark/scheduler/cluster/mesos/MesosCoarseGrainedSchedulerBackend.scala
@@ -637,7 +637,7 @@ private[spark] class MesosCoarseGrainedSchedulerBackend(
       if (state.equals(TaskState.RUNNING) &&
           shuffleServiceEnabled &&
           !slave.shuffleRegistered) {
-        assert(mesosExternalShuffleClient.isDefined,
+        assume(mesosExternalShuffleClient.isDefined,
           "External shuffle client was not instantiated even though shuffle service is enabled.")
         // TODO: Remove this and allow the MesosExternalShuffleService to detect
         // framework termination when new Mesos Framework HTTP API is available.