[rocketmq-connect] 15/43: Update Querier.java

[zhoubo]

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 <yuchenlich...@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();