[ https://issues.apache.org/jira/browse/TUBEMQ-453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Guocheng Zhang resolved TUBEMQ-453. ----------------------------------- Fix Version/s: 0.8.0 Resolution: Fixed > TubemqSourceFunction class prints too many logs problem > ------------------------------------------------------- > > Key: TUBEMQ-453 > URL: https://issues.apache.org/jira/browse/TUBEMQ-453 > Project: Apache TubeMQ > Issue Type: Bug > Reporter: xianle cao > Assignee: xianle cao > Priority: Major > Fix For: 0.8.0 > > > module: > tubemq-connector-flink > class: > TubemqSourceFunction > > ``` > Instant lastConsumeInstant = Instant.now(); > while (running) { > ConsumerResult consumeResult = messagePullConsumer.getMessage(); > if (!consumeResult.isSuccess()) { > ... > Duration idleTime = > Duration.between(lastConsumeInstant, Instant.now()); > if (idleTime.compareTo(maxIdleTime) > 0) { > LOG.info("Mark this source as temporarily idle."); > ctx.markAsTemporarilyIdle(); > } > continue; > } > ... > } > possible problems: > print too much log content: Mark this source as temporarily idle. > possible solution: > remove the log and print this line of code -- This message was sent by Atlassian Jira (v8.3.4#803005)