[rocketmq-connect] branch master updated: [ISSUE #268] upgrade mysql-connector-java version to 8.0.30 and fix NPE (#280)

[dinglei]

This is an automated email from the ASF dual-hosted git repository.

dinglei pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new 999196d  [ISSUE #268] upgrade mysql-connector-java version to 8.0.30 
and fix NPE (#280)
999196d is described below

commit 999196dd620fc0348d565cc70cb19bfdf856d4b6
Author: Oliver <wqdyx...@163.com>
AuthorDate: Wed Aug 24 16:53:44 2022 +0800

    [ISSUE #268] upgrade mysql-connector-java version to 8.0.30 and fix NPE 
(#280)
---
 connectors/rocketmq-connect-jdbc/pom.xml                               | 2 +-
 .../connect/jdbc/source/offset/TimestampIncrementingOffset.java        | 3 ++-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/connectors/rocketmq-connect-jdbc/pom.xml 
b/connectors/rocketmq-connect-jdbc/pom.xml
index a4face9..1efb087 100644
--- a/connectors/rocketmq-connect-jdbc/pom.xml
+++ b/connectors/rocketmq-connect-jdbc/pom.xml
@@ -162,7 +162,7 @@
         <dependency>
             <groupId>mysql</groupId>
             <artifactId>mysql-connector-java</artifactId>
-            <version>8.0.16</version>
+            <version>8.0.30</version>
         </dependency>
 
         <dependency>
diff --git 
a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java
 
b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java
index d843b50..0dab7af 100644
--- 
a/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java
+++ 
b/connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java
@@ -66,7 +66,8 @@ public class TimestampIncrementingOffset {
             return new TimestampIncrementingOffset(null, null);
         }
 
-        Long incr = Long.valueOf(map.get(INCREMENTING_FIELD).toString());
+        final Object increment = map.get(INCREMENTING_FIELD);
+        Long incr = increment == null ? 0 : Long.valueOf(increment.toString());
         Long millis = (Long) map.get(TIMESTAMP_FIELD);
         Timestamp ts = null;
         if (millis != null) {