You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by mb...@apache.org on 2022/01/24 12:07:46 UTC
[hive] branch master updated: HIVE-25891: Improve Iceberg error message for unsupported vectorization cases (#2965) (Marton Bod, reviewed by Peter Vary and Adam Szita)
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 <mb...@cloudera.com>
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(