private void openConnect() throws IOException {
        if (authMech == 1) {
            UserGroupInformation ugi = KrbUtils.loginAndReturnUgi(principal, keytabPath, krb5confPath);
            try {
                ugi.doAs((PrivilegedExceptionAction<Void>) () -> {
                    openJdbc();
                    return null;
                });
            } catch (InterruptedException | IOException e) {
                throw new IllegalArgumentException("connect impala error!", e);
            }
        } else {
            openJdbc();
        }
    }
Date: 2020/10/14
Company: www.dtstack.com

@author tiezhu
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaOutputFormat.java