[incubator-seatunnel] branch dev updated: [Bug] [JDBC Source] fix split exception when source table is empty (#4570)

[gaojun2048]

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

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new c73b9331c [Bug] [JDBC Source] fix split exception when source table is 
empty (#4570)
c73b9331c is described below

commit c73b9331ce56db94c529ef672c3f6b19a8cc309f
Author: Laglangyue <35491928+laglang...@users.noreply.github.com>
AuthorDate: Mon Apr 17 18:40:09 2023 +0800

    [Bug] [JDBC Source] fix split exception when source table is empty (#4570)
---
 .../seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java | 4 ++--
 .../connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java   | 3 ++-
 .../connectors/seatunnel/jdbc/source/PartitionParameter.java          | 4 ++--
 3 files changed, 6 insertions(+), 5 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
index e2f8d44ab..ee41f2e85 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java
@@ -155,11 +155,11 @@ public class JdbcSourceFactory implements 
TableSourceFactory {
                 max =
                         config.getPartitionUpperBound().isPresent()
                                 ? config.getPartitionUpperBound().get()
-                                : Long.parseLong(rs.getString(1));
+                                : rs.getLong(1);
                 min =
                         config.getPartitionLowerBound().isPresent()
                                 ? config.getPartitionLowerBound().get()
-                                : Long.parseLong(rs.getString(2));
+                                : rs.getLong(2);
             }
         } catch (SQLException e) {
             throw new PrepareFailException("jdbc", PluginType.SOURCE, 
e.toString());
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
index 13e79f0e1..185f87075 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplitEnumerator.java
@@ -108,7 +108,8 @@ public class JdbcSourceSplitEnumerator
                             : enumeratorContext.currentParallelism();
             JdbcNumericBetweenParametersProvider 
jdbcNumericBetweenParametersProvider =
                     new JdbcNumericBetweenParametersProvider(
-                                    partitionParameter.minValue, 
partitionParameter.maxValue)
+                                    partitionParameter.getMinValue(),
+                                    partitionParameter.getMaxValue())
                             .ofBatchNum(partitionNumber);
             Serializable[][] parameterValues =
                     jdbcNumericBetweenParametersProvider.getParameterValues();
diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/PartitionParameter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/PartitionParameter.java
index c6d55859e..14ba9f864 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/PartitionParameter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/PartitionParameter.java
@@ -27,7 +27,7 @@ import java.io.Serializable;
 public class PartitionParameter implements Serializable {
 
     String partitionColumnName;
-    Long minValue;
-    Long maxValue;
+    long minValue;
+    long maxValue;
     Integer partitionNumber;
 }