@Override
    public Connection getConn(String dbUrl, String userName, String password) {
        try {
            Connection connection;
            String url = getUrl();
            ClassLoaderManager.forName(IMPALA_DRIVER, getClass().getClassLoader());
            // Kerberos
            if (impalaSideTableInfo.getAuthMech() == 1) {
                String keyTabFilePath = impalaSideTableInfo.getKeyTabFilePath();
                String krb5FilePath = impalaSideTableInfo.getKrb5FilePath();
                String principal = impalaSideTableInfo.getPrincipal();
                UserGroupInformation ugi = KrbUtils.loginAndReturnUgi(principal, keyTabFilePath, krb5FilePath);
                connection = ugi.doAs(new PrivilegedExceptionAction<Connection>() {
                    @Override
                    public Connection run() throws SQLException {
                        return DriverManager.getConnection(url);
                    }
                });
            } else {
                connection = DriverManager.getConnection(url);
            }
            connection.setAutoCommit(false);
            return connection;
        } catch (Exception e) {
            LOG.error("", e);
            throw new RuntimeException("", e);
        }
    }
side operator with cache for all(period reload)
Date: 2019/11/12
Company: www.dtstack.com

@author xiuzhu
impala/impala-side/impala-all-side/src/main/java/com/dtstack/flink/sql/side/impala/ImpalaAllReqRow.java