答复: [DISCUSS] Initial 0.11.0 Release

John Fang -邮件原件- 发件人: P. Taylor Goetz [mailto:ptgo...@gmail.com] 发送时间: 2015年11月11日 6:16 收件人: dev@storm.apache.org 主题: [DISCUSS] Initial 0.11.0 Release I’d like to start discussing our next release (0.11.0). First off, I’d like to create a list of issues/features that are in-progress

答复: load configurations to topology

As we know, the priority order of the configuration is : CommandLine > user stormconf > storm.yaml > defaults.yaml -邮件原件- 发件人: jinhong lu [mailto:lujinho...@gmail.com] 发送时间: 2015年11月16日 12:57 收件人: dev@storm.apache.org 主题: load configurations to topology Hi, I do not understand the

答复: Re: java.lang.OutOfMemoryError: Direct buffer memory

You can add -verbose:gc -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation for nimbus and supervisor, so it can produce .gc log. Then you check your supervisor's gc log and nimbus's gc log. At the same time, you can check jstack

答复: supervisor的讨论

Sorry to send the wrong post. Everyone can browse : https://issues.apache.org/jira/browse/STORM-1279 发件人: John Fang [mailto:xiaojian@alibaba-inc.com] 发送时间: 2015年11月27日 20:16 收件人: dev@storm.apache.org; Longda Feng 主题: supervisor的讨论

supervisor的讨论

Discussion about supervisor.docx Description: MS-Word 2007 document

答复: Supervisor terminated without raising any error

Sorry， I can’t see the picture. OOM 、insufficient disk space、Full GC and so on。 发件人: Renya nath N [mailto:renyan...@gmail.com] 发送时间: 2015年11月26日 0:22 收件人: dev@storm.apache.org 主题: Supervisor terminated without raising any error Hi, Can you ease tell me why Supervisor terminated

答复: [DISCUSS] Plan for Merging JStorm Code

Hi Taylor, I'd like to help too, could you add me in? my id is: hustfxj -邮件原件- 发件人: P. Taylor Goetz [mailto:ptgo...@gmail.com] 发送时间: 2015年11月24日 23:54 收件人: dev@storm.apache.org 主题: Re: [DISCUSS] Plan for Merging JStorm Code Hi Cody, I wasn’t able to find your username. Are you sure you

答复: supervisor的讨论

a discussion thread around it. Thanks, Harsha On Fri, Nov 27, 2015, at 04:15 AM, John Fang wrote: > > Email had 1 attachment: > * Discussion about supervisor.docx 25k (application/vnd.openxmlformats- >officedocument.wordprocessingml.document)

答复: [VOTE] Storm 2.0 plan

+1 -邮件原件- 发件人: Cody Innowhere [mailto:e.neve...@gmail.com] 发送时间: 2015年11月24日 17:41 收件人: dev@storm.apache.org 抄送: Bobby Evans 主题: Re: [VOTE] Storm 2.0 plan +1 for this plan. Also +1 for starting evaluation solutions of major feature differences early before starting migration to avoid

答复: what should be in /etc/hosts ?

It has better configure domain and ip ; -邮件原件- 发件人: researcher cs [mailto:prog.researc...@gmail.com] 发送时间: 2016年1月11日 7:44 收件人: dev@storm.apache.org; u...@storm.apache.org 主题: what should be in /etc/hosts ? i need to submit topology in single machine first can i ? and what should be

答复: [DISCUSS] Java REST Framework adoption

+1 for DropWizard -邮件原件- 发件人: Hugo Da Cruz Louro [mailto:hlo...@hortonworks.com] 发送时间: 2016年2月24日 6:36 收件人: dev@storm.apache.org 主题: Re: [DISCUSS] Java REST Framework adoption I also vote on DropWizard > On Feb 23, 2016, at 2:29 PM, Parth Brahmbhatt >

答复: Publish Subscribe Model using Apache Storm

