You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by go...@apache.org on 2022/09/26 11:21:13 UTC
[inlong] 01/02: [INLONG-5917][DataProxy] Optimize TubeSink class (#5920)
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 <46...@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;