This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 4849ff5b56352b0782c24d314362e6e78a0cc252 Author: Yuchen Li <[email protected]> AuthorDate: Fri Aug 16 14:19:49 2019 +0800 Update TimestampIncrementingQuerier.java --- .../rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java | 2 -- 1 file changed, 2 deletions(-) diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java b/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java index 1dadc4f..3201456 100644 --- a/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java +++ b/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java @@ -221,8 +221,6 @@ public class TimestampIncrementingQuerier extends Querier { Connection conn = dataSource.getConnection(); for (Map.Entry<String, Database> entry : schema.dbMap.entrySet()) { String db = entry.getKey(); - if (!db.contains("time_db")) - continue; log.info("{} database is loading", db); Iterator<Map.Entry<String, Table>> iterator = entry.getValue().tableMap.entrySet().iterator(); while (iterator.hasNext()) {
