Re: RE: is stateful bolts production ready?

2017-08-10 Thread
In addition to the query, what is the intent of stateful bolt since we can just hold state in bolt instance? wangchunc...@outlook.com From: Wijekoon, Manusha Date: 2017-08-10 18:56 To:

Re: Re: is stateful bolts production ready?

2017-08-11 Thread
/github.com/apache/storm/blob/master/external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java From: 王 纯超 <wangchunc...@outlook.com<mailto:wangchunc...@outlook.com>> Reply-To: "user@storm.apache.org<mailto:user@storm.apache.org>" <user@

Re: Re: Executor Change

2017-08-05 Thread
Thanks, Bobby. Stateful bolt requires reliable processing guarantee, but in my case, it is abandoned for my specific requirement. Thus I tried to save the state myself in the bolt's close method, which did not work. The state was not saved. So how to store the state and when is close method

Re: Re: Worker Profiling

2017-08-09 Thread
Hi Bobby, I am using Storm 1.1.0. Oh, I forgot. F.Y.I, before I turn on the feature, the section is displayed. However, according to kishorvpatil's comment(https://issues.apache.org/jira/browse/STORM-1157?jql=text%20~%20%22Worker%20profiling%22) , it shouldn't. Is this a problem? In

Storm-HBase: OperationConflictException

2017-09-22 Thread
Hi all, Below error occurs occasionally. What's the possible cause? I am using Storm 1.1.0. And I have two bolt writing to HBase, both have two tasks. But the other bolt does not have this error. Their writing speeds are approximately the same. And the keyspace is far more larger than the

回复: NodeCache Notification Failure

2018-07-10 Thread
Sorry for some mistakes in the description. The fact is some Bolts missed some notifications from Zookeeper when the node changed or the said notifications were not triggered at all. I do not know which case it is actually. wangchunc...@outlook.com 发件人: 王 纯超

NodeCache Notification Failure

2018-07-08 Thread
Hi all, I want to have Storm respond to outside notification and update Bolt state accordingly. Currently, I am using Zookeeper to achieve this by making the Bolt watch a specific Zookeeper node (through NodeCache). There are a lot of Bolts, of high parallelism, watching the same node. But it