Skip to content

Commit 9e27398

Browse files
authored
[hotfix] Make lake catalog as projected (apache#1823)
1 parent 97bd2eb commit 9e27398

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkCatalog.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -114,7 +114,7 @@ public class FlinkCatalog extends AbstractCatalog {
114114
protected final String defaultDatabase;
115115
protected final String bootstrapServers;
116116
protected final Map<String, String> securityConfigs;
117-
private final LakeFlinkCatalog lakeFlinkCatalog;
117+
protected final LakeFlinkCatalog lakeFlinkCatalog;
118118
protected Connection connection;
119119
protected Admin admin;
120120

fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/catalog/FlinkTableFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -69,7 +69,7 @@
6969
/** Factory to create table source and table sink for Fluss. */
7070
public class FlinkTableFactory implements DynamicTableSourceFactory, DynamicTableSinkFactory {
7171

72-
private final LakeFlinkCatalog lakeFlinkCatalog;
72+
protected final LakeFlinkCatalog lakeFlinkCatalog;
7373
private volatile LakeTableFactory lakeTableFactory;
7474

7575
public FlinkTableFactory(LakeFlinkCatalog lakeFlinkCatalog) {

0 commit comments

Comments
 (0)