We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent cbc70fa commit 241e7bdCopy full SHA for 241e7bd
2 files changed
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaDialect.java
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java
@@ -34,7 +34,6 @@
34
import org.slf4j.LoggerFactory;
35
36
import java.io.IOException;
37
-import java.rmi.RemoteException;
38
import java.security.PrivilegedExceptionAction;
39
import java.sql.Connection;
40
import java.sql.DriverManager;
@@ -52,7 +51,6 @@
52
51
import java.util.concurrent.ScheduledFuture;
53
import java.util.concurrent.ScheduledThreadPoolExecutor;
54
import java.util.concurrent.TimeUnit;
55
-import java.util.concurrent.atomic.AtomicReference;
56
import java.util.regex.Matcher;
57
import java.util.regex.Pattern;
58
import java.util.stream.Collectors;
0 commit comments