You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@crunch.apache.org by jw...@apache.org on 2012/08/15 00:11:28 UTC
git commit: CRUNCH-46: Add repl support to PipelineLike.done calls
Updated Branches:
refs/heads/master 92c06fc6c -> 33f53e629
CRUNCH-46: Add repl support to PipelineLike.done calls
Project: http://git-wip-us.apache.org/repos/asf/incubator-crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-crunch/commit/33f53e62
Tree: http://git-wip-us.apache.org/repos/asf/incubator-crunch/tree/33f53e62
Diff: http://git-wip-us.apache.org/repos/asf/incubator-crunch/diff/33f53e62
Branch: refs/heads/master
Commit: 33f53e629291bb651265ff8bca607b9e47f27606
Parents: 92c06fc
Author: jwills <jw...@apache.org>
Authored: Tue Aug 14 15:09:08 2012 -0700
Committer: jwills <jw...@apache.org>
Committed: Tue Aug 14 15:09:08 2012 -0700
----------------------------------------------------------------------
.../org/apache/crunch/scrunch/PipelineLike.scala | 5 ++++-
1 files changed, 4 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-crunch/blob/33f53e62/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PipelineLike.scala
----------------------------------------------------------------------
diff --git a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PipelineLike.scala b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PipelineLike.scala
index b15966b..5a10ee7 100644
--- a/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PipelineLike.scala
+++ b/crunch-scrunch/src/main/scala/org/apache/crunch/scrunch/PipelineLike.scala
@@ -82,7 +82,10 @@ trait PipelineLike {
* clean up any intermediate data files that were created in
* this run or previous calls to `run`.
*/
- def done(): Unit = jpipeline.done()
+ def done(): Unit = {
+ InterpreterRunner.addReplJarsToJob(getConfiguration())
+ jpipeline.done()
+ }
/**
* Turn on debug logging for jobs that are run from this pipeline.