You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ni...@apache.org on 2019/06/25 05:50:33 UTC
[kylin] branch 2.6.x updated: Minor, remove duplicate code
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 <wa...@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) {