[kylin] branch 2.6.x updated: KYLIN-3793 KafkaSampleProducer exit after generating 1 message

[shaofengshi]

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

shaofengshi 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 ed312ea  KYLIN-3793 KafkaSampleProducer exit after generating 1 message
ed312ea is described below

commit ed312ea21dfdb4b00c877acb649ea4481044988b
Author: shaofengshi <shaofeng...@apache.org>
AuthorDate: Mon Jan 28 20:30:30 2019 +0800

    KYLIN-3793 KafkaSampleProducer exit after generating 1 message
---
 .../java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java
 
b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java
index 51e8ff3..750d2f0 100644
--- 
a/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java
+++ 
b/source-kafka/src/main/java/org/apache/kylin/source/kafka/util/KafkaSampleProducer.java
@@ -135,7 +135,7 @@ public class KafkaSampleProducer {
                 if(logger.isInfoEnabled()) logger.info("Sending 1 message: 
{}", JsonUtil.writeValueAsString(record));
                 producer.send(data);
                 Thread.sleep(interval);
-                if(System.currentTimeMillis() - startTime <= 7 * 24 * 3600 * 
1000){
+                if(System.currentTimeMillis() - startTime >= 7 * 24 * 3600 * 
1000){
                     alive = false;
                 }
             }