You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by pm...@apache.org on 2019/10/23 01:40:33 UTC
[samza] 02/03: Moving writeMetadataFile() invocation to
ContainerLaunchUtil from LocalContainerRunner (#1198)
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 <40...@users.noreply.github.com>
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);