This is an automated email from the ASF dual-hosted git repository. lzljs3620320 pushed a commit to branch release-1.3 in repository https://gitbox.apache.org/repos/asf/paimon.git
commit 3d09deb93d45e3b6cdd01d41accf9ddd2bc8afa0 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()) {
