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(