diff --git a/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/Factory.java b/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/Factory.java index 1f346e977..9152ca858 100644 --- a/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/Factory.java +++ b/flink-cdc-common/src/main/java/com/ververica/cdc/common/factories/Factory.java @@ -16,9 +16,8 @@ package com.ververica.cdc.common.factories; -import org.apache.flink.configuration.ConfigOption; - import com.ververica.cdc.common.annotation.PublicEvolving; +import com.ververica.cdc.common.configuration.ConfigOption; import com.ververica.cdc.common.configuration.Configuration; import java.util.Collections; diff --git a/flink-cdc-composer/pom.xml b/flink-cdc-composer/pom.xml index ea47d46b8..14900b7f2 100644 --- a/flink-cdc-composer/pom.xml +++ b/flink-cdc-composer/pom.xml @@ -29,7 +29,7 @@ under the License. com.ververica flink-cdc-common - ${revision} + ${project.version} diff --git a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory1.java b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory1.java index 335970ffc..b5149f5e6 100644 --- a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory1.java +++ b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory1.java @@ -16,8 +16,7 @@ package com.ververica.cdc.composer.utils.factory; -import org.apache.flink.configuration.ConfigOption; - +import com.ververica.cdc.common.configuration.ConfigOption; import com.ververica.cdc.common.factories.DataSinkFactory; import com.ververica.cdc.common.sink.DataSink; import com.ververica.cdc.common.sink.EventSinkProvider; diff --git a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory2.java b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory2.java index 9bdf45405..865a0621d 100644 --- a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory2.java +++ b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSinkFactory2.java @@ -16,8 +16,7 @@ package com.ververica.cdc.composer.utils.factory; -import org.apache.flink.configuration.ConfigOption; - +import com.ververica.cdc.common.configuration.ConfigOption; import com.ververica.cdc.common.factories.DataSinkFactory; import com.ververica.cdc.common.sink.DataSink; import com.ververica.cdc.common.sink.EventSinkProvider; diff --git a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory1.java b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory1.java index 53ea87d1d..4e4ca283b 100644 --- a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory1.java +++ b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory1.java @@ -16,8 +16,7 @@ package com.ververica.cdc.composer.utils.factory; -import org.apache.flink.configuration.ConfigOption; - +import com.ververica.cdc.common.configuration.ConfigOption; import com.ververica.cdc.common.factories.DataSourceFactory; import com.ververica.cdc.common.source.DataSource; import com.ververica.cdc.common.source.EventSourceProvider; diff --git a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory2.java b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory2.java index 909034766..31ac1fafe 100644 --- a/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory2.java +++ b/flink-cdc-composer/src/test/java/com/ververica/cdc/composer/utils/factory/DataSourceFactory2.java @@ -16,8 +16,7 @@ package com.ververica.cdc.composer.utils.factory; -import org.apache.flink.configuration.ConfigOption; - +import com.ververica.cdc.common.configuration.ConfigOption; import com.ververica.cdc.common.factories.DataSourceFactory; import com.ververica.cdc.common.source.DataSource; import com.ververica.cdc.common.source.EventSourceProvider;