Spark: Improve rewrite_data_files exception handling for where clause (…

…apache#8290)
haojue · Aug 15, 2023 · ff3fa2b · ff3fa2b
1 parent 34b6058
commit ff3fa2b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/....1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java b/....1/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java
@@ -130,7 +130,7 @@ private RewriteDataFiles checkAndApplyFilter(
             SparkExpressionConverter.collectResolvedSparkExpression(spark(), tableName, where);
         return action.filter(SparkExpressionConverter.convertToIcebergExpression(expression));
       } catch (AnalysisException e) {
-        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where);
+        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where, e);
       }
     }
     return action;

diff --git a/....2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java b/....2/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java
@@ -134,7 +134,7 @@ private RewriteDataFiles checkAndApplyFilter(
             SparkExpressionConverter.collectResolvedSparkExpression(spark(), tableName, where);
         return action.filter(SparkExpressionConverter.convertToIcebergExpression(expression));
       } catch (AnalysisException e) {
-        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where);
+        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where, e);
       }
     }
     return action;

diff --git a/....3/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java b/....3/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java
@@ -134,7 +134,7 @@ private RewriteDataFiles checkAndApplyFilter(
             SparkExpressionConverter.collectResolvedSparkExpression(spark(), tableName, where);
         return action.filter(SparkExpressionConverter.convertToIcebergExpression(expression));
       } catch (AnalysisException e) {
-        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where);
+        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where, e);
       }
     }
     return action;

diff --git a/....4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java b/....4/spark/src/main/java/org/apache/iceberg/spark/procedures/RewriteDataFilesProcedure.java
@@ -136,7 +136,7 @@ private RewriteDataFiles checkAndApplyFilter(
             SparkExpressionConverter.collectResolvedSparkExpression(spark(), tableName, where);
         return action.filter(SparkExpressionConverter.convertToIcebergExpression(expression));
       } catch (AnalysisException e) {
-        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where);
+        throw new IllegalArgumentException("Cannot parse predicates in where option: " + where, e);
       }
     }
     return action;