minor fix

625a5418 · nishantmonu51 · 1ca61237 · 625a5418
隐藏空白更改
内联并排

Showing with 1 addition and 1 deletion

indexing-hadoop/src/main/java/io/druid/indexer/DetermineHashedPartitionsJob.java ...n/java/io/druid/indexer/DetermineHashedPartitionsJob.java +1 -1

未找到文件。
--- a/indexing-hadoop/src/main/java/io/druid/indexer/DetermineHashedPartitionsJob.java
+++ b/indexing-hadoop/src/main/java/io/druid/indexer/DetermineHashedPartitionsJob.java
@@ -348,7 +348,7 @@ public class DetermineHashedPartitionsJob implements Jobby
    {

      if (config.get("mapred.job.tracker").equals("local") || determineIntervals) {
-        return 1;
+        return 0;
      } else {
        return reducerLookup.get(interval);
      }