This is an automated email from the ASF dual-hosted git repository.
mbod pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hive.git
The following commit(s) were added to refs/heads/master by this push:
new 37799b9 HIVE-25891: Improve Iceberg error message for unsupported
vectorization cases (#2965) (Marton Bod, reviewed by Peter Vary and Adam Szita)
37799b9 is described below
commit 37799b9c88403962dd99606585f8d2f564297d6e
Author: Marton Bod <[email protected]>
AuthorDate: Mon Jan 24 13:07:28 2022 +0100
HIVE-25891: Improve Iceberg error message for unsupported vectorization
cases (#2965) (Marton Bod, reviewed by Peter Vary and Adam Szita)
---
.../java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
index 9a02927..b7ff6dc 100644
---
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
+++
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/mapreduce/IcebergInputFormat.java
@@ -380,7 +380,8 @@ public class IcebergInputFormat<T> extends
InputFormat<Void, T> {
case PIG:
case HIVE:
// TODO implement value readers for Pig and Hive
- throw new UnsupportedOperationException("Avro support not yet
supported for Pig and Hive");
+ throw new UnsupportedOperationException("Vectorized execution is not
yet supported for Iceberg avro " +
+ "tables. Please turn off vectorization and retry the query.");
case GENERIC:
avroReadBuilder.createReaderFunc(
(expIcebergSchema, expAvroSchema) ->
@@ -407,7 +408,8 @@ public class IcebergInputFormat<T> extends
InputFormat<Void, T> {
case PIG:
case HIVE:
// TODO implement value readers for Pig and Hive
- throw new UnsupportedOperationException("Parquet support not yet
supported for Pig and Hive");
+ throw new UnsupportedOperationException("Vectorized execution is not
yet supported for Iceberg parquet " +
+ "tables. Please turn off vectorization and retry the query.");
case GENERIC:
parquetReadBuilder.createReaderFunc(
fileSchema -> GenericParquetReaders.buildReader(