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));