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 46F66CDDD for ; Thu, 7 Aug 2014 17:44:37 +0000 (UTC) Received: (qmail 42638 invoked by uid 500); 7 Aug 2014 17:44:37 -0000 Delivered-To: apmail-falcon-dev-archive@falcon.apache.org Received: (qmail 42592 invoked by uid 500); 7 Aug 2014 17:44:37 -0000 Mailing-List: contact dev-help@falcon.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@falcon.incubator.apache.org Delivered-To: mailing list dev@falcon.incubator.apache.org Received: (qmail 42571 invoked by uid 99); 7 Aug 2014 17:44:37 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 07 Aug 2014 17:44:37 +0000 X-ASF-Spam-Status: No, hits=-2000.7 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.3] (HELO mail.apache.org) (140.211.11.3) by apache.org (qpsmtpd/0.29) with SMTP; Thu, 07 Aug 2014 17:44:38 +0000 Received: (qmail 40153 invoked by uid 99); 7 Aug 2014 17:44:12 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 07 Aug 2014 17:44:12 +0000 Date: Thu, 7 Aug 2014 17:44:12 +0000 (UTC) From: "Balu Vellanki (JIRA)" To: dev@falcon.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (FALCON-327) Simplify message passing framework MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 X-Virus-Checked: Checked by ClamAV on apache.org [ https://issues.apache.org/jira/browse/FALCON-327?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14089510#comment-14089510 ] Balu Vellanki commented on FALCON-327: -------------------------------------- I cloned falcon from https://github.com/apache/incubator-falcon and then started reviewing patchs for https://issues.apache.org/jira/browse/FALCON-327. I applied patch for JIRA 484, 485, 486, 487, 488, 492. - Looking at comments, 484 and 485 seem like they have been reviewed. - The merge does not happen in a clean manner for OozieCoordinatorBuilder.java. - Cant find class EntityInstanceMessage at line 686,687 in file OozieProcessWorkflowBuilderTest it has been removed from source in patch FALCON-485-v3.patch and has not been added back. I did go through the code changes even though I could not build the cloned source after applying the patch. I do not see anything specific that needs fixing. Looking at code helped me understand the message passing framework. > Simplify message passing framework > ---------------------------------- > > Key: FALCON-327 > URL: https://issues.apache.org/jira/browse/FALCON-327 > Project: Falcon > Issue Type: Improvement > Components: messaging > Affects Versions: 0.5 > Reporter: Venkatesh Seetharam > Assignee: Venkatesh Seetharam > Labels: messaging > > Issues with the current implementation: > * hard to evolve the schema > If I need to add one attribute, requires change in various places > * Too many enum classes for the same variable > Confuses the heck out of me. Some small, some caps > * FalconPostProcessing gets args, parses the args into CLI and converts 'em back into args repeatedly > Too much redundant processing > * Timestamp should be long as opposed to a String - minor? > I need to compare dates and thought long is easier instead of constructing expensive SimpleDateFormats > * Hard dependency on JMS. > Suggest the following: > * Have the payload in a Map serialized as JSON > - wonder how to pass this from oozie > * Have one central Enum class for the keys in the payload > * Each class now depends on this Enum and takes what it needs from the Map > We also could rethink about the current messaging which falcon relies on (had started a discuss thread but did not get any response): > * Continue to use JMS > * Switch to FS Polling > * Use both > Thoughts? -- This message was sent by Atlassian JIRA (v6.2#6252)