Return-Path: X-Original-To: apmail-falcon-dev-archive@minotaur.apache.org Delivered-To: apmail-falcon-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 B41A817F19 for ; Tue, 16 Jun 2015 04:24:40 +0000 (UTC) Received: (qmail 80446 invoked by uid 500); 16 Jun 2015 04:24:40 -0000 Delivered-To: apmail-falcon-dev-archive@falcon.apache.org Received: (qmail 80399 invoked by uid 500); 16 Jun 2015 04:24:40 -0000 Mailing-List: contact dev-help@falcon.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@falcon.apache.org Delivered-To: mailing list dev@falcon.apache.org Received: (qmail 80381 invoked by uid 99); 16 Jun 2015 04:24:40 -0000 Received: from Unknown (HELO spamd2-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Jun 2015 04:24:40 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd2-us-west.apache.org (ASF Mail Server at spamd2-us-west.apache.org) with ESMTP id BBE9E1A5668 for ; Tue, 16 Jun 2015 04:24:39 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd2-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 3.992 X-Spam-Level: *** X-Spam-Status: No, score=3.992 tagged_above=-999 required=6.31 tests=[HEADER_FROM_DIFFERENT_DOMAINS=0.001, HTML_MESSAGE=3, KAM_LAZY_DOMAIN_SECURITY=1, T_RP_MATCHES_RCVD=-0.01, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-us-east.apache.org ([10.40.0.8]) by localhost (spamd2-us-west.apache.org [10.40.0.9]) (amavisd-new, port 10024) with ESMTP id HZCm2S6-cGwG for ; Tue, 16 Jun 2015 04:24:33 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-us-east.apache.org (ASF Mail Server at mx1-us-east.apache.org) with SMTP id CBA9B429A9 for ; Tue, 16 Jun 2015 04:24:32 +0000 (UTC) Received: (qmail 80324 invoked by uid 99); 16 Jun 2015 04:24:32 -0000 Received: from reviews-vm.apache.org (HELO reviews.apache.org) (140.211.11.40) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 16 Jun 2015 04:24:32 +0000 Received: from reviews.apache.org (localhost [127.0.0.1]) by reviews.apache.org (Postfix) with ESMTP id 928CA1DFE5F; Tue, 16 Jun 2015 04:24:31 +0000 (UTC) Content-Type: multipart/alternative; boundary="===============8534628989095144190==" MIME-Version: 1.0 Subject: Re: Review Request 35468: FeedReplicator improvement to include more DistCP options From: "Pallavi Rao" To: "Venkat Ranganathan" , "Srikanth Sundarrajan" , "Pallavi Rao" Cc: "Sowmya Ramesh" , "Falcon" Date: Tue, 16 Jun 2015 04:24:31 -0000 Message-ID: <20150616042431.19659.44159@reviews.apache.org> X-ReviewBoard-URL: https://reviews.apache.org/ Auto-Submitted: auto-generated Sender: "Pallavi Rao" X-ReviewGroup: Falcon X-Auto-Response-Suppress: DR, RN, OOF, AutoReply X-ReviewRequest-URL: https://reviews.apache.org/r/35468/ X-Sender: "Pallavi Rao" References: <20150615181042.32039.76108@reviews.apache.org> In-Reply-To: <20150615181042.32039.76108@reviews.apache.org> Reply-To: "Pallavi Rao" X-ReviewRequest-Repository: falcon-git --===============8534628989095144190== MIME-Version: 1.0 Content-Type: text/plain; charset="utf-8" Content-Transfer-Encoding: 7bit ----------------------------------------------------------- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/35468/#review88025 ----------------------------------------------------------- docs/src/site/twiki/EntitySpecification.twiki (line 293) The Distcp Options do not exactly match the options you have listed above. For example, -pr of Distcp is preserveReplicationNumber of Falcon. Given that, I think we should list the options as we support it, in Falcon documentation. oozie/src/main/java/org/apache/falcon/oozie/OozieOrchestrationWorkflowBuilder.java (line 150) Repititive code. May be we can define the Replication options supported as enum and just have one for loop to iterate over the enum values. - Pallavi Rao On June 15, 2015, 6:10 p.m., Sowmya Ramesh wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/35468/ > ----------------------------------------------------------- > > (Updated June 15, 2015, 6:10 p.m.) > > > Review request for Falcon, Pallavi Rao, Srikanth Sundarrajan, and Venkat Ranganathan. > > > Bugs: FALCON-668 > https://issues.apache.org/jira/browse/FALCON-668 > > > Repository: falcon-git > > > Description > ------- > > FeedReplicator improvement to include more DistCP options listed below. User is expected to pass these as custom properties in the feed defined for replicaiton and those will be propagated to DistCp tool. > > * overwrite > * ignore errors > * skip checksum > * remove deleted files > * preserve block size > * preserve replication count > * preserve permissions > > > Diffs > ----- > > common/src/main/java/org/apache/falcon/util/ReplicationConstants.java PRE-CREATION > docs/src/site/twiki/EntitySpecification.twiki 1ed2cb5 > oozie/src/main/java/org/apache/falcon/oozie/OozieOrchestrationWorkflowBuilder.java 49f9e07 > oozie/src/main/java/org/apache/falcon/oozie/feed/FSReplicationWorkflowBuilder.java 1d97204 > oozie/src/main/java/org/apache/falcon/oozie/feed/HCatReplicationWorkflowBuilder.java 72bbca4 > replication/src/main/java/org/apache/falcon/replication/FeedReplicator.java b2175b2 > replication/src/test/java/org/apache/falcon/replication/FeedReplicatorTest.java 539d00d > > Diff: https://reviews.apache.org/r/35468/diff/ > > > Testing > ------- > > Verified custom property added got propagated to FeedReplicator Java action and the replication succeeded. > > Action configuration: > > org.apache.falcon.replication.FeedReplicator > -Dfalcon.include.path=hftp://sandbox.hortonworks.com:50070/user/ambari-qa/dr/test/primaryCluster/feed/input/2015/06/08 > -Dmapred.job.queue.name=default > -Dmapred.job.priority=NORMAL > -maxMaps > 33 > -mapBandwidth > 2 > -sourcePaths > hftp://sandbox.hortonworks.com:50070/user/ambari-qa/dr/test/primaryCluster/feed/input/2015/06/08 > -targetPath > hdfs://sandbox.hortonworks.com:8020/user/ambari-qa/dr/test/backupCluster/feed/output/2015/06/08 > -falconFeedStorageType > FILESYSTEM > -availabilityFlag > NA > -overwrite > true > -ignoreErrors > false > -preservePermissions > false > > > Thanks, > > Sowmya Ramesh > > --===============8534628989095144190==--