Revert "[feat](catalog)Support Pre-Execution Authentication for HMS T…

…ype Iceberg Catalog Operations" This reverts commit d90b608.
CalvinKirs · Nov 8, 2024 · 448114d · 448114d
1 parent d90b608
commit 448114d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 8 deletions.
diff --git a/.../main/java/org/apache/doris/common/security/authentication/PreExecutionAuthenticator.java b/.../main/java/org/apache/doris/common/security/authentication/PreExecutionAuthenticator.java
@@ -37,10 +37,6 @@ public class PreExecutionAuthenticator {
      * Default constructor for PreExecutionAuthenticator.
      * This allows setting the HadoopAuthenticator at a later point if needed.
      */
-    public PreExecutionAuthenticator(HadoopAuthenticator authenticator) {
-        this.hadoopAuthenticator = authenticator;
-    }
-
     public PreExecutionAuthenticator() {
     }
 

diff --git a/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergMetadataOps.java b/fe/fe-core/src/main/java/org/apache/doris/datasource/iceberg/IcebergMetadataOps.java
@@ -28,6 +28,7 @@
 import org.apache.doris.common.ErrorCode;
 import org.apache.doris.common.ErrorReport;
 import org.apache.doris.common.UserException;
+import org.apache.doris.common.security.authentication.PreExecutionAuthenticator;
 import org.apache.doris.datasource.DorisTypeVisitor;
 import org.apache.doris.datasource.ExternalCatalog;
 import org.apache.doris.datasource.ExternalDatabase;
@@ -114,7 +115,8 @@ public void createDb(CreateDbStmt stmt) throws DdlException {
 
             });
         } catch (Exception e) {
-            throw new DdlException("Failed to create database: " + stmt.getFullDbName(), e);
+            throw new DdlException("Failed to create database: "
+                    + stmt.getFullDbName() + " ,error message is: " + e.getMessage());
         }
     }
 
@@ -147,7 +149,7 @@ public void dropDb(DropDbStmt stmt) throws DdlException {
                 return null;
             });
         } catch (Exception e) {
-            throw new DdlException("Failed to drop database: " + stmt.getDbName(), e);
+            throw new DdlException("Failed to drop database: " + stmt.getDbName() + " ,error message is: ", e);
         }
     }
 
@@ -171,7 +173,7 @@ public boolean createTable(CreateTableStmt stmt) throws UserException {
         try {
             preExecutionAuthenticator.execute(() -> performCreateTable(stmt));
         } catch (Exception e) {
-            throw new DdlException("Failed to create table: " + stmt.getTableName(), e);
+            throw new DdlException("Failed to create table: " + stmt.getTableName() + " ,error message is:", e);
         }
         return false;
     }
@@ -215,7 +217,7 @@ public void dropTable(DropTableStmt stmt) throws DdlException {
                 return null;
             });
         } catch (Exception e) {
-            throw new DdlException("Failed to drop table: " + stmt.getTableName(), e);
+            throw new DdlException("Failed to drop table: " + stmt.getTableName() + " ,error message is:", e);
         }
     }