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:27 UTC
[rocketmq-connect] 19/43: Update Querier.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 e72688b6be2103d02ac7fe9313bdd786dc0c7c5f
Author: Yuchen Li <yu...@126.com>
AuthorDate: Fri Aug 16 14:20:54 2019 +0800
Update Querier.java
---
src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java | 2 --
1 file changed, 2 deletions(-)
diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java b/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
index 0907d40..13cbda5 100644
--- a/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
+++ b/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java
@@ -144,8 +144,6 @@ public class Querier {
Connection conn = dataSource.getConnection();
for (Map.Entry<String, Database> entry : schema.dbMap.entrySet()) {
String db = entry.getKey();
- if (!db.contains("jdbc_db"))
- continue;
Iterator<Map.Entry<String, Table>> iterator = entry.getValue().tableMap.entrySet().iterator();
while (iterator.hasNext()) {
Map.Entry<String, Table> tableEntry = iterator.next();