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 <[email protected]> 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); } }
