Commit e165b498 authored by Daniele Venzano's avatar Daniele Venzano

Set finished executions as finished and not as terminated

parent a5d3f9bd
......@@ -225,6 +225,7 @@ class PlatformManager:
if container.readable_name == "spark-submit" or container.readable_name == "spark-master":
log.debug("found a dead spark-submit container, cleaning up")
self.execution_terminate(state, container.cluster.execution)
container.cluster.execution.set_finished()
notify_execution_finished(container.cluster.execution)
else:
log.warning("Container {} (ID: {}) died unexpectedly")
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment