Good morning,
The request to the Storm Rest UI now is the next, in the same server that
Storm,
var sUrl = http://localhost:port/api/v1/cluster/summary;
$.ajaxSetup({
error: function(jqXHR, textStatus, response) {
console.log(jqXHR: + jqXHR);
Hi,
The software we having been developing is based on Esper, supporting
hot-deployment of esper engine (including event types and EPL statements),
and providing esper engine management .
Recently we consider running it in clusters. Since Esper is not horizontally
scalable, we use Storm as a
So your code still relies on Nimbus to propagate the fatjar to the other nodes?
From: John Reilly [mailto:j...@inconspicuous.org]
Sent: Monday, December 01, 2014 8:57 PM
To: user@storm.apache.org
Subject: Re: storm jar alternative
Strictly, I think the answer is yes but not the way you are
if you set spoutConfig.forceFromStart=true it will cause KafkaSpout to
ignore the existing offsets stored in the zookeeper and starts reading
from the beginning of the queue. It makes sense to have it in for the
first time you deploy the topology and for the next runs ( kill and
redeploy
Correct
On Tue, Dec 2, 2014 at 04:59 Brunner, Bill bill.brun...@baml.com wrote:
So your code still relies on Nimbus to propagate the fatjar to the other
nodes?
*From:* John Reilly [mailto:j...@inconspicuous.org]
*Sent:* Monday, December 01, 2014 8:57 PM
*To:* user@storm.apache.org
The message is always replayed from the Spout, you will have to add dedup
mechanism in B1 if you want to avoid duplicate processing.
Implementing trident still won’t help you for the use case you are trying to
solve. If you want intermediate bolts to dedup, you have to write the dedup
logic.
But i thought trident method ensures you read the message only once. while
in traditional kafkaSpout reads the message until it is processed
successfully. Am I missing something here? Help clarify this. Thanks.
--
Kushan Maskey
817.403.7500
M. Miller Associates http://mmillerassociates.com/
Not yet but I am working on it. You can track progress here:
https://issues.apache.org/jira/browse/STORM-561
On Tue, Dec 2, 2014 at 8:54 PM, yuhao yu...@easyway.net.cn wrote:
Hi,
Is it possible to build topology dynamically? For example, given some
topology configuration which can tell
thanks for clear answer, it really helped
-Original Message-
From: Harshalt;st...@harsha.iogt;
To: lt;user@storm.apache.orggt;;
Cc:
Sent: 2014-12-02 (화) 22:51:29
Subject: Re: is there a way for kafka spout to read from written zookeeper
offset
if you set
