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

…r quota
apache · Sep 6, 2023 · f95e1e9 · f95e1e9
1 parent 8feb51b
commit f95e1e9
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -70,7 +70,7 @@ public byte[] serialize(SourceSplitBase split) throws IOException {
             boolean useCatalogBeforeSchema =
                     SerializerUtils.shouldUseCatalogBeforeSchema(snapshotSplit.getTableId());
             out.writeBoolean(useCatalogBeforeSchema);
-            out.writeUTF(snapshotSplit.getTableId().toString());
+            out.writeUTF(snapshotSplit.getTableId().toDoubleQuotedString());
             out.writeUTF(snapshotSplit.splitId());
             out.writeUTF(snapshotSplit.getSplitKeyType().asSerializableString());