Can you supply more information? You can refer to storm/external/storm-kafka. -邮件原件- 发件人: Vigneshwaran Ganesan [mailto:vigneshwaran.gane...@gmail.com] 发送时间: 2016年3月10日 4:08 收件人: d...@storm.incubator.apache.org 主题: Publish Subscribe Model using Apache Storm Hi Team, I am planning to

why don't we relocate the kryo by maven-shade-plugin?

why don't we relocate the kryo by maven-shade-plugin? Due to the carbonite ? The conflict with kryo’s version happened sometime. Regards John Fang

答复: why don't we relocate the kryo by maven-shade-plugin?

orical reason. 发件人: Bobby Evans [mailto:ev...@yahoo-inc.com] 发送时间: 2016年4月5日 22:50 收件人: dev@storm.apache.org; John Fang 主题: Re: why don't we relocate the kryo by maven-shade-plugin? Because we expose kryo to the end users. They can add in their own plugins to serialize objects and if we

答复: [VOTE] Release Apache Storm 1.0.0 (rc2)

+1 Regards John Fang -邮件原件- 发件人: Bobby Evans [mailto:ev...@yahoo-inc.com.INVALID] 发送时间: 2016年4月8日 2:36 收件人: dev@storm.apache.org 主题: Re: [VOTE] Release Apache Storm 1.0.0 (rc2) Forgot to say +1 binding - Bobby On Thursday, April 7, 2016 1:36 PM, Bobby Evans <ev...@ya

答复: Question on Metrics Server to Alibaba team

rics work when TopologyMaster is down? > And how metrics work when failover of Nimbus occurs? > > Personally I don't mind losing metrics for short durations (just want > to check availability of H/A), but failure shouldn't mess up whole metrics. > > Thanks, > Jungtaek Lim (Hear

答复: Question on Metrics Server to Alibaba team

-邮件原件- 发件人: John Fang [mailto:xiaojian@alibaba-inc.com] 发送时间: 2016年3月23日 14:39 收件人: dev@storm.apache.org; 'Bobby Evans' 主题: 答复: Question on Metrics Server to Alibaba team @ Bobby Evans Jstorm code has experienced a lot of tests over the past few years, espatially HA

答复: Question on Metrics Server to Alibaba team

@ Bobby Evans Jstorm code has experienced a lot of tests over the past few years, espatially HA and scalability. We have done a lot of optimization about Metrics. The performance is better than Flink in my tests. In my personal opinion, the metric in jstorm offers very much informations. And

回复：[VOTE] Release Apache Storm 1.0.0 (rc1)

I hope we can release Apache storm 1.0.0 in mid, I am doing tests. Of course, now I can't find some bugs.

答复: 答复: Question on Metrics Server to Alibaba team

t actually that > >complex to setup and run). > > If we feel that we must have some external state store that is > >required for storm to run, then we need to make the decision > >carefully and deliberately. > > - Bobby > > > >On Wednesday, March 23, 2

答复: [VOTE] Release Apache Storm 1.0.1

Thank you for Jungtaek, I also hope we can do another candidate with these fixed in. -邮件原件- 发件人: Harsha [mailto:st...@harsha.io] 发送时间: 2016年4月27日 10:20 收件人: dev@storm.apache.org 主题: Re: [VOTE] Release Apache Storm 1.0.1 I am +1 on doing another release candidate with these fixes in.

答复: [DISCUSSION] Version lines of 1.x

I'm also think we shouldn't maintain 0.10.x branch -邮件原件- 发件人: Cody Innowhere [mailto:e.neve...@gmail.com] 发送时间: 2016年5月9日 19:42 收件人: dev@storm.apache.org 主题: Re: [DISCUSSION] Version lines of 1.x I'm also +1 for maintaining 1.x branch & master and not maintaining 0.10.x branch. On

[jira] [Commented] (STORM-162) Load Balancing Shuffle Grouping

