fix style.

apache · Nov 1, 2022 · 34e6be6 · 34e6be6
1 parent 44b42ae
commit 34e6be6
Show file tree

Hide file tree

Showing 6 changed files with 27 additions and 19 deletions.
diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQMessageSerializationSchema.java b/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQMessageSerializationSchema.java
@@ -17,9 +17,10 @@
 
 package org.apache.rocketmq.flink.sink2;
 
+import org.apache.rocketmq.common.message.Message;
+
 import org.apache.flink.annotation.Internal;
 import org.apache.flink.api.common.serialization.SerializationSchema;
-import org.apache.rocketmq.common.message.Message;
 
 import java.io.Serializable;
 

diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQSink.java b/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQSink.java
@@ -17,15 +17,16 @@
 
 package org.apache.rocketmq.flink.sink2;
 
+import org.apache.rocketmq.flink.sink2.committer.RocketMQCommittable;
+import org.apache.rocketmq.flink.sink2.committer.RocketMQCommittableSerializer;
+import org.apache.rocketmq.flink.sink2.committer.RocketMQCommitter;
+import org.apache.rocketmq.flink.sink2.writer.RocketMQWriter;
+
 import org.apache.flink.api.connector.sink2.Committer;
 import org.apache.flink.api.connector.sink2.StatefulSink;
 import org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink;
 import org.apache.flink.connector.base.DeliveryGuarantee;
 import org.apache.flink.core.io.SimpleVersionedSerializer;
-import org.apache.rocketmq.flink.sink2.committer.RocketMQCommittable;
-import org.apache.rocketmq.flink.sink2.committer.RocketMQCommittableSerializer;
-import org.apache.rocketmq.flink.sink2.committer.RocketMQCommitter;
-import org.apache.rocketmq.flink.sink2.writer.RocketMQWriter;
 
 import java.io.IOException;
 import java.util.Collection;

diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQSinkBuilder.java b/src/main/java/org/apache/rocketmq/flink/sink2/RocketMQSinkBuilder.java
@@ -17,10 +17,12 @@
 
 package org.apache.rocketmq.flink.sink2;
 
+import org.apache.rocketmq.flink.legacy.RocketMQConfig;
+
 import org.apache.flink.api.common.ExecutionConfig;
 import org.apache.flink.api.java.ClosureCleaner;
 import org.apache.flink.connector.base.DeliveryGuarantee;
-import org.apache.rocketmq.flink.legacy.RocketMQConfig;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/TopicSelector.java b/src/main/java/org/apache/rocketmq/flink/sink2/TopicSelector.java
@@ -20,5 +20,4 @@
 import java.io.Serializable;
 import java.util.function.Function;
 
-public interface TopicSelector<IN> extends Function<IN, String>, Serializable {
-}
+public interface TopicSelector<IN> extends Function<IN, String>, Serializable {}
diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/committer/RocketMQCommitter.java b/src/main/java/org/apache/rocketmq/flink/sink2/committer/RocketMQCommitter.java
@@ -17,12 +17,14 @@
 
 package org.apache.rocketmq.flink.sink2.committer;
 
-import org.apache.flink.api.connector.sink2.Committer;
 import org.apache.rocketmq.client.producer.LocalTransactionState;
 import org.apache.rocketmq.client.producer.TransactionListener;
 import org.apache.rocketmq.common.message.Message;
 import org.apache.rocketmq.common.message.MessageExt;
 import org.apache.rocketmq.flink.sink2.RocketMQSink;
+
+import org.apache.flink.api.connector.sink2.Committer;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/src/main/java/org/apache/rocketmq/flink/sink2/writer/RocketMQWriter.java b/src/main/java/org/apache/rocketmq/flink/sink2/writer/RocketMQWriter.java
@@ -17,16 +17,6 @@
 
 package org.apache.rocketmq.flink.sink2.writer;
 
-import org.apache.flink.api.common.operators.MailboxExecutor;
-import org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext;
-import org.apache.flink.api.connector.sink2.Sink.InitContext;
-import org.apache.flink.api.connector.sink2.StatefulSink;
-import org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter;
-import org.apache.flink.connector.base.DeliveryGuarantee;
-import org.apache.flink.metrics.Counter;
-import org.apache.flink.metrics.groups.SinkWriterMetricGroup;
-import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList;
-import org.apache.flink.util.FlinkRuntimeException;
 import org.apache.rocketmq.client.exception.MQClientException;
 import org.apache.rocketmq.client.producer.DefaultMQProducer;
 import org.apache.rocketmq.client.producer.SendCallback;
@@ -40,6 +30,19 @@
 import org.apache.rocketmq.flink.sink2.committer.RocketMQCommittable;
 import org.apache.rocketmq.flink.sink2.committer.RocketMQCommitter;
 import org.apache.rocketmq.remoting.exception.RemotingException;
+
+import org.apache.flink.api.common.operators.MailboxExecutor;
+import org.apache.flink.api.common.serialization.SerializationSchema.InitializationContext;
+import org.apache.flink.api.connector.sink2.Sink.InitContext;
+import org.apache.flink.api.connector.sink2.StatefulSink;
+import org.apache.flink.api.connector.sink2.TwoPhaseCommittingSink.PrecommittingSinkWriter;
+import org.apache.flink.connector.base.DeliveryGuarantee;
+import org.apache.flink.metrics.Counter;
+import org.apache.flink.metrics.groups.SinkWriterMetricGroup;
+import org.apache.flink.util.FlinkRuntimeException;
+
+import org.apache.flink.shaded.guava30.com.google.common.collect.ImmutableList;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;