Minor, remove duplicate code

chenzhx · Jun 5, 2019 · 745842b · 745842b
1 parent c3a7110
commit 745842b
Showing 1 changed file with 0 additions and 1 deletion.
diff --git a/source-kafka/src/main/java/org/apache/kylin/source/kafka/hadoop/KafkaFlatTableJob.java b/source-kafka/src/main/java/org/apache/kylin/source/kafka/hadoop/KafkaFlatTableJob.java
@@ -158,7 +158,6 @@ private void setupMapper(CubeSegment cubeSeg) throws IOException {
         job.setOutputKeyClass(BytesWritable.class);
         job.setOutputValueClass(Text.class);
         job.setOutputFormatClass(SequenceFileOutputFormat.class);
-        job.setNumReduceTasks(0);
     }
 
     private static void appendKafkaOverrideProperties(final KylinConfig kylinConfig, Configuration conf) {