Skip to content

Commit

Permalink
style
Browse files Browse the repository at this point in the history
  • Loading branch information
PeterZh6 committed Nov 10, 2024
1 parent 5fc3215 commit 3f077a3
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,6 @@

package org.apache.inlong.sort.kafka.table;

import org.apache.flink.util.Preconditions;
import org.apache.inlong.sort.kafka.source.KafkaSource;
import org.apache.inlong.sort.kafka.source.KafkaSourceBuilder;

Expand Down Expand Up @@ -52,6 +51,7 @@
import org.apache.flink.table.data.TimestampData;
import org.apache.flink.table.types.DataType;
import org.apache.flink.table.types.utils.DataTypeUtils;
import org.apache.flink.util.Preconditions;
import org.apache.kafka.clients.consumer.ConsumerConfig;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.apache.kafka.clients.consumer.OffsetResetStrategy;
Expand Down

0 comments on commit 3f077a3

Please sign in to comment.