You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kylin.apache.org by ma...@apache.org on 2015/11/17 07:56:08 UTC
incubator-kylin git commit: minor: bug fix
Repository: incubator-kylin
Updated Branches:
refs/heads/2.x-staging 60daf39b3 -> a89dc636f
minor: bug fix
Project: http://git-wip-us.apache.org/repos/asf/incubator-kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-kylin/commit/a89dc636
Tree: http://git-wip-us.apache.org/repos/asf/incubator-kylin/tree/a89dc636
Diff: http://git-wip-us.apache.org/repos/asf/incubator-kylin/diff/a89dc636
Branch: refs/heads/2.x-staging
Commit: a89dc636f7a63922edbab496a8d5b8a22f9e0992
Parents: 60daf39
Author: honma <ho...@ebay.com>
Authored: Tue Nov 17 15:01:00 2015 +0800
Committer: honma <ho...@ebay.com>
Committed: Tue Nov 17 15:01:24 2015 +0800
----------------------------------------------------------------------
.../java/org/apache/kylin/job/streaming/KafkaDataLoader.java | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-kylin/blob/a89dc636/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
----------------------------------------------------------------------
diff --git a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
index 27e3897..4d9c0aa 100644
--- a/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
+++ b/assembly/src/test/java/org/apache/kylin/job/streaming/KafkaDataLoader.java
@@ -10,12 +10,12 @@ import kafka.producer.KeyedMessage;
import kafka.producer.ProducerConfig;
import org.apache.commons.lang.StringUtils;
+import org.apache.kylin.source.kafka.config.BrokerConfig;
+import org.apache.kylin.source.kafka.config.KafkaClusterConfig;
import com.google.common.base.Function;
import com.google.common.collect.Collections2;
import com.google.common.collect.Lists;
-import org.apache.kylin.source.kafka.config.BrokerConfig;
-import org.apache.kylin.source.kafka.config.KafkaClusterConfig;
/**
* Load prepared data into kafka(for test use)
@@ -36,7 +36,7 @@ public class KafkaDataLoader {
props.put("metadata.broker.list", brokerList);
props.put("serializer.class", "kafka.serializer.StringEncoder");
props.put("request.required.acks", "1");
- props.put("retry.backoff.ms",1000);
+ props.put("retry.backoff.ms", "1000");
ProducerConfig config = new ProducerConfig(props);