Skip to content

Commit 9e5e047

Browse files
committed
change to new Name for DescriptorsMeta
1 parent 71adc0c commit 9e5e047

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

tis-incr/tis-incr-test/src/main/java/com/qlangtech/plugins/incr/flink/chunjun/doris/sink/TestFlinkSinkExecutor.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -415,7 +415,7 @@ public IMQListener create() {
415415
CreateTableSqlBuilder.CreateDDL createDDL = null;
416416
if (!dataXWriter.isGenerateCreateDDLSwitchOff()) {
417417
createDDL = dataXWriter.generateCreateDDL(
418-
SourceColMetaGetter.getNone(), new IDataxProcessor.TableMap(totalpayInfo), Optional.empty());
418+
SourceColMetaGetter.getNone(), new IDataxProcessor.TableMap(Optional.empty(),totalpayInfo), Optional.empty());
419419
Assert.assertNotNull("createDDL can not be empty", createDDL);
420420
// log.info("create table ddl:\n{}", createDDL);
421421
FileUtils.write(new File(ddlDir, tabSql), createDDL.getDDLScript(), TisUTF8.get());

0 commit comments

Comments
 (0)