fix comments

apache · Jan 6, 2025 · 836ee69 · 836ee69
1 parent 179f04d
commit 836ee69
Showing 1 changed file with 10 additions and 0 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
@@ -168,6 +168,9 @@ private void open() throws Exception {
                 this.lookupTable =
                         PrimaryKeyPartialLookupTable.createRemoteTable(
                                 storeTable, projection, joinKeys);
+                LOG.info(
+                        "Created lookup table for {}. Type is PrimaryKeyPartialLookupTable with remote service.",
+                        table.name());
             } else {
                 try {
                     this.lookupTable =
@@ -177,6 +180,9 @@ private void open() throws Exception {
                                     path,
                                     joinKeys,
                                     getRequireCachedBucketIds());
+                    LOG.info(
+                            "Created lookup table for {}. Type is PrimaryKeyPartialLookupTable with LocalQueryExecutor.",
+                            table.name());
                 } catch (UnsupportedOperationException ignore2) {
                 }
             }
@@ -193,6 +199,10 @@ private void open() throws Exception {
                             joinKeys,
                             getRequireCachedBucketIds());
             this.lookupTable = FullCacheLookupTable.create(context, options.get(LOOKUP_CACHE_ROWS));
+            LOG.info(
+                    "Created lookup table for {}. Type is {}.",
+                    table.name(),
+                    lookupTable.getClass().getSimpleName());
         }
 
         if (partitionLoader != null) {