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:23 UTC
[rocketmq-connect] 15/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 d0569b7e91ee784d53ef6e4f723a1ab0f02453d8
Author: Yuchen Li <yu...@126.com>
AuthorDate: Fri Aug 9 13:49:37 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 3d5b2c6..073a896 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
@@ -120,8 +120,6 @@ public class Querier {
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();