[incubator-doris] 03/03: [fix] fix bug when partition_id exceeds integer range in spark load (#9073)

[morningman]

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

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

commit 1c5f7dade1b8c04275f2d1b9e8372a546fdc4b85
Author: spaces-x <weixiao5...@gmail.com>
AuthorDate: Wed Apr 20 14:50:55 2022 +0800

    [fix] fix bug when partition_id exceeds integer range in spark load (#9073)
---
 .../src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/fe/spark-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java 
b/fe/spark-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java
index 8b34957da7..f94a82700b 100644
--- a/fe/spark-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java
+++ b/fe/spark-dpp/src/main/java/org/apache/doris/load/loadv2/dpp/SparkDpp.java
@@ -248,7 +248,7 @@ public final class SparkDpp implements java.io.Serializable 
{
                             LOG.warn("invalid bucket key:" + curBucketKey);
                             continue;
                         }
-                        int partitionId = Integer.parseInt(bucketKey[0]);
+                        long partitionId = Long.parseLong(bucketKey[0]);
                         int bucketId = Integer.parseInt(bucketKey[1]);
                         dstPath = String.format(pathPattern, tableId, 
partitionId, indexMeta.indexId,
                                 bucketId, indexMeta.schemaHash);


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org