Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 1F642200BDB for ; Mon, 28 Nov 2016 02:56:03 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 1DF6E160B20; Mon, 28 Nov 2016 01:56:03 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id 64FB7160B12 for ; Mon, 28 Nov 2016 02:56:02 +0100 (CET) Received: (qmail 65871 invoked by uid 500); 28 Nov 2016 01:56:01 -0000 Mailing-List: contact issues-help@eagle.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@eagle.incubator.apache.org Delivered-To: mailing list issues@eagle.incubator.apache.org Received: (qmail 65862 invoked by uid 99); 28 Nov 2016 01:56:01 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 28 Nov 2016 01:56:01 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id EF25FC0333 for ; Mon, 28 Nov 2016 01:56:00 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -7.018 X-Spam-Level: X-Spam-Status: No, score=-7.018 tagged_above=-999 required=6.31 tests=[KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999, URIBL_BLOCKED=0.001] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id zLSUq9KBLax2 for ; Mon, 28 Nov 2016 01:56:00 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 4E8505F256 for ; Mon, 28 Nov 2016 01:55:59 +0000 (UTC) Received: (qmail 65826 invoked by uid 99); 28 Nov 2016 01:55:58 -0000 Received: from arcas.apache.org (HELO arcas) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 28 Nov 2016 01:55:58 +0000 Received: from arcas.apache.org (localhost [127.0.0.1]) by arcas (Postfix) with ESMTP id 535972C03DB for ; Mon, 28 Nov 2016 01:55:58 +0000 (UTC) Date: Mon, 28 Nov 2016 01:55:58 +0000 (UTC) From: "ASF GitHub Bot (JIRA)" To: issues@eagle.incubator.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Commented] (EAGLE-794) Enable publish bolt parallelism MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 archived-at: Mon, 28 Nov 2016 01:56:03 -0000 [ https://issues.apache.org/jira/browse/EAGLE-794?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15700672#comment-15700672 ] ASF GitHub Bot commented on EAGLE-794: -------------------------------------- GitHub user garrettlish opened a pull request: https://github.com/apache/incubator-eagle/pull/687 EAGLE-794: enable publish bolt parallelism Currently the publish is using shuffle grouping, we cannot enable parallelism for publish since we may have local cache which is unavailable across the storm cluster. We are going to use field group function to partition streams for publish bolt parallelism. You can merge this pull request into a Git repository by running: $ git pull https://github.com/garrettlish/incubator-eagle eagle794 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/incubator-eagle/pull/687.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #687 ---- commit 505a32ae576689e9012a80346c6f005c3082de42 Author: Xiancheng Li Date: 2016-11-25T01:47:41Z EAGLE-794: enable publish bolt parallelism ---- > Enable publish bolt parallelism > ------------------------------- > > Key: EAGLE-794 > URL: https://issues.apache.org/jira/browse/EAGLE-794 > Project: Eagle > Issue Type: Improvement > Affects Versions: v0.5.0 > Reporter: Garrett Li > Assignee: Garrett Li > Fix For: v0.5.0 > > > Currently the publish is using shuffle grouping, we cannot enable parallelism for publish since we may have local cache which is unavailable across the storm cluster. > We are going to use the same strategy as router bolts to alert bolts, which is using field grouping (define empty list of field) and dispatch tuple according to group by fields hashing. -- This message was sent by Atlassian JIRA (v6.3.4#6332)