From 80160ca3344e92104279c767c06932d49d4d8839 Mon Sep 17 00:00:00 2001 From: gongzhongqiang <764629910@qq.com> Date: Wed, 30 Aug 2023 00:32:56 +0800 Subject: [PATCH] [hotfix] [base] fix TableId.java use identifier decode error with four quota --- .../src/main/java/io/debezium/relational/TableId.java | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/flink-connector-debezium/src/main/java/io/debezium/relational/TableId.java b/flink-connector-debezium/src/main/java/io/debezium/relational/TableId.java index 003dba881ac..46f1998defc 100644 --- a/flink-connector-debezium/src/main/java/io/debezium/relational/TableId.java +++ b/flink-connector-debezium/src/main/java/io/debezium/relational/TableId.java @@ -3,6 +3,7 @@ * * Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0 */ + package io.debezium.relational; import io.debezium.annotation.Immutable; @@ -12,9 +13,11 @@ import java.io.Serializable; /** - * Copy from Debezium and implement Serializable. Unique identifier for a database table. + * Copied from Debezium 1.9.7.Final. + * + *

Unique identifier for a database table. * - * @author Randall Hauch + *

Just add serialization support. */ @Immutable public final class TableId implements DataCollectionId, Comparable, Serializable {