This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 39c0fec680 [fix] fix bug when partition_id exceeds integer range in
spark load (#9073)
39c0fec680 is described below
commit 39c0fec6800c98c32354459d325a02943c9f053a
Author: spaces-x <[email protected]>
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: [email protected]
For additional commands, e-mail: [email protected]
