kylin-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From liy...@apache.org
Subject [02/23] kylin git commit: minor, update default kafka consumer session.timeout to 10 seconds and request.timeout to 20 seconds
Date Mon, 18 Sep 2017 03:36:00 GMT
minor, update default kafka consumer session.timeout to 10 seconds and request.timeout to 20
seconds


Project: http://git-wip-us.apache.org/repos/asf/kylin/repo
Commit: http://git-wip-us.apache.org/repos/asf/kylin/commit/22c86ace
Tree: http://git-wip-us.apache.org/repos/asf/kylin/tree/22c86ace
Diff: http://git-wip-us.apache.org/repos/asf/kylin/diff/22c86ace

Branch: refs/heads/master
Commit: 22c86acef1829d17dc0fab23ef4dbb9a16c2ede5
Parents: bfe9c52
Author: Billy Liu <billyliu@apache.org>
Authored: Sun Sep 10 00:10:13 2017 +0800
Committer: 成 <cheng.wang@kyligence.io>
Committed: Sun Sep 10 19:18:01 2017 +0800

----------------------------------------------------------------------
 build/conf/kylin-kafka-consumer.xml                            | 6 +++++-
 examples/test_case_data/localmeta/kylin-kafka-consumer.xml     | 6 +++++-
 examples/test_case_data/sandbox/kylin-kafka-consumer.xml       | 6 +++++-
 .../kylin/source/kafka/config/KafkaConsumerPropertiesTest.java | 6 +++---
 4 files changed, 18 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kylin/blob/22c86ace/build/conf/kylin-kafka-consumer.xml
----------------------------------------------------------------------
diff --git a/build/conf/kylin-kafka-consumer.xml b/build/conf/kylin-kafka-consumer.xml
index 6da7004..8529a41 100644
--- a/build/conf/kylin-kafka-consumer.xml
+++ b/build/conf/kylin-kafka-consumer.xml
@@ -22,6 +22,10 @@
 <configuration>
     <property>
         <name>session.timeout.ms</name>
-        <value>30000</value>
+        <value>10000</value>
+    </property>
+    <property>
+        <name>request.timeout.ms</name>
+        <value>20000</value>
     </property>
 </configuration>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/kylin/blob/22c86ace/examples/test_case_data/localmeta/kylin-kafka-consumer.xml
----------------------------------------------------------------------
diff --git a/examples/test_case_data/localmeta/kylin-kafka-consumer.xml b/examples/test_case_data/localmeta/kylin-kafka-consumer.xml
index 6da7004..8529a41 100644
--- a/examples/test_case_data/localmeta/kylin-kafka-consumer.xml
+++ b/examples/test_case_data/localmeta/kylin-kafka-consumer.xml
@@ -22,6 +22,10 @@
 <configuration>
     <property>
         <name>session.timeout.ms</name>
-        <value>30000</value>
+        <value>10000</value>
+    </property>
+    <property>
+        <name>request.timeout.ms</name>
+        <value>20000</value>
     </property>
 </configuration>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/kylin/blob/22c86ace/examples/test_case_data/sandbox/kylin-kafka-consumer.xml
----------------------------------------------------------------------
diff --git a/examples/test_case_data/sandbox/kylin-kafka-consumer.xml b/examples/test_case_data/sandbox/kylin-kafka-consumer.xml
index 6da7004..8529a41 100644
--- a/examples/test_case_data/sandbox/kylin-kafka-consumer.xml
+++ b/examples/test_case_data/sandbox/kylin-kafka-consumer.xml
@@ -22,6 +22,10 @@
 <configuration>
     <property>
         <name>session.timeout.ms</name>
-        <value>30000</value>
+        <value>10000</value>
+    </property>
+    <property>
+        <name>request.timeout.ms</name>
+        <value>20000</value>
     </property>
 </configuration>
\ No newline at end of file

http://git-wip-us.apache.org/repos/asf/kylin/blob/22c86ace/source-kafka/src/test/java/org/apache/kylin/source/kafka/config/KafkaConsumerPropertiesTest.java
----------------------------------------------------------------------
diff --git a/source-kafka/src/test/java/org/apache/kylin/source/kafka/config/KafkaConsumerPropertiesTest.java
b/source-kafka/src/test/java/org/apache/kylin/source/kafka/config/KafkaConsumerPropertiesTest.java
index 208fdb6..75cfc2d 100644
--- a/source-kafka/src/test/java/org/apache/kylin/source/kafka/config/KafkaConsumerPropertiesTest.java
+++ b/source-kafka/src/test/java/org/apache/kylin/source/kafka/config/KafkaConsumerPropertiesTest.java
@@ -52,7 +52,7 @@ public class KafkaConsumerPropertiesTest extends LocalFileMetadataTestCase
{
         KafkaConsumerProperties kafkaConsumerProperties = KafkaConsumerProperties.getInstanceFromEnv();
         assertFalse(kafkaConsumerProperties.extractKafkaConfigToProperties().containsKey("acks"));
         assertTrue(kafkaConsumerProperties.extractKafkaConfigToProperties().containsKey("session.timeout.ms"));
-        assertEquals("30000", kafkaConsumerProperties.extractKafkaConfigToProperties().getProperty("session.timeout.ms"));
+        assertEquals("10000", kafkaConsumerProperties.extractKafkaConfigToProperties().getProperty("session.timeout.ms"));
     }
 
     @Test
@@ -60,9 +60,9 @@ public class KafkaConsumerPropertiesTest extends LocalFileMetadataTestCase
{
         KafkaConsumerProperties kafkaConsumerProperties = KafkaConsumerProperties.getInstanceFromEnv();
         Configuration conf = new Configuration(false);
         conf.addResource(new FileInputStream(new File(kafkaConsumerProperties.getKafkaConsumerHadoopJobConf())),
KafkaConsumerProperties.KAFKA_CONSUMER_FILE);
-        assertEquals("30000", conf.get("session.timeout.ms"));
+        assertEquals("10000", conf.get("session.timeout.ms"));
 
         Properties prop = KafkaConsumerProperties.extractKafkaConfigToProperties(conf);
-        assertEquals("30000", prop.getProperty("session.timeout.ms"));
+        assertEquals("10000", prop.getProperty("session.timeout.ms"));
     }
 }


Mime
View raw message