[inlong] 03/03: [INLONG-6484][Sort] Bugfix: fix schema update Circular dependency error in multiple sink iceberg scenes (#6486)

[dockerzhang]

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

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

commit 4634918b513ea84db6d06fa15d8b7200a521fd4b
Author: thesumery <107393625+thesum...@users.noreply.github.com>
AuthorDate: Thu Nov 10 10:55:39 2022 +0800

    [INLONG-6484][Sort] Bugfix: fix schema update Circular dependency error in 
multiple sink iceberg scenes (#6486)
    
    Co-authored-by: thesumery <158971...@qq.com>
---
 .../inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java
 
b/inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java
index 378f040d9..ec65fbae7 100644
--- 
a/inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java
+++ 
b/inlong-sort/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java
@@ -186,6 +186,7 @@ public class DynamicSchemaHandleOperator extends 
AbstractStreamOperator<RecordWi
                 output.collect(new StreamRecord<>(recordWithSchema));
             } else {
                 handldAlterSchemaEventFromOperator(tableId, latestSchema, 
dataSchema);
+                break;
             }
         }
     }