[inlong] branch master updated: [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 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 9aeb5f66c [INLONG-6484][Sort] Bugfix: fix schema update Circular 
dependency error in multiple sink iceberg scenes (#6486)
9aeb5f66c is described below

commit 9aeb5f66c66b191bd31a5af376ddb9ba8dce2bc7
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;
             }
         }
     }