From 6521a5fc3c616e0ba7318aad644fff973b81690e Mon Sep 17 00:00:00 2001 From: yuzelin Date: Mon, 6 Jan 2025 18:04:42 +0800 Subject: [PATCH] fix comment --- .../apache/paimon/flink/lookup/FileStoreLookupFunction.java | 5 ----- 1 file changed, 5 deletions(-) diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java index bdd493c3f586..2f3ec62bbc58 100644 --- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java +++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java @@ -166,11 +166,6 @@ private void open() throws Exception { LOG.info("Creating lookup table for {}.", table.name()); if (options.get(LOOKUP_CACHE_MODE) == LookupCacheMode.AUTO && new HashSet<>(table.primaryKeys()).equals(new HashSet<>(joinKeys))) { - String message = - String.format( - "{}={} and primary keys equal to join keys, trying to create PrimaryKeyPartialLookupTable.", - LOOKUP_CACHE_MODE.key(), - LookupCacheMode.AUTO); if (isRemoteServiceAvailable(storeTable)) { this.lookupTable = PrimaryKeyPartialLookupTable.createRemoteTable(