(fluss) branch main updated: [hotfix] Make lake catalog as projected (#1823)

[mehulbatra]

This is an automated email from the ASF dual-hosted git repository.

mehulbatra pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 9e27398da [hotfix] Make lake catalog as projected (#1823)
9e27398da is described below

commit 9e27398da74b11f516bc4035c07ea62201bbc95c
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Fri Oct 17 17:07:00 2025 +0800

    [hotfix] Make lake catalog as projected (#1823)
---
 .../src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java      | 2 +-
 .../src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
index 7e10c4a5c..0627e3f68 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java
@@ -114,7 +114,7 @@ public class FlinkCatalog extends AbstractCatalog {
     protected final String defaultDatabase;
     protected final String bootstrapServers;
     protected final Map<String, String> securityConfigs;
-    private final LakeFlinkCatalog lakeFlinkCatalog;
+    protected final LakeFlinkCatalog lakeFlinkCatalog;
     protected Connection connection;
     protected Admin admin;
 
diff --git 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java
 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java
index 57ead2c9e..d90b14164 100644
--- 
a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java
+++ 
b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java
@@ -69,7 +69,7 @@ import static 
org.apache.fluss.flink.utils.FlinkConversions.toFlinkOption;
 /** Factory to create table source and table sink for Fluss. */
 public class FlinkTableFactory implements DynamicTableSourceFactory, 
DynamicTableSinkFactory {
 
-    private final LakeFlinkCatalog lakeFlinkCatalog;
+    protected final LakeFlinkCatalog lakeFlinkCatalog;
     private volatile LakeTableFactory lakeTableFactory;
 
     public FlinkTableFactory(LakeFlinkCatalog lakeFlinkCatalog) {