fix comment

apache · Jan 6, 2025 · 6521a5f · 6521a5f
1 parent 45f9324
commit 6521a5f
Showing 1 changed file with 0 additions and 5 deletions.
diff --git a/...on-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java b/...on-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(