[kylin] branch 2.6.x updated: Minor, remove duplicate code

[nic]

This is an automated email from the ASF dual-hosted git repository.

nic pushed a commit to branch 2.6.x
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/2.6.x by this push:
     new f346884  Minor, remove duplicate code
f346884 is described below

commit f3468845047bca4c873a09567aeb2b9072eb79d5
Author: chao long <wayn...@qq.com>
AuthorDate: Wed Jun 5 16:57:25 2019 +0800

    Minor, remove duplicate code
---
 .../java/org/apache/kylin/source/kafka/hadoop/KafkaFlatTableJob.java     | 1 -
 1 file changed, 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
index e106a0a..2ac4692 100644
--- 
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 @@ public class KafkaFlatTableJob extends AbstractHadoopJob {
         job.setOutputKeyClass(BytesWritable.class);
         job.setOutputValueClass(Text.class);
         job.setOutputFormatClass(SequenceFileOutputFormat.class);
-        job.setNumReduceTasks(0);
     }
 
     private static void appendKafkaOverrideProperties(final KylinConfig 
kylinConfig, Configuration conf) {