in kyuubi-relocated-hive-metastore-client/src/main/java/org/apache/kyuubi/shaded/hive/metastore/security/TUGIAssumingTransport.java [44:71]
public void open() throws TTransportException {
try {
ugi.doAs(
new PrivilegedExceptionAction<Void>() {
public Void run() {
try {
wrapped.open();
} catch (TTransportException tte) {
// Wrap the transport exception in an RTE, since UGI.doAs() then goes
// and unwraps this for us out of the doAs block. We then unwrap one
// more time in our catch clause to get back the TTE. (ugh)
throw new RuntimeException(tte);
}
return null;
}
});
} catch (IOException ioe) {
throw new RuntimeException("Received an ioe we never threw!", ioe);
} catch (InterruptedException ie) {
throw new RuntimeException("Received an ie we never threw!", ie);
} catch (RuntimeException rte) {
if (rte.getCause() instanceof TTransportException) {
throw (TTransportException) rte.getCause();
} else {
throw rte;
}
}
}