comment

some comment
apache · Apr 1, 2017 · 48433aa · 48433aa
1 parent d1526d4
commit 48433aa
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/.../hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/SerializableConfiguration.java b/.../hadoop-common/src/main/java/org/apache/beam/sdk/io/hadoop/SerializableConfiguration.java
@@ -74,6 +74,7 @@ public static Job newJob(@Nullable SerializableConfiguration conf) throws IOExce
     if (conf == null) {
       return Job.getInstance();
     } else {
+      // Don't reading configuration from slave thread, but only from master thread.
       Job job = Job.getInstance(new Configuration(false));
       for (Map.Entry<String, String> entry : conf.get()) {
         job.getConfiguration().set(entry.getKey(), entry.getValue());