[inlong] branch master updated: [INLONG-8602][Sort] Fix StackOverflowError of Oracle CDC (#8607)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new 2fc03b4062 [INLONG-8602][Sort] Fix StackOverflowError of Oracle CDC 
(#8607)
2fc03b4062 is described below

commit 2fc03b406239f1d2aab23191112739539cfdb767
Author: emhui <111486498+e-m...@users.noreply.github.com>
AuthorDate: Thu Aug 3 10:33:47 2023 +0800

    [INLONG-8602][Sort] Fix StackOverflowError of Oracle CDC (#8607)
---
 .../oracle/debezium/table/RowDataDebeziumDeserializeSchema.java    | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java
 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java
index d7dd5081a2..e75e794912 100644
--- 
a/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java
+++ 
b/inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java
@@ -797,13 +797,18 @@ public final class RowDataDebeziumDeserializeSchema
 
     @Override
     public void deserialize(SourceRecord record, Collector<RowData> out) 
throws Exception {
-        deserialize(record, out);
+        extractRowAndEmitRecord(record, out, null);
     }
 
     @Override
     public void deserialize(SourceRecord record, Collector<RowData> out,
             TableChange tableSchema)
             throws Exception {
+        extractRowAndEmitRecord(record, out, tableSchema);
+    }
+
+    private void extractRowAndEmitRecord(SourceRecord record, 
Collector<RowData> out, TableChange tableSchema)
+            throws Exception {
         Envelope.Operation op = Envelope.operationFor(record);
         Struct value = (Struct) record.value();
         Schema valueSchema = record.valueSchema();