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 <[email protected]> Authored: Tue Aug 14 15:09:08 2012 -0700 Committer: jwills <[email protected]> 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.
