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:31 UTC
[rocketmq-connect] 23/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 5457c06de05510322c0d8e6f25b8216b600513e1
Author: Yuchen Li <yu...@126.com>
AuthorDate: Mon Sep 9 19:27:45 2019 +0800
Update JdbcSourceTask.java
---
.../org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java | 4 ++--
1 file changed, 2 insertions(+), 2 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 45252bb..e01c226 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
@@ -134,7 +134,7 @@ public class JdbcSourceTask extends SourceTask {
tableQueue.add(querier);
} catch (Exception e) {
// TODO Auto-generated catch block
- e.printStackTrace();
+ log.error("Start unsuccessfully Because of {}",e);
}
} else {
TimestampIncrementingQuerier querier = new TimestampIncrementingQuerier();
@@ -144,7 +144,7 @@ public class JdbcSourceTask extends SourceTask {
tableQueue.add(querier);
} catch (Exception e) {
// TODO Auto-generated catch block
- e.printStackTrace();
+ log.error("Start unsuccessfully Because of {}",e);
}
}