This is an automated email from the ASF dual-hosted git repository. yuanbo pushed a commit to branch TUBEMQ-421 in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git
commit 3b6d610035952a9e10cfedee35bd4d5a182ac81e Author: leno1001 <[email protected]> AuthorDate: Tue Dec 15 22:08:08 2020 +0800 [TUBEMQ-453] TubemqSourceFunction class prints too many logs problem (#350) Co-authored-by: 曹显乐 <[email protected]> --- .../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(); }
