incubator-crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jwi...@apache.org
Subject git commit: CRUNCH-46: Add repl support to PipelineLike.done calls
Date Tue, 14 Aug 2012 22:11:28 GMT
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 <jwills@apache.org>
Authored: Tue Aug 14 15:09:08 2012 -0700
Committer: jwills <jwills@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.


Mime
View raw message