[inlong] 01/02: [INLONG-5917][DataProxy] Optimize TubeSink class (#5920)

[gosonzhang]

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

gosonzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git

commit 0edca61351e51b4926d6884a6eafe696155efc82
Author: gosonzhang <4675...@qq.com>
AuthorDate: Mon Sep 26 19:17:54 2022 +0800

    [INLONG-5917][DataProxy] Optimize TubeSink class (#5920)
---
 .../src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java        | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
index 713cdfd72..a27a00758 100644
--- 
a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
+++ 
b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/TubeSink.java
@@ -19,6 +19,8 @@ package org.apache.inlong.dataproxy.sink;
 
 import static 
org.apache.inlong.dataproxy.consts.AttributeConstants.SEP_HASHTAG;
 import static 
org.apache.inlong.dataproxy.consts.ConfigConstants.MAX_MONITOR_CNT;
+
+import com.google.common.base.Preconditions;
 import java.util.HashMap;
 import java.util.HashSet;
 import java.util.Map;