File tree Expand file tree Collapse file tree
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala Expand file tree Collapse file tree Original file line number Diff line number Diff line change 3434import org .slf4j .LoggerFactory ;
3535
3636import java .io .IOException ;
37- import java .rmi .RemoteException ;
3837import java .security .PrivilegedExceptionAction ;
3938import java .sql .Connection ;
4039import java .sql .DriverManager ;
5251import java .util .concurrent .ScheduledFuture ;
5352import java .util .concurrent .ScheduledThreadPoolExecutor ;
5453import java .util .concurrent .TimeUnit ;
55- import java .util .concurrent .atomic .AtomicReference ;
5654import java .util .regex .Matcher ;
5755import java .util .regex .Pattern ;
5856import java .util .stream .Collectors ;
@@ -630,7 +628,7 @@ private String quoteIdentifier(String identifier) {
630628 public static Builder getImpalaBuilder () {
631629 return new Builder ();
632630 }
633-
631+
634632 public static class Builder {
635633 private final ImpalaOutputFormat format = new ImpalaOutputFormat ();
636634
You can’t perform that action at this time.
0 commit comments