diff --git a/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java b/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
index df1f8e0..6aad32f 100644
--- a/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
+++ b/azkaban-common/src/test/java/azkaban/executor/InteractiveTestJob.java
@@ -22,12 +22,13 @@ import static org.junit.Assert.assertNotNull;
import azkaban.flow.CommonJobProperties;
import azkaban.jobExecutor.AbstractProcessJob;
import azkaban.utils.Props;
+import java.util.Collection;
import java.util.concurrent.ConcurrentHashMap;
import org.apache.log4j.Logger;
public class InteractiveTestJob extends AbstractProcessJob {
- public static final ConcurrentHashMap<String, InteractiveTestJob> testJobs =
+ private static final ConcurrentHashMap<String, InteractiveTestJob> testJobs =
new ConcurrentHashMap<>();
private Props generatedProperties = new Props();
private boolean isWaiting = true;
@@ -53,6 +54,10 @@ public class InteractiveTestJob extends AbstractProcessJob {
throw new IllegalStateException(name + " wasn't added in testJobs map");
}
+ public static Collection<String> getTestJobNames() {
+ return testJobs.keySet();
+ }
+
public static void clearTestJobs() {
testJobs.clear();
}
diff --git a/azkaban-exec-server/src/test/java/azkaban/execapp/FlowRunnerTestBase.java b/azkaban-exec-server/src/test/java/azkaban/execapp/FlowRunnerTestBase.java
index ffa4970..27775cb 100644
--- a/azkaban-exec-server/src/test/java/azkaban/execapp/FlowRunnerTestBase.java
+++ b/azkaban-exec-server/src/test/java/azkaban/execapp/FlowRunnerTestBase.java
@@ -140,7 +140,7 @@ public class FlowRunnerTestBase {
}
private void printTestJobs() {
- for (final String testJob : InteractiveTestJob.testJobs.keySet()) {
+ for (final String testJob : InteractiveTestJob.getTestJobNames()) {
final ExecutableNode testNode = this.runner.getExecutableFlow()
.getExecutableNodePath(testJob);
System.err.println("testJob: " + testNode.getNestedId() + " " + testNode.getStatus());