SAMZA-994: fix StreamAppender start up issue w/ refactored JobCoordinator
diff --git a/samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java b/samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java
index ca4eb7f..5b532bc 100644
--- a/samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java
+++ b/samza-log4j/src/main/java/org/apache/samza/logging/log4j/StreamAppender.java
@@ -53,7 +53,7 @@
public class StreamAppender extends AppenderSkeleton {
private static final String JAVA_OPTS_CONTAINER_NAME = "samza.container.name";
- private static final String APPLICATION_MASTER_TAG = "samza-application-master";
+ private static final String JOB_COORDINATOR_TAG = "samza-job-coordinator";
private static final String SOURCE = "log4j-log";
private Config config = null;
private SystemStream systemStream = null;
@@ -82,7 +82,7 @@
public void activateOptions() {
String containerName = System.getProperty(JAVA_OPTS_CONTAINER_NAME);
if (containerName != null) {
- isApplicationMaster = containerName.contains(APPLICATION_MASTER_TAG);
+ isApplicationMaster = containerName.contains(JOB_COORDINATOR_TAG);
} else {
throw new SamzaException("Got null container name from system property: " + JAVA_OPTS_CONTAINER_NAME +
". This is used as the key for the log appender, so can't proceed.");
diff --git a/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestStreamAppender.java b/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestStreamAppender.java
index e2e17a0..59669b7 100644
--- a/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestStreamAppender.java
+++ b/samza-log4j/src/test/java/org/apache/samza/logging/log4j/TestStreamAppender.java
@@ -95,7 +95,7 @@
@Test
public void testSystemProducerAppenderInAM() {
- System.setProperty("samza.container.name", "samza-application-master");
+ System.setProperty("samza.container.name", "samza-job-coordinator");
MockSystemProducerAppender systemProducerAppender = new MockSystemProducerAppender();
PatternLayout layout = new PatternLayout();
