[hotfix] [base] fix TableId.java use identifier decode error with fou…

…r quota
apache · Aug 30, 2023 · 8a1b660 · 8a1b660
1 parent 80160ca
commit 8a1b660
Showing 1 changed file with 0 additions and 3 deletions.
diff --git a/.../main/java/com/ververica/cdc/connectors/base/source/meta/split/SourceSplitSerializer.java b/.../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());