modify createFlinkOptions() to createOptions()

baisui1981 · baisui1981 · commit ff5c020ac588 · 2025-06-05T06:54:04.000+08:00
diff --git a/tis-incr/tis-flink-cdc-common/src/main/java/com/qlangtech/plugins/incr/debuzium/DebuziumPropAssist.java b/tis-incr/tis-flink-cdc-common/src/main/java/com/qlangtech/plugins/incr/debuzium/DebuziumPropAssist.java
@@ -42,7 +42,7 @@ private DebuziumPropAssist(Descriptor descriptor) {
 
     public static <T extends Describable, PLUGIN extends T> Options<PLUGIN, Field> createOpts(Descriptor<T> descriptor) {
         DebuziumPropAssist flinkProps = new DebuziumPropAssist(descriptor);
-        return flinkProps.createFlinkOptions();
+        return flinkProps.createOptions();
     }
 
     @Override

Original file line number	Diff line number	Diff line change
`@@ -42,7 +42,7 @@ private DebuziumPropAssist(Descriptor descriptor) {`
`42`	`42`
`43`	`43`	`public static <T extends Describable, PLUGIN extends T> Options<PLUGIN, Field> createOpts(Descriptor<T> descriptor) {`
`44`	`44`	`DebuziumPropAssist flinkProps = new DebuziumPropAssist(descriptor);`
`45`		`- return flinkProps.createFlinkOptions();`
	`45`	`+ return flinkProps.createOptions();`
`46`	`46`	`}`
`47`	`47`
`48`	`48`	`@Override`