You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tubemq.apache.org by go...@apache.org on 2020/12/15 14:08:19 UTC
[incubator-tubemq] branch master updated: [TUBEMQ-453]
TubemqSourceFunction class prints too many logs problem (#350)
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 <19...@qq.com>
AuthorDate: Tue Dec 15 22:08:08 2020 +0800
[TUBEMQ-453] TubemqSourceFunction class prints too many logs problem (#350)
Co-authored-by: 曹显乐 <xi...@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();
}