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:32 UTC
[rocketmq-connect] 24/43: Update JdbcSourceTask.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 db7644ae06f9edef81098c699cbd070a7989b282
Author: Yuchen Li <yu...@126.com>
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")) {