From cd4b1c9f237f6926e304a85f649e6813018a24f9 Mon Sep 17 00:00:00 2001 From: PeterZh6 Date: Fri, 15 Nov 2024 15:34:22 +0800 Subject: [PATCH] solve factory identifier issue --- .../services/org.apache.flink.table.factories.Factory | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory b/inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory index 9b8bf8e042..5f3c21a9d4 100644 --- a/inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory +++ b/inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/resources/META-INF/services/org.apache.flink.table.factories.Factory @@ -13,5 +13,5 @@ # See the License for the specific language governing permissions and # limitations under the License. -org.apache.flink.streaming.connectors.kafka.table.KafkaDynamicTableFactory -org.apache.flink.streaming.connectors.kafka.table.UpsertKafkaDynamicTableFactory +org.apache.inlong.sort.kafka.table.KafkaDynamicTableFactory +org.apache.inlong.sort.kafka.table.UpsertKafkaDynamicTableFactory