[inlong] branch master updated: [INLONG-7073][Sort] Remove exception when topic does not exist (#7038)

[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 6f5bde761 [INLONG-7073][Sort]  Remove exception when topic does not 
exist (#7038)
6f5bde761 is described below

commit 6f5bde7614f823dfe1fd669e79f08384c3a474a6
Author: vernedeng <deng...@pku.edu.cn>
AuthorDate: Fri Dec 23 15:25:20 2022 +0800

    [INLONG-7073][Sort]  Remove exception when topic does not exist (#7038)
---
 .../sort/standalone/sink/kafka/KafkaFederationSinkContext.java      | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationSinkContext.java
 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationSinkContext.java
index e6a880f54..a1dfa5630 100644
--- 
a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationSinkContext.java
+++ 
b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationSinkContext.java
@@ -35,6 +35,7 @@ import java.util.ArrayList;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.concurrent.ConcurrentHashMap;
 
 /** Context of kafka sink. */
@@ -119,10 +120,7 @@ public class KafkaFederationSinkContext extends 
SinkContext {
      */
     public String getTopic(String uid) {
         KafkaIdConfig idConfig = this.idConfigMap.get(uid);
-        if (idConfig == null) {
-            throw new NullPointerException("uid " + uid + "got null topic");
-        }
-        return idConfig.getTopic();
+        return Objects.isNull(idConfig) ? null : idConfig.getTopic();
     }
 
     /**