Repository: samza Updated Branches: refs/heads/master 623661e02 -> 482c6a227
SAMZA-1934: Do not set app.class for LegacyTaskApplication' Author: Boris S <[email protected]> Author: Boris S <[email protected]> Author: Boris Shkolnik <[email protected]> Reviewers: Yi Pan <[email protected]>, Xinyu Liu <[email protected]> Closes #705 from sborya/LegacyTaskApp Project: http://git-wip-us.apache.org/repos/asf/samza/repo Commit: http://git-wip-us.apache.org/repos/asf/samza/commit/482c6a22 Tree: http://git-wip-us.apache.org/repos/asf/samza/tree/482c6a22 Diff: http://git-wip-us.apache.org/repos/asf/samza/diff/482c6a22 Branch: refs/heads/master Commit: 482c6a22719b0eec9f49a34146dc291b23bcc3f8 Parents: 623661e Author: Boris S <[email protected]> Authored: Thu Oct 11 11:46:32 2018 -0700 Committer: Boris S <[email protected]> Committed: Thu Oct 11 11:46:32 2018 -0700 ---------------------------------------------------------------------- .../src/main/java/org/apache/samza/execution/JobPlanner.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/samza/blob/482c6a22/samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java ---------------------------------------------------------------------- diff --git a/samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java b/samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java index abbec18..83f3f61 100644 --- a/samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java +++ b/samza-core/src/main/java/org/apache/samza/execution/JobPlanner.java @@ -28,6 +28,7 @@ import java.util.Set; import org.apache.commons.lang3.StringUtils; import org.apache.samza.application.ApplicationDescriptor; import org.apache.samza.application.ApplicationDescriptorImpl; +import org.apache.samza.application.LegacyTaskApplication; import org.apache.samza.config.ApplicationConfig; import org.apache.samza.config.Config; import org.apache.samza.config.JobConfig; @@ -88,8 +89,10 @@ public abstract class JobPlanner { Map<String, String> systemStreamConfigs = expandSystemStreamConfigs(appDesc); cfg.putAll(systemStreamConfigs); - // adding app.class in the configuration - cfg.put(ApplicationConfig.APP_CLASS, appDesc.getAppClass().getName()); + // adding app.class in the configuration, unless it is LegacyTaskApplication + if (!LegacyTaskApplication.class.getName().equals(appDesc.getAppClass().getName())) { + cfg.put(ApplicationConfig.APP_CLASS, appDesc.getAppClass().getName()); + } // create the physical execution plan and merge with overrides. This works for a single-stage job now // TODO: This should all be consolidated with ExecutionPlanner after fixing SAMZA-1811
