[GitHub] [incubator-gobblin] autumnust commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

autumnust commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r441108741 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java ## @@ -100,17 +101,29 @@ protected vo

[GitHub] [incubator-gobblin] autumnust commented on a change in pull request #3027: [GOBBLIN-1187] cancel flow execution when dag manager is disabled

autumnust commented on a change in pull request #3027: URL: https://github.com/apache/incubator-gobblin/pull/3027#discussion_r439150290 ## File path: gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java ## @@ -108,10 +102,10 @@ p