This is an automated email from the ASF dual-hosted git repository. duhengforever pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-flink.git
commit 0be1ed7a027b0e88cec2bab420554251c73a7387 Author: zhu zhengwen <[email protected]> AuthorDate: Fri Jun 21 16:00:13 2019 +0800 code format --- src/main/java/org/apache/rocketmq/flink/RocketMQSource.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java b/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java index dcb1d31..18277e0 100644 --- a/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java +++ b/src/main/java/org/apache/rocketmq/flink/RocketMQSource.java @@ -19,7 +19,11 @@ package org.apache.rocketmq.flink; import java.nio.charset.StandardCharsets; -import java.util.*; +import java.util.List; +import java.util.Map; +import java.util.Properties; +import java.util.Set; +import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; import org.apache.commons.lang.Validate;
