Skip to content

Commit 3384b86

Browse files
committed
【opt】opt import
1 parent 7b4fd9d commit 3384b86

3 files changed

Lines changed: 0 additions & 8 deletions

File tree

core/src/main/java/com/dtstack/flink/sql/table/AbstractSourceTableInfo.java

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -21,13 +21,9 @@
2121
package com.dtstack.flink.sql.table;
2222

2323
import com.google.common.base.Strings;
24-
import com.google.common.collect.Lists;
2524
import com.google.common.collect.Maps;
26-
import org.apache.flink.util.StringUtils;
2725

28-
import java.util.ArrayList;
2926
import java.util.Map;
30-
import java.util.TimeZone;
3127

3228
/**
3329
* Reason:

core/src/main/java/com/dtstack/flink/sql/watermarker/AbstractCustomerWaterMarker.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,6 @@
2929
import org.apache.flink.streaming.api.functions.timestamps.BoundedOutOfOrdernessTimestampExtractor;
3030
import org.apache.flink.streaming.api.windowing.time.Time;
3131

32-
import java.util.TimeZone;
33-
3432
/**
3533
* Reason:
3634
* Date: 2018/10/18

core/src/main/java/com/dtstack/flink/sql/watermarker/CustomerWaterMarkerForLong.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -26,8 +26,6 @@
2626
import org.slf4j.Logger;
2727
import org.slf4j.LoggerFactory;
2828

29-
import java.util.TimeZone;
30-
3129
/**
3230
* Custom watermark --- for eventtime
3331
* Date: 2017/12/28

0 commit comments

Comments
 (0)