This is an automated email from the ASF dual-hosted git repository.

szita 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 639fc763f5 HIVE-25967: Prevent residual expressions from getting 
serialized in Iceberg splits (addendum) (#3178) (Adam Szita, reviewed by Peter 
Vary)
639fc763f5 is described below

commit 639fc763f56dc65e69669101c8669e4884949e14
Author: Adam Szita <[email protected]>
AuthorDate: Wed Apr 6 10:36:31 2022 +0200

    HIVE-25967: Prevent residual expressions from getting serialized in Iceberg 
splits (addendum) (#3178) (Adam Szita, reviewed by Peter Vary)
---
 .../src/main/java/org/apache/iceberg/mr/hive/HiveIcebergSplit.java     | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git 
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergSplit.java
 
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergSplit.java
index f636829759..b698d869d3 100644
--- 
a/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergSplit.java
+++ 
b/iceberg/iceberg-handler/src/main/java/org/apache/iceberg/mr/hive/HiveIcebergSplit.java
@@ -124,8 +124,7 @@ public class HiveIcebergSplit extends FileSplit implements 
IcebergSplitContainer
   @Override
   public void write(DataOutput out) throws IOException {
     for (FileScanTask fileScanTask : icebergSplit().task().files()) {
-      if (fileScanTask.residual() != Expressions.alwaysTrue() &&
-          fileScanTask.getClass().isAssignableFrom(SPLIT_SCAN_TASK_CLAZZ)) {
+      if (fileScanTask.getClass().isAssignableFrom(SPLIT_SCAN_TASK_CLAZZ)) {
 
         Object residuals = 
RESIDUALS_FIELD.get(FILE_SCAN_TASK_FIELD.get(fileScanTask));
 

Reply via email to