Skip to content

Commit 35cc8e9

Browse files
authored
chore: additional error mappings for deltalake (#4265)
1 parent bfa407f commit 35cc8e9

File tree

2 files changed

+14
-0
lines changed

2 files changed

+14
-0
lines changed

warehouse/integrations/deltalake/deltalake.go

+8
Original file line numberDiff line numberDiff line change
@@ -109,6 +109,14 @@ var errorsMappings = []model.JobError{
109109
Type: model.PermissionError,
110110
Format: regexp.MustCompile(`SecurityException: User does not have permission CREATE on CATALOG`),
111111
},
112+
{
113+
Type: model.ResourceNotFoundError,
114+
Format: regexp.MustCompile(`ENDPOINT_NOT_FOUND`),
115+
},
116+
{
117+
Type: model.ResourceNotFoundError,
118+
Format: regexp.MustCompile(`RESOURCE_DOES_NOT_EXIST`),
119+
},
112120
}
113121

114122
type Deltalake struct {

warehouse/router/errors_test.go

+6
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,12 @@ func TestErrorHandler_MatchUploadJobErrorType(t *testing.T) {
6363
{
6464
"Deltalake user does not have permission to create on catalog", warehouseutils.DELTALAKE, errors.New("{\"creating_remote_schema_failed\":{\"attempt\":2,\"errors\":[\"error while executing with response: [42000] [Simba][Hardy] (80) Syntax or semantic analysis error thrown in server while executing query. Error message from server: org.apache.hive.service.cli.HiveSQLException: Error running query: java.lang.SecurityException: User does not have permission CREATE on CATALOG.\tat org.apache.spark.sql.hive.thriftserver.HiveThriftServerErrors$.runningQueryError(HiveThriftServerErrors.sc (80) (SQLExecDirectW)\"]}}"), model.PermissionError,
6565
},
66+
{
67+
"Deltalake endpoint not found", warehouseutils.DELTALAKE, errors.New("{\"fetching_remote_schema_failed\":{\"attempt\":5,\"errors\":[\"fetching schema from warehouse: fetching schema: creating schema: checking if schema exists: schema exists: databricks: request error: error connecting: host=*** port=***, httpPath=***: databricks: request error: open session request error: Post ***: ENDPOINT_NOT_FOUND: SQL warehouse *** does not exist at all in the database: request error after 1 attempt(s): unexpected HTTP status 404 Not Found\"]}}"), model.ResourceNotFoundError,
68+
},
69+
{
70+
"Deltalake resource does not exist", warehouseutils.DELTALAKE, errors.New("{\"fetching_remote_schema_failed\":{\"attempt\":2,\"errors\":[\"fetching schema from warehouse: fetching schema: creating schema: checking if schema exists: schema exists: databricks: request error: error connecting: host=*** port=443, httpPath=***: databricks: request error: open session request error: Post ***: RESOURCE_DOES_NOT_EXIST: No cluster found matching: ***: request error after 1 attempt(s): unexpected HTTP status 404 Not Found\"]}}"), model.ResourceNotFoundError,
71+
},
6672

6773
{
6874
"MSSQL unable to open tcp connection", warehouseutils.MSSQL, errors.New("{\"fetching_remote_schema_failed\":{\"attempt\":2,\"errors\":[\"unable to open tcp connection with host ***: dial tcp ***: i/o timeout\"]}}"), model.PermissionError,

0 commit comments

Comments
 (0)