From df0223f0285dffc484de92595102f5f77b4f1386 Mon Sep 17 00:00:00 2001
From: zhangkai <1024702151@qq.com>
Date: Wed, 16 Jul 2025 18:56:59 +0800
Subject: [PATCH] fix: fixed bucket table insert error
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

When a table is configured with a fixed number of buckets, an exception will occur when insert data：
io.trino.spi.Page: blocks out of bounds
---
 .../apache/paimon/trino/FixedBucketTableShuffleFunction.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java b/src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java
index 839ad0c..534917e 100644
--- a/src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java
+++ b/src/main/java/org/apache/paimon/trino/FixedBucketTableShuffleFunction.java
@@ -55,7 +55,7 @@ public FixedBucketTableShuffleFunction(
                 ThreadLocal.withInitial(
                         () ->
                                 CodeGenUtils.newProjection(
-                                        schema.logicalPrimaryKeysType(), schema.primaryKeys()));
+                                        schema.logicalBucketKeyType(), schema.bucketKeys()));
         this.bucketCount = new CoreOptions(schema.options()).bucket();
         this.workerCount = workerCount;
         this.isRowId =