This is an automated email from the ASF dual-hosted git repository. pmaheshwari pushed a commit to branch 1.3.0 in repository https://gitbox.apache.org/repos/asf/samza.git
commit 1b1af6e21a1627d6ba41c4a1ff20745290ad72c2 Author: rmatharu <[email protected]> AuthorDate: Mon Oct 21 13:28:02 2019 -0700 Moving writeMetadataFile() invocation to ContainerLaunchUtil from LocalContainerRunner (#1198) --- .../src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java | 1 + .../src/main/java/org/apache/samza/runtime/LocalContainerRunner.java | 3 --- 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java b/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java index e1b9b24..47f7398 100644 --- a/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java +++ b/samza-core/src/main/java/org/apache/samza/runtime/ContainerLaunchUtil.java @@ -79,6 +79,7 @@ public class ContainerLaunchUtil { JobModel jobModel) { Config config = jobModel.getConfig(); + DiagnosticsUtil.writeMetadataFile(jobName, jobId, containerId, execEnvContainerId, config); run(appDesc, jobName, jobId, containerId, execEnvContainerId, jobModel, config, buildExternalContext(config)); System.exit(0); diff --git a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java index ebebbe7..07cd637 100644 --- a/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java +++ b/samza-core/src/main/java/org/apache/samza/runtime/LocalContainerRunner.java @@ -31,7 +31,6 @@ import org.apache.samza.config.JobConfig; import org.apache.samza.config.ShellCommandConfig; import org.apache.samza.container.SamzaContainer; import org.apache.samza.job.model.JobModel; -import org.apache.samza.util.DiagnosticsUtil; import org.apache.samza.util.SamzaUncaughtExceptionHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -72,8 +71,6 @@ public class LocalContainerRunner { MDC.put("jobName", jobName); MDC.put("jobId", jobId); - DiagnosticsUtil.writeMetadataFile(jobName, jobId, containerId, execEnvContainerId, config); - ApplicationDescriptorImpl<? extends ApplicationDescriptor> appDesc = ApplicationDescriptorUtil.getAppDescriptor(ApplicationUtil.fromConfig(config), config);
