From 8a1b6607bbdb084a609c717b652e1912c59a3b14 Mon Sep 17 00:00:00 2001
From: gongzhongqiang <764629910@qq.com>
Date: Wed, 30 Aug 2023 15:12:36 +0800
Subject: [PATCH] [hotfix] [base] fix TableId.java use identifier decode error
 with four quota

---
 .../base/source/meta/split/SourceSplitSerializer.java          | 3 ---
 1 file changed, 3 deletions(-)

diff --git a/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java b/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java
index 0bd7f8156e3..baa874b5c87 100644
--- a/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java
+++ b/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java
@@ -67,9 +67,6 @@ public byte[] serialize(SourceSplitBase split) throws IOException {
 
             final DataOutputSerializer out = SERIALIZER_CACHE.get();
             out.writeInt(SNAPSHOT_SPLIT_FLAG);
-            boolean useCatalogBeforeSchema =
-                    SerializerUtils.shouldUseCatalogBeforeSchema(snapshotSplit.getTableId());
-            out.writeBoolean(useCatalogBeforeSchema);
             out.writeUTF(SerializerUtils.rowToSerializedString(snapshotSplit.getTableId()));
             out.writeUTF(snapshotSplit.splitId());
             out.writeUTF(snapshotSplit.getSplitKeyType().asSerializableString());