crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject crunch git commit: CRUNCH-494: Fix to bump the limit on unioning PCollections above 5k
Date Tue, 24 Feb 2015 18:10:24 GMT
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 <jwills@apache.org>
Authored: Sun Feb 15 23:05:01 2015 -0800
Committer: Josh Wills <jwills@apache.org>
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;
   }


Mime
View raw message