Fix retry in case of untracked task failures (#436)

goyalankit · web-flow · commit 9568e1882216 · 2020-05-19T18:47:52.000-07:00
diff --git a/tony-core/src/main/java/com/linkedin/tony/ApplicationMaster.java b/tony-core/src/main/java/com/linkedin/tony/ApplicationMaster.java
@@ -549,6 +549,9 @@ private void reset() {
       LOG.info("Stop a task in container: containerId = " + container.getId() + ", containerNode = "
                + container.getNodeId().getHost());
     }
+    
+    // Reset the flag to track untracked processes.
+    untrackedTaskFailed = false;
 
     // Reset session
     session = sessionBuilder.build();

Original file line number	Diff line number	Diff line change
`@@ -549,6 +549,9 @@ private void reset() {`
`549`	`549`	`LOG.info("Stop a task in container: containerId = " + container.getId() + ", containerNode = "`
`550`	`550`	`+ container.getNodeId().getHost());`
`551`	`551`	`}`
	`552`	`+`
	`553`	`+ // Reset the flag to track untracked processes.`
	`554`	`+ untrackedTaskFailed = false;`
`552`	`555`
`553`	`556`	`// Reset session`
`554`	`557`	`session = sessionBuilder.build();`