[ https://issues.apache.org/jira/browse/STORM-162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=14988849#comment-14988849 ] John Fang commented on STORM-162: - +1 > Load Balancing Shuffle Group

[jira] [Commented] (STORM-1365) Small improvements in Travis scripts

[ https://issues.apache.org/jira/browse/STORM-1365?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15044224#comment-15044224 ] John Fang commented on STORM-1365: -- +1 > Small improvements in Travis scri

[jira] [Commented] (STORM-1452) Worker "profiler" actions broken by default

[ https://issues.apache.org/jira/browse/STORM-1452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15088515#comment-15088515 ] John Fang commented on STORM-1452: -- +1 > Worker "profiler" actions brok

[jira] [Assigned] (STORM-1320) Port JStorm scheduler to storm

[ https://issues.apache.org/jira/browse/STORM-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1320: Assignee: John Fang > Port JStorm scheduler to st

[jira] [Assigned] (STORM-1321) Evaluate/Port JStorm nimbus HA

[ https://issues.apache.org/jira/browse/STORM-1321?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1321: Assignee: John Fang > Evaluate/Port JStorm nimbus

[jira] [Assigned] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1279: Assignee: John Fang > port backtype.storm.daemon.supervisor to j

[jira] [Assigned] (STORM-1328) Evaluate/Port JStorm tuple groupings

[ https://issues.apache.org/jira/browse/STORM-1328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1328: Assignee: John Fang > Evaluate/Port JStorm tuple groupi

[jira] [Commented] (STORM-1351) Storm spouts and bolts need a way to communicate problems back to toplogy runner

[ https://issues.apache.org/jira/browse/STORM-1351?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029354#comment-15029354 ] John Fang commented on STORM-1351: -- Implementing ISpoutWaitStrategy is enough to solve the problem

[jira] [Updated] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1279: - Attachment: Discussion about supervisor.pdf I review the superviosor of Storm JStorm’s supervisor

[jira] [Comment Edited] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029820#comment-15029820 ] John Fang edited comment on STORM-1279 at 11/27/15 12:50 PM: - I review

[jira] [Updated] (STORM-1320) Port JStorm scheduler to storm

[ https://issues.apache.org/jira/browse/STORM-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1320: - Attachment: Discussion about sheduler.pdf In fact Jstorm’s default scheduler is similar to Storm’s

[jira] [Commented] (STORM-1232) port backtype.storm.scheduler.DefaultScheduler to java

[ https://issues.apache.org/jira/browse/STORM-1232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029902#comment-15029902 ] John Fang commented on STORM-1232: -- Hi, I would like to discuss about the Storm's default scheduler. I

[jira] [Comment Edited] (STORM-1232) port backtype.storm.scheduler.DefaultScheduler to java

[ https://issues.apache.org/jira/browse/STORM-1232?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15029902#comment-15029902 ] John Fang edited comment on STORM-1232 at 11/27/15 2:10 PM: Hi, I would like

[jira] [Assigned] (STORM-1243) port backtype.storm.command.healthcheck to java

[ https://issues.apache.org/jira/browse/STORM-1243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1243: Assignee: John Fang > port backtype.storm.command.healthcheck to j

[jira] [Commented] (STORM-1243) port backtype.storm.command.healthcheck to java

[ https://issues.apache.org/jira/browse/STORM-1243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023544#comment-15023544 ] John Fang commented on STORM-1243: -- I hava ported the healthcheck to java in jstorm，so this issue maybe

[jira] [Commented] (STORM-1320) Port JStorm scheduler to storm

[ https://issues.apache.org/jira/browse/STORM-1320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15023552#comment-15023552 ] John Fang commented on STORM-1320: -- can I supplement more information about JStorm scheduler before

[jira] [Assigned] (STORM-1262) port backtype.storm.command.dev-zookeeper to java

[ https://issues.apache.org/jira/browse/STORM-1262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1262: Assignee: John Fang > port backtype.storm.command.dev-zookeeper to j

[jira] [Assigned] (STORM-1273) port backtype.storm.cluster to java

[ https://issues.apache.org/jira/browse/STORM-1273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1273: Assignee: John Fang > port backtype.storm.cluster to j

[jira] [Commented] (STORM-1257) port backtype.storm.zookeeper to java

[ https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15097590#comment-15097590 ] John Fang commented on STORM-1257: -- I am merging zookeeper now, cluster is linked with zookeeper

[jira] [Assigned] (STORM-1257) port backtype.storm.zookeeper to java

[ https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1257: Assignee: John Fang (was: Basti Liu) > port backtype.storm.zookeeper to j

[jira] [Commented] (STORM-1257) port backtype.storm.zookeeper to java

[ https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15116987#comment-15116987 ] John Fang commented on STORM-1257: -- please look at https://github.com/apache/storm/pull/1047 > p

[jira] [Assigned] (STORM-1277) port backtype.storm.daemon.executor to java

[ https://issues.apache.org/jira/browse/STORM-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1277: Assignee: John Fang > port backtype.storm.daemon.executor to j

[jira] [Commented] (STORM-1578) ClassCastException from Integer to Long for "port" in cluster.clj translation

[ https://issues.apache.org/jira/browse/STORM-1578?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168387#comment-15168387 ] John Fang commented on STORM-1578: -- Thank you [~zhuoliu] > ClassCastException from Integer to L

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15168494#comment-15168494 ] John Fang commented on STORM-1279: -- I finished porting supervisor to java, but I want to get some more

[jira] [Commented] (STORM-1582) asyncLoop will calls repeatedly when the return type of call only is Long

[ https://issues.apache.org/jira/browse/STORM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15171571#comment-15171571 ] John Fang commented on STORM-1582: -- I know your means. Only I think it maybe hard code. Because we don't

[jira] [Commented] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15167193#comment-15167193 ] John Fang commented on STORM-1279: -- I have finished port backtype.storm.daemon.supervisor to java. I

[jira] [Created] (STORM-1589) port the webapp portion of drpc.clj over to java

John Fang created STORM-1589: Summary: port the webapp portion of drpc.clj over to java Key: STORM-1589 URL: https://issues.apache.org/jira/browse/STORM-1589 Project: Apache Storm Issue Type

[jira] [Created] (STORM-1590) port metrics.meters to java for all of our code to use

John Fang created STORM-1590: Summary: port metrics.meters to java for all of our code to use Key: STORM-1590 URL: https://issues.apache.org/jira/browse/STORM-1590 Project: Apache Storm Issue

[jira] [Created] (STORM-1582) asyncLoop will calls repeatedly when the return type of call only is Long

John Fang created STORM-1582: Summary: asyncLoop will calls repeatedly when the return type of call only is Long Key: STORM-1582 URL: https://issues.apache.org/jira/browse/STORM-1582 Project: Apache

[jira] [Commented] (STORM-1582) asyncLoop will calls repeatedly when the return type of call only is Long

[ https://issues.apache.org/jira/browse/STORM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15170587#comment-15170587 ] John Fang commented on STORM-1582: -- Thank you [~kabhwan] . I are confused with the return, because

[jira] [Created] (STORM-1572) throw NPE when parsing the command line arguments by CLI

John Fang created STORM-1572: Summary: throw NPE when parsing the command line arguments by CLI Key: STORM-1572 URL: https://issues.apache.org/jira/browse/STORM-1572 Project: Apache Storm Issue

[jira] [Created] (STORM-1506) It's better to be Integer about port of STORM_ZOOKEEPER_PORT_ZOOKEEPER_PORT

John Fang created STORM-1506: Summary: It's better to be Integer about port of STORM_ZOOKEEPER_PORT_ZOOKEEPER_PORT Key: STORM-1506 URL: https://issues.apache.org/jira/browse/STORM-1506 Project: Apache

[jira] [Updated] (STORM-1506) It's better to be Integer about port of STORM_ZOOKEEPER_PORT_ZOOKEEPER_PORT

[ https://issues.apache.org/jira/browse/STORM-1506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1506: - Description: It's better to replace Object by Integer about port of STORM_ZOOKEEPER_PORT_ZOOKEEPER_PORT

[jira] [Created] (STORM-1553) port backtype.storm.event to java

John Fang created STORM-1553: Summary: port backtype.storm.event to java Key: STORM-1553 URL: https://issues.apache.org/jira/browse/STORM-1553 Project: Apache Storm Issue Type: New Feature

[jira] [Commented] (STORM-1553) port backtype.storm.event to java

[ https://issues.apache.org/jira/browse/STORM-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148236#comment-15148236 ] John Fang commented on STORM-1553: -- https://github.com/apache/storm/pull/1110 > p

[jira] [Commented] (STORM-1243) port backtype.storm.command.healthcheck to java

[ https://issues.apache.org/jira/browse/STORM-1243?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148362#comment-15148362 ] John Fang commented on STORM-1243: -- [~revans2] I am sorry. I create the PR which is https://github.com

[jira] [Issue Comment Deleted] (STORM-1243) port backtype.storm.command.healthcheck to java

[ https://issues.apache.org/jira/browse/STORM-1243?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1243: - Comment: was deleted (was: [~revans2] I am sorry. I create the PR which is https://github.com/apache

[jira] [Assigned] (STORM-1279) port backtype.storm.daemon.supervisor to java

[ https://issues.apache.org/jira/browse/STORM-1279?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1279: Assignee: John Fang (was: Basti Liu) > port backtype.storm.daemon.supervisor to j

[jira] [Assigned] (STORM-1273) port backtype.storm.cluster to java

[ https://issues.apache.org/jira/browse/STORM-1273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1273: Assignee: John Fang (was: Basti Liu) > port backtype.storm.cluster to j

[jira] [Commented] (STORM-1262) port backtype.storm.command.dev-zookeeper to java

[ https://issues.apache.org/jira/browse/STORM-1262?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15148486#comment-15148486 ] John Fang commented on STORM-1262: -- https://github.com/apache/storm/pull/1113 > p

[jira] [Assigned] (STORM-1553) port backtype.storm.event to java

[ https://issues.apache.org/jira/browse/STORM-1553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1553: Assignee: John Fang > port backtype.storm.event to j

[jira] [Assigned] (STORM-1274) port backtype.storm.LocalDRPC to java

[ https://issues.apache.org/jira/browse/STORM-1274?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1274: Assignee: John Fang > port backtype.storm.LocalDRPC to j

[jira] [Assigned] (STORM-1270) port backtype.storm.daemon.drpc to java

[ https://issues.apache.org/jira/browse/STORM-1270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1270: Assignee: John Fang > port backtype.storm.daemon.drpc to j

[jira] [Commented] (STORM-1563) Replace Shutdownable to be AutoClosable

[ https://issues.apache.org/jira/browse/STORM-1563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15155864#comment-15155864 ] John Fang commented on STORM-1563: -- I agree with you. +1 > Replace Shutdownable to be AutoClosa

[jira] [Commented] (STORM-1562) Provide a pluggable ability to capture topology information on Nimbus (ISubmitterHook on Nimbus)

[ https://issues.apache.org/jira/browse/STORM-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15155869#comment-15155869 ] John Fang commented on STORM-1562: -- We can add ITopologyHook which can do a lot of monitor actions

[jira] [Assigned] (STORM-1286) port backtype.storm.command.kill-workers to java

[ https://issues.apache.org/jira/browse/STORM-1286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1286: Assignee: John Fang > port backtype.storm.command.kill-workers to j

[jira] [Assigned] (STORM-1318) Investigate if backtype.storm.command.shell-submission shuld be dropped

[ https://issues.apache.org/jira/browse/STORM-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1318: Assignee: John Fang > Investigate if backtype.storm.command.shell-submission shuld be drop

[jira] [Commented] (STORM-1630) "create symbolic link" needs elevation or setting privilege about creating symbolic link

[ https://issues.apache.org/jira/browse/STORM-1630?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196925#comment-15196925 ] John Fang commented on STORM-1630: -- not only leaving a few sentences to cover, but we can tell users how

[jira] [Commented] (STORM-1271) port backtype.storm.daemon.task to java

[ https://issues.apache.org/jira/browse/STORM-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196945#comment-15196945 ] John Fang commented on STORM-1271: -- [~abhishek.agarwal] Do you start worker with this Issue. I think it's

[jira] [Commented] (STORM-1318) Investigate if backtype.storm.command.shell-submission shuld be dropped

[ https://issues.apache.org/jira/browse/STORM-1318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196975#comment-15196975 ] John Fang commented on STORM-1318: -- [~revans2] I prefer that we can drop it. > Investig

[jira] [Commented] (STORM-1271) port backtype.storm.daemon.task to java

[ https://issues.apache.org/jira/browse/STORM-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15196982#comment-15196982 ] John Fang commented on STORM-1271: -- It's nice. Thank you > port backtype.storm.daemon.task to j

[jira] [Commented] (STORM-1623) nimbus.clj's minor bug

[ https://issues.apache.org/jira/browse/STORM-1623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15193278#comment-15193278 ] John Fang commented on STORM-1623: -- https://github.com/apache/storm/pull/1211 > nimbus.clj's minor

[jira] [Commented] (STORM-1688) provide ParallismKillWorkerManager to shutdown workers in parallel

[ https://issues.apache.org/jira/browse/STORM-1688?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15227613#comment-15227613 ] John Fang commented on STORM-1688: -- [~caofangkun] You can refer to jstorm, which shutdown workers

[jira] [Commented] (STORM-1635) Master branch broken! Exception thrown immediately after submitting topology

[ https://issues.apache.org/jira/browse/STORM-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15198534#comment-15198534 ] John Fang commented on STORM-1635: -- [~jerrypeng] I have fixed it. https://issues.apache.org/jira/browse

[jira] [Assigned] (STORM-1635) Master branch broken! Exception thrown immediately after submitting topology

[ https://issues.apache.org/jira/browse/STORM-1635?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1635: Assignee: John Fang > Master branch broken! Exception thrown immediately after submitting topol

[jira] [Created] (STORM-1650) improve performance by XORShiftRandom

John Fang created STORM-1650: Summary: improve performance by XORShiftRandom Key: STORM-1650 URL: https://issues.apache.org/jira/browse/STORM-1650 Project: Apache Storm Issue Type: Improvement

[jira] [Updated] (STORM-1650) improve performance by XORShiftRandom

[ https://issues.apache.org/jira/browse/STORM-1650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1650: - Description: '''Implement a random number generator based on the XORShift algorithm discovered by George

[jira] [Commented] (STORM-1271) port backtype.storm.daemon.task to java

[ https://issues.apache.org/jira/browse/STORM-1271?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15207721#comment-15207721 ] John Fang commented on STORM-1271: -- [~abhishek.agarwal] thank you > port backtype.storm.daemon.t

[jira] [Created] (STORM-1611) port org.apache.storm.pacemaker.pacemaker to java

John Fang created STORM-1611: Summary: port org.apache.storm.pacemaker.pacemaker to java Key: STORM-1611 URL: https://issues.apache.org/jira/browse/STORM-1611 Project: Apache Storm Issue Type

[jira] [Created] (STORM-1606) Travis CI can't print the infomation of the testcase which is on failure

John Fang created STORM-1606: Summary: Travis CI can't print the infomation of the testcase which is on failure Key: STORM-1606 URL: https://issues.apache.org/jira/browse/STORM-1606 Project: Apache

[jira] [Assigned] (STORM-615) Add REST API to upload topology

[ https://issues.apache.org/jira/browse/STORM-615?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-615: --- Assignee: John Fang > Add REST API to upload topol

[jira] [Commented] (STORM-1605) storm shell script should use /bin/env python to check python version

[ https://issues.apache.org/jira/browse/STORM-1605?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15182467#comment-15182467 ] John Fang commented on STORM-1605: -- It looks good to me， although we don't run storm.py directly

[jira] [Created] (STORM-1610) port pacemaker-state-factory-test to java

John Fang created STORM-1610: Summary: port pacemaker-state-factory-test to java Key: STORM-1610 URL: https://issues.apache.org/jira/browse/STORM-1610 Project: Apache Storm Issue Type: New

[jira] [Created] (STORM-1685) port local_supervisor.clj to java

John Fang created STORM-1685: Summary: port local_supervisor.clj to java Key: STORM-1685 URL: https://issues.apache.org/jira/browse/STORM-1685 Project: Apache Storm Issue Type: Improvement

[jira] [Commented] (STORM-1286) port backtype.storm.command.kill-workers to java

[ https://issues.apache.org/jira/browse/STORM-1286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15225465#comment-15225465 ] John Fang commented on STORM-1286: -- [~zhuoliu] ok, because I am working on the worker.clj. > p

[jira] [Updated] (STORM-1286) port backtype.storm.command.kill-workers to java

[ https://issues.apache.org/jira/browse/STORM-1286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1286: - Assignee: Zhuo Liu (was: John Fang) > port backtype.storm.command.kill-workers to j

[jira] [Assigned] (STORM-1582) asyncLoop will calls repeatedly when the return type of call only is Long

[ https://issues.apache.org/jira/browse/STORM-1582?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1582: Assignee: John Fang > asyncLoop will calls repeatedly when the return type of call only is L

[jira] [Assigned] (STORM-1589) port the webapp portion of drpc.clj over to java

[ https://issues.apache.org/jira/browse/STORM-1589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang reassigned STORM-1589: Assignee: John Fang > port the webapp portion of drpc.clj over to j

[jira] [Comment Edited] (STORM-1560) Topology stops processing after Netty catches/swallows Throwable

[ https://issues.apache.org/jira/browse/STORM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15215907#comment-15215907 ] John Fang edited comment on STORM-1560 at 3/29/16 12:09 PM: Connect.run() only

[jira] [Commented] (STORM-1560) Topology stops processing after Netty catches/swallows Throwable

[ https://issues.apache.org/jira/browse/STORM-1560?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15215907#comment-15215907 ] John Fang commented on STORM-1560: -- Connect.run() only calls Client.close() when closing is true. We see

[jira] [Commented] (STORM-1358) Porting JStorm multi-thread mode of spout to Storm

[ https://issues.apache.org/jira/browse/STORM-1358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15255165#comment-15255165 ] John Fang commented on STORM-1358: -- [~snisarg] we envision this merger happening in two phases major

[jira] [Commented] (STORM-834) Class cast exception Object to Iterable

[ https://issues.apache.org/jira/browse/STORM-834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15257359#comment-15257359 ] John Fang commented on STORM-834: - [~lonerzzz] In fact I come into the same problem before, but it haven't

[jira] [Commented] (STORM-1358) Porting JStorm multi-thread mode of spout to Storm

[ https://issues.apache.org/jira/browse/STORM-1358?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15253588#comment-15253588 ] John Fang commented on STORM-1358: -- I hope you can do it at phase 2. And you should test the trident when

[jira] [Commented] (STORM-1277) port backtype.storm.daemon.executor to java

[ https://issues.apache.org/jira/browse/STORM-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15255876#comment-15255876 ] John Fang commented on STORM-1277: -- I am busy on the development of JStorm recently. If you

[jira] [Updated] (STORM-1277) port backtype.storm.daemon.executor to java

[ https://issues.apache.org/jira/browse/STORM-1277?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fang updated STORM-1277: - Assignee: Cody (was: John Fang) > port backtype.storm.daemon.executor to j

[jira] [Created] (STORM-1712) make storage plugin for transactional state

John Fang created STORM-1712: Summary: make storage plugin for transactional state Key: STORM-1712 URL: https://issues.apache.org/jira/browse/STORM-1712 Project: Apache Storm Issue Type