Repository: crunch Updated Branches: refs/heads/master d7443e392 -> 04e02516a
CRUNCH-494: Fix to bump the limit on unioning PCollections above 5k Project: http://git-wip-us.apache.org/repos/asf/crunch/repo Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/04e02516 Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/04e02516 Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/04e02516 Branch: refs/heads/master Commit: 04e02516a975d02014078bfb418fae83c2c8b919 Parents: d7443e3 Author: Josh Wills <[email protected]> Authored: Sun Feb 15 23:05:01 2015 -0800 Committer: Josh Wills <[email protected]> Committed: Tue Feb 24 09:57:09 2015 -0800 ---------------------------------------------------------------------- .../java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/crunch/blob/04e02516/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java ---------------------------------------------------------------------- diff --git a/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java b/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java index f098f2b..315baf1 100644 --- a/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java +++ b/crunch-core/src/main/java/org/apache/crunch/impl/dist/collect/PCollectionImpl.java @@ -318,7 +318,7 @@ public abstract class PCollectionImpl<S> implements PCollection<S> { public Set<Target> getTargetDependencies() { Set<Target> targetDeps = Sets.<Target>newHashSet(doOptions.getTargets()); for (PCollectionImpl<?> parent : getParents()) { - targetDeps = Sets.union(targetDeps, parent.getTargetDependencies()); + targetDeps.addAll(parent.getTargetDependencies()); } return targetDeps; }
