| commit | 6c80d533339551b5306d3a8311a5929aa885b813 | [log] [tgz] |
|---|---|---|
| author | Abdullah Alamoudi <bamousaa@gmail.com> | Wed Jun 15 05:12:02 2016 +0300 |
| committer | abdullah alamoudi <bamousaa@gmail.com> | Tue Jun 14 21:34:48 2016 -0700 |
| tree | b450231db3c90910dcc476c936f34f7f9e196bb3 | |
| parent | 11a0d306b7be86693708cb251b5af6a4289d5391 [diff] |
Fix partitioning for datasets with meta Change-Id: Ida2dfe2c54e4fa4ae3b4131ec5acc801fa89ca0d Reviewed-on: https://asterix-gerrit.ics.uci.edu/924 Reviewed-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu> Reviewed-by: Yingyi Bu <buyingyi@gmail.com>
diff --git a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InsertDeleteUpsertPOperator.java b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InsertDeleteUpsertPOperator.java index f0bd603..0bc683c 100644 --- a/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InsertDeleteUpsertPOperator.java +++ b/hyracks-fullstack/algebricks/algebricks-core/src/main/java/org/apache/hyracks/algebricks/core/algebra/operators/physical/InsertDeleteUpsertPOperator.java
@@ -83,7 +83,11 @@ IPhysicalPropertiesVector reqdByParent, IOptimizationContext context) { List<LogicalVariable> scanVariables = new ArrayList<LogicalVariable>(); scanVariables.addAll(keys); + // Why do we add $$-1 and not the payLoad variable? scanVariables.add(new LogicalVariable(-1)); + if (additionalNonFilteringFields != null) { + scanVariables.addAll(additionalNonFilteringFields); + } IPhysicalPropertiesVector r = dataSource.getPropertiesProvider().computePropertiesVector(scanVariables); r.getLocalProperties().clear(); IPhysicalPropertiesVector[] requirements = new IPhysicalPropertiesVector[1];