You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 03:20:26 UTC
[rocketmq-connect] 18/43: Update TimestampIncrementingQuerier.java
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 <yu...@126.com>
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()) {