Backport: Fix retry in case of untracked task failures (tony-framework#436)

goyalankit · zuston · commit 4cb97c03fc37 · 2021-06-23T17:10:41.000+08:00
PR: tony-framework#436
diff --git a/tony-core/src/main/java/com/linkedin/tony/ApplicationMaster.java b/tony-core/src/main/java/com/linkedin/tony/ApplicationMaster.java
@@ -689,6 +689,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
`@@ -689,6 +689,9 @@ private void reset() {`
`689`	`689`	`LOG.info("Stop a task in container: containerId = " + container.getId() + ", containerNode = "`
`690`	`690`	`+ container.getNodeId().getHost());`
`691`	`691`	`}`
	`692`	`+`
	`693`	`+ // Reset the flag to track untracked processes.`
	`694`	`+ untrackedTaskFailed = false;`
`692`	`695`
`693`	`696`	`// Reset session`
`694`	`697`	`session = sessionBuilder.build();`