Re: [DISCUSSION] Apache Storm and moving to the Attic

I agree with Taylor, and suggest Taylor as the new PMC chair (he is the former Storm PMC chair, has rich experience in community operation and management). Rui Abreu 于2023年2月3日周五 08:21写道： > Storm is a very successful project, even before the major re-write that > happened on version 2.x. > The

Re: storm versions with jdk versions

Hi sam, Storm 0.9.x -> JDK1.6+ Storm 0.10.x -> JDK1.7+ Storm 1.x -> JDK1.7+ Storm 2.x -> JDK1.8+ IMHO, I recommend you to use the latest 1.1.x release. Thanks, Xin 2017-07-10 21:27 GMT+08:00 sam mohel : > Is there any help , please? > > On Monday, July 10, 2017, sam

Re: Is Java8 supported by Storm?

Hi Hector, The Storm 2.0 needs JDK 1.8. Seems like the documents should be updated. And you can write a bolt using Java8 Lambda. Example: https://github.com/apache/storm/blob/master/examples/storm-starter/src/jvm/org/apache/storm/starter/LambdaTopology.java Thanks, Xin 2017-07-10 19:13

Re: Recording - Storm & Kafka Meetup on April 20th 2017

How about publishing this to Storm site? - Xin 2017-04-22 19:27 GMT+08:00 steve tueno : > great > > Thanks > > > > Cordialement, > > TUENO FOTSO Steve Jeffrey > Ingénieur de conception > Génie Informatique > +237 676 57 17 28 <+237%206%2076%2057%2017%2028> > +237 697 86

Re: [ANNOUNCE] Apache Storm 1.1.0 Released

Hi ipvp, Please read "Important Changes in the Binary Distribution" section in Storm 1.1.0 release document( http://storm.apache.org/2017/03/29/storm110-released.html). - Xin 2017-04-05 6:12 GMT+08:00 I PVP : > Hello, > > Did all the external integrations jars (under

Re: nimbus.thrift.max_buffer_size

Hi Qingxiang, For large topology, you can change the `nimbus.thrift.max_buffer_size` value to 5242880(5MB), default is 1048576(1MB). - Xin 2017-03-31 16:46 GMT+08:00 Antoine Tran : > https://issues.apache.org/jira/browse/STORM-1469 > > On 31/03/2017 05:37, 马庆祥

Re: failed to upgrade storm from 0.9.5 to 1.0.3

Hi daxwang, According to the trace, the ClassLoader loaded the old storm-core. I wonder if you packaged old storm-core in your fat topology jar. Remove it if true. - Xin Wang 2017-03-09 15:34 GMT+08:00 daxwang(王文军) <daxw...@tencent.com>: > > i want to upgrade my topology from 0.

Re: Storm Flux Viewer

Hi Ambud, Thanks for your nice work. I tested it. Looks good. This can be a useful tool for flux users. - Xin 2017-02-03 5:08 GMT+08:00 Ambud Sharma : > Put together a simple webpage to visualize Flux YAML files to help > troubleshooting and development of Flux based

Re: moving from storm 0.9.3 to storm 1.0.1

Hi Ohad, You can try setting topology.backpressure.enable: false -Xin Wang (vesense) 2016-11-30 17:58 GMT+08:00 Ohad Edelstein <oh...@mintigo.com>: > We are in the process of upgrading our storm infra from 0.9.3 to 1.0.1 > We are running python in the storm. > We moved for t

Re: Containerising Storm

Hi AI, You can take a look at the `Container, Resource Management System Integration` part in https://issues.apache.org/jira/browse/STORM-2209 Thanks, Xin Wang (vesense) 2016-11-23 16:00 GMT+08:00 <samuel.buch...@swisscom.com>: > Maybe http://highscalability.com/blog/2016/4/2

Re: Spout stops running after some times

I created a Jira(https://issues.apache.org/jira/browse/STORM-2181) for this. 2016-11-01 21:49 GMT+08:00 Xin Wang <data.xinw...@gmail.com>: > hi Junguk, > > About back-pressure:: > Storm 1.0.2 disabled back-pressure by default. you can take a try. > IMHO, the back-pressure

Re: Spout stops running after some times

hi Junguk, About back-pressure:: Storm 1.0.2 disabled back-pressure by default. you can take a try. IMHO, the back-pressure feature is not mature enough. I find similar situation in our product environment. so we disabled it. Please let me know your test result after disabling it. Thanks, Xin

Re: Assignment of threads to tcp ports

we plan to contribute our UserDefinedScheduler to community this or next month. https://issues.apache.org/jira/browse/STORM-2033 the UserDefinedScheduler support specifying nodes and ports for topology and its components. 2016-09-02 0:52 GMT+08:00 Kyle Nusbaum : > Yep!

Re: Error in setBolt("cassandra", new CassandraWriterBolt());

recommend upgrading both storm-core and storm-cassandra to 1.0.1. and refer to the NOTE in 1.0.1 release docs: http://storm.apache.org/releases/1.0.1/index.html 2016-07-14 16:42 GMT+08:00 Jungtaek Lim : > Sorry forgot to paste: backtype.storm -> org.apache.storm > > 2016년 7월

Re: Storm Shared Memory

Now Storm no concept like 'shared memory' you should use external resources. As a reference, you can take a look at `storm-redis` https://github.com/apache/storm/tree/master/external/storm-redis. 2016-07-13 21:21 GMT+08:00 Stephen Powis : > You'd need to use some external

Re: Multilang, C and binary data

Thanks Brian, I will add these links to https://issues.apache.org/jira/browse/STORM-1658 , and solve these issues as far as possible. Xin 2016-03-29 0:57 GMT+08:00 Brian Candler <b.cand...@pobox.com>: > On 27/03/2016 05:03, Xin Wang wrote: > >> RAS: >> http://storm.a

Re: Multilang, C and binary data

RAS: http://storm.apache.org/releases/2.0.0-SNAPSHOT/Resource_Aware_Scheduler_overview.html CGroup: http://storm.apache.org/releases/2.0.0-SNAPSHOT/cgroups_in_storm.html 2016-03-24 16:59 GMT+08:00 Brian Candler <b.cand...@pobox.com>: > On 23/03/2016 03:37, Xin Wang wrote: > >

Re: Multilang, C and binary data

I have provided an implementation `MessagePackSerializer` for improving muti-lang performance. (PR: https://github.com/apache/storm/pull/1136). You can take a look at this. It's not merged yet. Thanks, Xin 2016-03-22 18:37 GMT+08:00 Brian Candler : > Hello, > > I have