Return-Path: X-Original-To: apmail-storm-user-archive@minotaur.apache.org Delivered-To: apmail-storm-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id BE64B111CC for ; Mon, 28 Jul 2014 11:09:17 +0000 (UTC) Received: (qmail 20292 invoked by uid 500); 28 Jul 2014 11:09:17 -0000 Delivered-To: apmail-storm-user-archive@storm.apache.org Received: (qmail 20251 invoked by uid 500); 28 Jul 2014 11:09:17 -0000 Mailing-List: contact user-help@storm.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@storm.incubator.apache.org Delivered-To: mailing list user@storm.incubator.apache.org Received: (qmail 20241 invoked by uid 99); 28 Jul 2014 11:09:17 -0000 Received: from Unknown (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 28 Jul 2014 11:09:17 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of abhishekroyn@gmail.com designates 209.85.217.169 as permitted sender) Received: from [209.85.217.169] (HELO mail-lb0-f169.google.com) (209.85.217.169) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 28 Jul 2014 11:08:59 +0000 Received: by mail-lb0-f169.google.com with SMTP id s7so5698854lbd.0 for ; Mon, 28 Jul 2014 04:08:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:date:message-id:subject:from:to:content-type; bh=J3JtZ4l9zFV6bAzKBvHR7dCGB3roOg0sMC+JF8PVpgc=; b=B21sc1CLRHJHAFuJaAM3ATjGxASRi/puhJ3Her+SMNtC7XYk/cvy30uufo5DRn4sSJ Va6NaypO+nTkCo9BlaKFqd5HKgaJWhA8ht9VLlofSmp5v+9R4sApvGFLyzuKIGbjmY9h w7iYSOjnXgtIY3CYthRwIdZX1gda2QoqqpPATtLE2jDqR5W0IkZvTl4cDmIMPUoHzGPM ht1jdHThpMzPOWyoMai7C/Yf4fAOrdA583qJvWCzmlsf9w1ZXldvsgOZAX0d3N0MZhWi /Q/371OPKfbimWy6wxrfF0gcWmil3Gfkt2TBby6JjpAySNB1fwa9Y+1BB2SCbtgVF+ga FnVw== MIME-Version: 1.0 X-Received: by 10.112.154.134 with SMTP id vo6mr2342652lbb.92.1406545714902; Mon, 28 Jul 2014 04:08:34 -0700 (PDT) Received: by 10.112.12.38 with HTTP; Mon, 28 Jul 2014 04:08:34 -0700 (PDT) Date: Mon, 28 Jul 2014 06:08:34 -0500 Message-ID: Subject: Serialization issue in storm spouts and bolts (methods running on different threads) From: Abhishek Roy To: user@storm.incubator.apache.org Content-Type: multipart/alternative; boundary=089e01227730b27da304ff3ef142 X-Virus-Checked: Checked by ClamAV on apache.org --089e01227730b27da304ff3ef142 Content-Type: text/plain; charset=ISO-8859-1 Hi guys, I am new to Storm and trying to use storm-0.9.1-incubating in our project. I noticed that I have Spout methods (open() and nextTuple() each running on different threads) whereas I need each of spout methods to be executed by same threads. Same is the case with Bolt methods (prepare() and execute()). Any quick suggestion would be helpful. Thanks and Regards, Abhishek Roy --089e01227730b27da304ff3ef142 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
Hi guys,

I am new to Storm a= nd trying to use storm-0.9.1-incubating in our project.
I noticed= that I have Spout methods (open() and nextTuple() each running on differen= t threads) whereas I need each of spout methods to be executed by same thre= ads.
Same is the case with Bolt methods (prepare() and execute()).=A0
=
Any quick suggestion would be helpful.

Thanks and Regards,
Abhishek Roy
--089e01227730b27da304ff3ef142--