modify impala sink throw exception

Author: a49a

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

@@ -7,6 +7,7 @@
 
 import java.io.IOException;
 import java.security.PrivilegedAction;
+import java.security.PrivilegedExceptionAction;
 import java.util.List;
 
 import static org.apache.flink.util.Preconditions.checkNotNull;
@@ -55,17 +56,17 @@ public ImpalaOutputFormat(
     public void open(int taskNumber, int numTasks) throws IOException {
         if (authMech == 1) {
             UserGroupInformation ugi = KrbUtils.getUgi(principal, keytabPath, krb5confPath);
-            ugi.doAs(new PrivilegedAction<Object>() {
-                @Override
-                public Object run() {
-                    try {
+            try {
+                ugi.doAs(new PrivilegedExceptionAction<Void>() {
+                    @Override
+                    public Void run() throws IOException {
                         openJdbc();
-                    } catch (IOException e) {
-                        e.printStackTrace();
+                        return null;
                     }
-                    return null;
-                }
-            });
+                });
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
         } else {
             super.open(taskNumber, numTasks);
         }