private static Map<String, String> retrieveFlinkProperties(
            Map<String, String> hiveTableParams) {
        return hiveTableParams.entrySet().stream()
                .filter(e -> e.getKey().startsWith(FLINK_PROPERTY_PREFIX))
                .collect(
                        Collectors.toMap(
                                e -> e.getKey().substring(FLINK_PROPERTY_PREFIX.length()),
                                e -> e.getValue()));
    }
@Test
    public void testRetrieveFlinkProperties() throws Exception {
        ObjectPath hiveObjectPath =
                new ObjectPath(HiveCatalog.DEFAULT_DB, "testRetrieveProperties");

        Map<String, String> options = getLegacyFileSystemConnectorOptions("/test_path");
        options.put(CONNECTOR.key(), "jdbc");
        options.put("url", "jdbc:clickhouse://host:port/testUrl1");
        options.put("flink.url", "jdbc:clickhouse://host:port/testUrl2");

        hiveCatalog.createTable(
                hiveObjectPath,
                new ResolvedCatalogTable(
                        CatalogTable.of(schema, null, new ArrayList<>(), options), resolvedSchema),
                false);

        CatalogBaseTable hiveTable = hiveCatalog.getTable(hiveObjectPath);
        assertThat(hiveTable.getOptions())
                .containsEntry("url", "jdbc:clickhouse://host:port/testUrl1");
        assertThat(hiveTable.getOptions())
                .containsEntry("flink.url", "jdbc:clickhouse://host:port/testUrl2");
    }