@ -29,7 +29,7 @@ limitations under the License.
<artifactId>flink-cdc-pipeline-connector-paimon</artifactId>
<properties>
<paimon.version>0.9.0</paimon.version>
<paimon.version>1.0.0</paimon.version>
<hadoop.version>2.8.5</hadoop.version>
<hive.version>2.3.9</hive.version>
<mockito.version>3.4.6</mockito.version>
@ -150,7 +150,7 @@ public class PaimonMetadataApplier implements MetadataApplier {
private void applyCreateTable(CreateTableEvent event) throws SchemaEvolveException {
try {
if (!catalog.databaseExists(event.tableId().getSchemaName())) {
if (!catalog.listDatabases().contains(event.tableId().getSchemaName())) {
catalog.createDatabase(event.tableId().getSchemaName(), true);
}
Schema schema = event.getSchema();
@ -34,7 +34,7 @@ limitations under the License.
<flink-major-1.20>1.20</flink-major-1.20>
<mysql.driver.version>8.0.27</mysql.driver.version>
<starrocks.connector.version>1.2.10_flink-${flink.major.version}</starrocks.connector.version>
</properties>
<dependencies>