Skip to content

Commit 3b415a2

Browse files
committed
add test
1 parent 7de5bd6 commit 3b415a2

File tree

1 file changed

+14
-0
lines changed

1 file changed

+14
-0
lines changed

fluss-flink/fluss-flink-common/src/test/java/org/apache/fluss/flink/catalog/FlinkCatalogITCase.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -818,6 +818,20 @@ void testCreateCatalogWithUnexistedDatabase() {
818818
"The configured default-database 'non-exist' does not exist in the Fluss cluster.");
819819
}
820820

821+
@Test
822+
void testCreateCatalogWithLakeProperties() {
823+
Map<String, String> properties = new HashMap<>();
824+
properties.put("paimon.jdbc.password", "pass");
825+
tEnv.executeSql(
826+
String.format(
827+
"create catalog test_catalog_with_lake_properties with ('type' = 'fluss', '%s' = '%s', 'paimon.jdbc.password' = 'pass')",
828+
BOOTSTRAP_SERVERS.key(), FLUSS_CLUSTER_EXTENSION.getBootstrapServers()));
829+
FlinkCatalog catalog =
830+
(FlinkCatalog) tEnv.getCatalog("test_catalog_with_lake_properties").get();
831+
832+
assertOptionsEqual(catalog.getLakeCatalogProperties().get(), properties);
833+
}
834+
821835
/**
822836
* Before Flink 2.1, the {@link Schema} did not include an index field. Starting from Flink 2.1,
823837
* Flink introduced the concept of an index, and in Fluss, the primary key is considered as an

0 commit comments

Comments
 (0)