Skip to content

Commit 0a503e4

Browse files
authored
[Fix-3862][cdc] Fix not specifying it will result in a null pointer exception when starting the job (#4418)
1 parent 35deca4 commit 0a503e4

1 file changed

Lines changed: 5 additions & 1 deletion

File tree

dinky-core/src/main/java/org/dinky/trans/ddl/CreateCDCSourceOperation.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -226,7 +226,11 @@ private Driver checkAndCreateSinkSchema(FlinkCDCConfig config, String schemaName
226226
return null;
227227
}
228228
String url = sink.get("url");
229-
String schema = SqlUtil.replaceAllParam(sink.get(FlinkCDCConfig.SINK_DB), "schemaName", schemaName);
229+
String schema = schemaName;
230+
String sinkDb = sink.get(FlinkCDCConfig.SINK_DB);
231+
if (Asserts.isNotNullString(sinkDb)) {
232+
schema = SqlUtil.replaceAllParam(sinkDb, "schemaName", schemaName);
233+
}
230234
Driver driver = Driver.build(sink.get("connector"), url, sink.get("username"), sink.get("password"));
231235
if (null != driver && !driver.existSchema(schema)) {
232236
driver.createSchema(schema);

0 commit comments

Comments
 (0)