This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git
The following commit(s) were added to refs/heads/master by this push:
new 1bbf321896 [hotfix] Add more informat to check partition spec in
InternalRowPartitionComputer
1bbf321896 is described below
commit 1bbf3218960a4986b863457971a4009780ae6892
Author: JingsongLi <[email protected]>
AuthorDate: Mon Nov 3 22:09:00 2025 +0800
[hotfix] Add more informat to check partition spec in
InternalRowPartitionComputer
---
.../java/org/apache/paimon/utils/InternalRowPartitionComputer.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git
a/paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java
b/paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java
index edefce3189..0f207aaa64 100644
---
a/paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java
+++
b/paimon-common/src/main/java/org/apache/paimon/utils/InternalRowPartitionComputer.java
@@ -107,7 +107,11 @@ public class InternalRowPartitionComputer {
public static GenericRow convertSpecToInternalRow(
Map<String, String> spec, RowType partType, String
defaultPartValue) {
- checkArgument(spec.size() == partType.getFieldCount());
+ checkArgument(
+ spec.size() == partType.getFieldCount(),
+ "Partition spec size %s not match partition field count %s",
+ spec.size(),
+ partType.getFieldCount());
GenericRow partRow = new GenericRow(spec.size());
List<String> fieldNames = partType.getFieldNames();
for (Map.Entry<String, String> entry : spec.entrySet()) {