[inlong] branch master updated: [INLONG-6952][Sort] Cancel parsing fault tolerance for JsonDynamicSchemaFormat (#6953)

[zirui]

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

zirui 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 639ca6dc4 [INLONG-6952][Sort] Cancel parsing fault tolerance for 
JsonDynamicSchemaFormat (#6953)
639ca6dc4 is described below

commit 639ca6dc4e52135ba77b647ce25d1e0cae240e5c
Author: yunqingmoswu <44659300+yunqingmo...@users.noreply.github.com>
AuthorDate: Mon Dec 19 14:46:41 2022 +0800

    [INLONG-6952][Sort] Cancel parsing fault tolerance for 
JsonDynamicSchemaFormat (#6953)
---
 .../org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
 
b/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
index e8e336a9f..0767b7586 100644
--- 
a/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
+++ 
b/inlong-sort/sort-connectors/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java
@@ -265,7 +265,9 @@ public abstract class JsonDynamicSchemaFormat extends 
AbstractDynamicSchemaForma
                 replacement = extract(rootNode, keyText);
             }
             if (replacement == null) {
-                replacement = "";
+                // The variable replacement here is mainly used for
+                // multi-sink scenario synchronization destination 
positioning, so the value of null cannot be ignored.
+                throw new IOException(String.format("Can't find value for key: 
%s", keyText));
             }
             matcher.appendReplacement(sb, replacement);
         }