[rocketmq-connect] 05/43: Update JdbcSourceConnector.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 675099dc7f85460317aa60031039132d4fabec09
Author: Yuchen Li <yuchenlich...@126.com>
AuthorDate: Fri Jul 19 14:22:14 2019 +0800

    Update JdbcSourceConnector.java
---
 .../apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
 
b/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
index d6b0e3b..8a6047c 100644
--- 
a/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
+++ 
b/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
@@ -36,16 +36,13 @@ public class JdbcSourceConnector extends SourceConnector {
 
     @Override
     public String verifyAndSetConfig(KeyValue config) {
-        System.out.println(11+config.toString());
         log.info("JdbcSourceConnector verifyAndSetConfig enter");
         for (String requestKey : Config.REQUEST_CONFIG) {
-            System.out.println(12+requestKey);
             if (!config.containsKey(requestKey)) {
                 return "Request config key: " + requestKey;
             }
         }
         this.config = config;
-        System.out.println(11+config.toString());
         return "";
     }
 
@@ -78,6 +75,5 @@ public class JdbcSourceConnector extends SourceConnector {
         config.add(this.config);
         return config;
     }
-    
-   // abstract Set<String> getRequiredConfig();
+
 }