[incubator-tubemq] branch master updated: [TUBEMQ-453] TubemqSourceFunction class prints too many logs problem (#350)

[gosonzhang]

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

gosonzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git


The following commit(s) were added to refs/heads/master by this push:
     new 0467734  [TUBEMQ-453] TubemqSourceFunction class prints too many logs 
problem (#350)
0467734 is described below

commit 0467734fcab7f04d73b9b728456f2a8820d2fb53
Author: leno1001 <1960700...@qq.com>
AuthorDate: Tue Dec 15 22:08:08 2020 +0800

    [TUBEMQ-453] TubemqSourceFunction class prints too many logs problem (#350)
    
    Co-authored-by: 曹显乐 <xianle....@vivo.com>
---
 .../java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java
 
b/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java
index c93e057..33c498e 100644
--- 
a/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java
+++ 
b/tubemq-connectors/tubemq-connector-flink/src/main/java/org/apache/flink/connectors/tubemq/TubemqSourceFunction.java
@@ -264,7 +264,6 @@ public class TubemqSourceFunction<T>
                 Duration idleTime =
                     Duration.between(lastConsumeInstant, Instant.now());
                 if (idleTime.compareTo(maxIdleTime) > 0) {
-                    LOG.info("Mark this source as temporarily idle.");
                     ctx.markAsTemporarilyIdle();
                 }