Skip to content

Commit f41ca1a

Browse files
committed
fix style
1 parent 0240447 commit f41ca1a

File tree

1 file changed

+11
-2
lines changed

1 file changed

+11
-2
lines changed

flink-cdc-connect/flink-cdc-pipeline-connectors/flink-cdc-pipeline-connector-starrocks/src/test/java/org/apache/flink/cdc/connectors/starrocks/sink/StarRocksMetadataApplierTest.java

Lines changed: 11 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,11 @@
1818
package org.apache.flink.cdc.connectors.starrocks.sink;
1919

2020
import org.apache.flink.cdc.common.configuration.Configuration;
21-
import org.apache.flink.cdc.common.event.*;
21+
import org.apache.flink.cdc.common.event.AddColumnEvent;
22+
import org.apache.flink.cdc.common.event.CreateTableEvent;
23+
import org.apache.flink.cdc.common.event.DropColumnEvent;
24+
import org.apache.flink.cdc.common.event.RenameColumnEvent;
25+
import org.apache.flink.cdc.common.event.TableId;
2226
import org.apache.flink.cdc.common.schema.Column;
2327
import org.apache.flink.cdc.common.schema.Schema;
2428
import org.apache.flink.cdc.common.types.BooleanType;
@@ -35,7 +39,12 @@
3539
import org.junit.jupiter.api.BeforeEach;
3640
import org.junit.jupiter.api.Test;
3741

38-
import java.util.*;
42+
import java.util.ArrayList;
43+
import java.util.Arrays;
44+
import java.util.Collections;
45+
import java.util.HashMap;
46+
import java.util.List;
47+
import java.util.Map;
3948

4049
import static org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions.TABLE_CREATE_NUM_BUCKETS;
4150
import static org.apache.flink.cdc.connectors.starrocks.sink.StarRocksDataSinkOptions.TABLE_SCHEMA_CHANGE_TIMEOUT;

0 commit comments

Comments
 (0)