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 db7644ae06f9edef81098c699cbd070a7989b282 Author: Yuchen Li <[email protected]> AuthorDate: Mon Sep 9 19:45:33 2019 +0800 Update JdbcSourceTask.java --- .../apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java | 9 +++------ 1 file changed, 3 insertions(+), 6 deletions(-) diff --git a/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java b/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java index e01c226..767c3aa 100644 --- a/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java +++ b/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java @@ -118,12 +118,9 @@ public class JdbcSourceTask extends SourceTask { @Override public void start(KeyValue props) { - try { - config = new Config(); - config.load(props); - } catch (Exception e) { - log.error("Cannot start Jdbc Source Task because of configuration error{}", e); - } + config = new Config(); + config.load(props); + Map<Map<String, String>, Map<String, Object>> offsets = null; String mode = config.mode; if (mode.equals("bulk")) {
