Return-Path: X-Original-To: apmail-incubator-crunch-dev-archive@minotaur.apache.org Delivered-To: apmail-incubator-crunch-dev-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id BDBE5E332 for ; Mon, 17 Dec 2012 17:36:43 +0000 (UTC) Received: (qmail 7100 invoked by uid 500); 17 Dec 2012 17:36:43 -0000 Delivered-To: apmail-incubator-crunch-dev-archive@incubator.apache.org Received: (qmail 6972 invoked by uid 500); 17 Dec 2012 17:36:42 -0000 Mailing-List: contact crunch-dev-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: crunch-dev@incubator.apache.org Delivered-To: mailing list crunch-dev@incubator.apache.org Received: (qmail 5592 invoked by uid 99); 17 Dec 2012 17:36:19 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 17 Dec 2012 17:36:19 +0000 Date: Mon, 17 Dec 2012 17:36:19 +0000 (UTC) From: "Gabriel Reid (JIRA)" To: crunch-dev@incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (CRUNCH-128) Allow one stage of an MR pipeline to depend on another target being created MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/CRUNCH-128?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13534104#comment-13534104 ] Gabriel Reid commented on CRUNCH-128: ------------------------------------- On adding the two new PCollection methods: I'm ok with it if you guys are ok with it (I trust your combined judgement on such matters much more than my own). And yep, definitely +1 on moving sample and sort out of PCollection. > Allow one stage of an MR pipeline to depend on another target being created > --------------------------------------------------------------------------- > > Key: CRUNCH-128 > URL: https://issues.apache.org/jira/browse/CRUNCH-128 > Project: Crunch > Issue Type: Improvement > Reporter: Josh Wills > Attachments: CheckpointingIT.java, CRUNCH-128.patch, CRUNCH-128v2.patch, CRUNCH-128-with-op.patch > > > There are a couple of problems (e.g., mapside-joins, total orderings, etc.) where we need to guarantee that one PCollection has been written to the FileSystem before another MapReduce pipeline that depends on that file is allowed to run. This doesn't fit cleanly into the current set of abstractions for Crunch, which is why we force pipelines to execute via the run command to guarantee that the files have been created before the second stage is run. > We should add the ability for a particular PCollection to require that a SourceTarget instance has been created before it can be executed, and the planner should incorporate this information into the MR pipeline planning process. -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators For more information on JIRA, see: http://www.atlassian.com/software/jira