From 78b2bffcb43bf06a94b96ce09e717cf4af476d23 Mon Sep 17 00:00:00 2001 From: Jingsong Date: Tue, 2 Apr 2024 16:38:34 +0800 Subject: [PATCH] minor --- .../org/apache/paimon/flink/lookup/FullCacheLookupTable.java | 2 +- .../apache/paimon/flink/lookup/SecondaryIndexLookupTable.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java index dd5525aaa397..9ed83a9bb457 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FullCacheLookupTable.java @@ -200,7 +200,7 @@ public interface TableBulkLoader { void finish() throws IOException; } - static FullCacheLookupTable create(Context context, long lruCacheSize) throws IOException { + static FullCacheLookupTable create(Context context, long lruCacheSize) { List primaryKeys = context.table.primaryKeys(); if (primaryKeys.isEmpty()) { return new NoPrimaryKeyLookupTable(context, lruCacheSize); diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java index 2cb5f1ce89d2..f551f17ccbc4 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/SecondaryIndexLookupTable.java @@ -38,7 +38,7 @@ public class SecondaryIndexLookupTable extends PrimaryKeyLookupTable { private RocksDBSetState indexState; - public SecondaryIndexLookupTable(Context context, long lruCacheSize) throws IOException { + public SecondaryIndexLookupTable(Context context, long lruCacheSize) { super(context, lruCacheSize / 2, context.table.primaryKeys()); List fieldNames = projectedType.getFieldNames(); int[] secKeyMapping = context.joinKey.stream().mapToInt(fieldNames::indexOf).toArray();