[jira] [Resolved] (STORM-938) storm-hive add a time interval to flush tuples to hive

2015-08-19 Thread Aaron Dossett (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aaron Dossett resolved STORM-938.
-
Resolution: Fixed

 storm-hive add a time interval to flush tuples to hive
 --

 Key: STORM-938
 URL: https://issues.apache.org/jira/browse/STORM-938
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Sriharsha Chintalapani
Assignee: Aaron Dossett

 currently we've batch way updating hive orc tables. Unless configured batch 
 size reaches flush won't happen . In some cases we might need to have an 
 option of time interval if a configured time interval reaches storm-hive bolt 
 should flush these tuples to hive.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-938) storm-hive add a time interval to flush tuples to hive

2015-08-19 Thread Aaron Dossett (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aaron Dossett updated STORM-938:

Fix Version/s: 0.11.0

 storm-hive add a time interval to flush tuples to hive
 --

 Key: STORM-938
 URL: https://issues.apache.org/jira/browse/STORM-938
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Sriharsha Chintalapani
Assignee: Aaron Dossett
 Fix For: 0.11.0


 currently we've batch way updating hive orc tables. Unless configured batch 
 size reaches flush won't happen . In some cases we might need to have an 
 option of time interval if a configured time interval reaches storm-hive bolt 
 should flush these tuples to hive.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Derek Dagit (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702977#comment-14702977
 ] 

Derek Dagit commented on STORM-1000:


Hi [~YvonneIronberg], it might be easier to submit a github pull request so the 
changes are easier to review.

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-960) Hive-Bolt can lose tuples when flushing data

2015-08-19 Thread Aaron Dossett (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Aaron Dossett updated STORM-960:

Fix Version/s: 0.11.0

 Hive-Bolt can lose tuples when flushing data
 

 Key: STORM-960
 URL: https://issues.apache.org/jira/browse/STORM-960
 Project: Apache Storm
  Issue Type: Improvement
  Components: external
Reporter: Aaron Dossett
Assignee: Aaron Dossett
Priority: Minor
 Fix For: 0.11.0


 In HiveBolt's execute method tuples are ack'd as they are received.  When a 
 batchsize of tuples has been received, the writers are flushed.  However, if 
 the flush fails only the most recent tuple will be marked as failed.  All 
 prior tuples will already have been ack'd.  This creates a window for data 
 loss.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-973) Netty-Client Connection Failed

2015-08-19 Thread Alex Panov (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14702936#comment-14702936
 ] 

Alex Panov commented on STORM-973:
--

[~darion] Can you please attach a unit test that reproduces the error?

 Netty-Client Connection Failed
 --

 Key: STORM-973
 URL: https://issues.apache.org/jira/browse/STORM-973
 Project: Apache Storm
  Issue Type: Bug
Affects Versions: 0.9.4
 Environment: apache-storm-0.9.4 JDK 1.7.0_75 
Reporter: darion yaphets

 When Storm Topology startup in a distribution cluster I found netty 
 connection will failed and messages will be droped by client itself. 
 worker log info as following :
 ```
 2015-08-07T11:43:18.903+0800 b.s.m.n.StormClientErrorHandler [INFO] 
 Connection failed Netty-Client-storm-01
 java.io.IOException: Connection reset by peer
   at sun.nio.ch.FileDispatcherImpl.read0(Native Method) ~[na:1.7.0_75]
   at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39) 
 ~[na:1.7.0_75]
   at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223) 
 ~[na:1.7.0_75]
   at sun.nio.ch.IOUtil.read(IOUtil.java:192) ~[na:1.7.0_75]
   at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:379) 
 ~[na:1.7.0_75]
   at 
 org.apache.storm.netty.channel.socket.nio.NioWorker.read(NioWorker.java:64) 
 [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.channel.socket.nio.AbstractNioWorker.process(AbstractNioWorker.java:108)
  [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.channel.socket.nio.AbstractNioSelector.run(AbstractNioSelector.java:318)
  [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.channel.socket.nio.AbstractNioWorker.run(AbstractNioWorker.java:89)
  [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.channel.socket.nio.NioWorker.run(NioWorker.java:178) 
 [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.util.ThreadRenamingRunnable.run(ThreadRenamingRunnable.java:108)
  [storm-core-0.9.4.jar:0.9.4]
   at 
 org.apache.storm.netty.util.internal.DeadLockProofWorker$1.run(DeadLockProofWorker.java:42)
  [storm-core-0.9.4.jar:0.9.4]
   at 
 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145)
  [na:1.7.0_75]
   at 
 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615)
  [na:1.7.0_75]
   at java.lang.Thread.run(Thread.java:745) [na:1.7.0_75]
 2015-08-07T11:43:19.426+0800 b.s.m.n.Client [INFO] connection attempt 1 to 
 Netty-Client-syq-storm-01.meilishuo.com/172.16.7.25:8711 scheduled to run in 
 0 ms
 2015-08-07T11:43:19.427+0800 b.s.m.n.Client [ERROR] connection to 
 Netty-Client-storm-01 is unavailable
 2015-08-07T11:43:19.427+0800 b.s.m.n.Client [ERROR] dropping 1 message(s) 
 destined for Netty-Client-storm-01
 2015-08-07T11:43:19.428+0800 b.s.m.n.Client [ERROR] connection to 
 Netty-Client-storm-01 is unavailable
 2015-08-07T11:43:19.428+0800 b.s.m.n.Client [ERROR] dropping 103 message(s) 
 destined for Netty-Client-storm-01 
 2015-08-07T11:43:19.428+0800 b.s.m.n.Client [ERROR] connection to 
 Netty-Client-storm-01 is unavailable
 2015-08-07T11:43:19.428+0800 b.s.m.n.Client [ERROR] dropping 35 message(s) 
 destined for Netty-Client-storm-01
 ```



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Description: 
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to  its enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of STORM-797 
(https://issues.apache.org/jira/browse/STORM-797), see its patch 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).

This issue tries to improve all such places in the current codebase. 

  was:
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of STORM-797 
(https://issues.apache.org/jira/browse/STORM-797), see its patch 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).

This issue tries to improve all such places in the current codebase. 


 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to  its enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-919) Gathering worker and supervisor process information (CPU/Memory) and ranking the components

2015-08-19 Thread Shyam Rajendran (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Shyam Rajendran updated STORM-919:
--
Attachment: WorkerStats With Component Rank.png

 Gathering worker and supervisor process information (CPU/Memory) and ranking 
 the components
 ---

 Key: STORM-919
 URL: https://issues.apache.org/jira/browse/STORM-919
 Project: Apache Storm
  Issue Type: New Feature
Reporter: Shyam Rajendran
Assignee: Shyam Rajendran
Priority: Minor
 Attachments: WorkerStats With Component Rank.png


 It would be useful to have supervisor and worker process related information 
 such as %cpu utilization, JVM memory and network bandwidth available to 
 NIMBUS which would be useful for resource aware scheduler implementation 
 later on. As a beginning, the information can be piggybacked on the existing 
 heartbeats into the ZK or to the pacemaker as required. 
 Related JIRAs
 STORM-177
 STORM-891
 STORM-899



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-919) Gathering worker and supervisor process information (CPU/Memory)

2015-08-19 Thread Shyam Rajendran (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703471#comment-14703471
 ] 

Shyam Rajendran commented on STORM-919:
---

*** DO NOT MERGE THIS YET  
As part of the work for Elasticity in Storm, the initial work to gather the 
stats and understand the relative impact of components has been prototyped. 
Presently only the CPU Utilization% is used to rank the components as per the 
details in previous comment.
Also the present code depends on features developed internally which are not 
yet available in the community storm. We have plans to have it merged back and 
I would like to wait till then before I can open a new request and void this.  
It would be helpful to hear opinion / suggestions on this. Thanks!

 Gathering worker and supervisor process information (CPU/Memory)
 

 Key: STORM-919
 URL: https://issues.apache.org/jira/browse/STORM-919
 Project: Apache Storm
  Issue Type: New Feature
Reporter: Shyam Rajendran
Assignee: Shyam Rajendran
Priority: Minor
 Attachments: WorkerStats With Component Rank.png


 It would be useful to have supervisor and worker process related information 
 such as %cpu utilization, JVM memory and network bandwidth available to 
 NIMBUS which would be useful for resource aware scheduler implementation 
 later on. As a beginning, the information can be piggybacked on the existing 
 heartbeats into the ZK or to the pacemaker as required. 
 Related JIRAs
 STORM-177
 STORM-891
 STORM-899



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Derek Dagit (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703431#comment-14703431
 ] 

Derek Dagit commented on STORM-1000:


Yeah, just create a different git branch for each JIRA Issue.  Then you can 
make a pull request for each.

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to  its enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797), see 
 its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703379#comment-14703379
 ] 

Yvonne Ironberg commented on STORM-1000:


Hi Derek, Thanks. Is it possible to have multiple pulls at the same time? I 
searched it for a while but couldn't find a way.

Now I have another pull awaiting review 
(https://github.com/apache/storm/pull/689).

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Comment Edited] (STORM-919) Gathering worker and supervisor process information (CPU/Memory)

2015-08-19 Thread Shyam Rajendran (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703471#comment-14703471
 ] 

Shyam Rajendran edited comment on STORM-919 at 8/19/15 5:59 PM:


*** DO NOT MERGE THIS YET  
As part of the work for Elasticity in Storm, the initial work to gather the 
stats and understand the relative impact of components has been prototyped. 
Presently only the CPU Utilization% is used to rank the components scheduled 
across the nodes on different workers as per the details in previous comment.
Also the present code depends on features developed internally which are not 
yet available in the community storm. We have plans to have it merged back and 
I would like to wait till then before I can open a new request and void this.  
It would be helpful to hear opinion / suggestions on this. Thanks!


was (Author: shyamrajendran):
*** DO NOT MERGE THIS YET  
As part of the work for Elasticity in Storm, the initial work to gather the 
stats and understand the relative impact of components has been prototyped. 
Presently only the CPU Utilization% is used to rank the components as per the 
details in previous comment.
Also the present code depends on features developed internally which are not 
yet available in the community storm. We have plans to have it merged back and 
I would like to wait till then before I can open a new request and void this.  
It would be helpful to hear opinion / suggestions on this. Thanks!

 Gathering worker and supervisor process information (CPU/Memory)
 

 Key: STORM-919
 URL: https://issues.apache.org/jira/browse/STORM-919
 Project: Apache Storm
  Issue Type: New Feature
Reporter: Shyam Rajendran
Assignee: Shyam Rajendran
Priority: Minor
 Attachments: WorkerStats With Component Rank.png


 It would be useful to have supervisor and worker process related information 
 such as %cpu utilization, JVM memory and network bandwidth available to 
 NIMBUS which would be useful for resource aware scheduler implementation 
 later on. As a beginning, the information can be piggybacked on the existing 
 heartbeats into the ZK or to the pacemaker as required. 
 Related JIRAs
 STORM-177
 STORM-891
 STORM-899



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] storm pull request: STORM-919 Gathering worker and supervisor proc...

2015-08-19 Thread bourneagain
Github user bourneagain commented on the pull request:

https://github.com/apache/storm/pull/608#issuecomment-132722067
  
*** PLEASE DO NOT MERGE THIS YET  
More information @ https://issues.apache.org/jira/browse/STORM-919. 


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (STORM-919) Gathering worker and supervisor process information (CPU/Memory)

2015-08-19 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703475#comment-14703475
 ] 

ASF GitHub Bot commented on STORM-919:
--

Github user bourneagain commented on the pull request:

https://github.com/apache/storm/pull/608#issuecomment-132722067
  
*** PLEASE DO NOT MERGE THIS YET  
More information @ https://issues.apache.org/jira/browse/STORM-919. 


 Gathering worker and supervisor process information (CPU/Memory)
 

 Key: STORM-919
 URL: https://issues.apache.org/jira/browse/STORM-919
 Project: Apache Storm
  Issue Type: New Feature
Reporter: Shyam Rajendran
Assignee: Shyam Rajendran
Priority: Minor
 Attachments: WorkerStats With Component Rank.png


 It would be useful to have supervisor and worker process related information 
 such as %cpu utilization, JVM memory and network bandwidth available to 
 NIMBUS which would be useful for resource aware scheduler implementation 
 later on. As a beginning, the information can be piggybacked on the existing 
 heartbeats into the ZK or to the pacemaker as required. 
 Related JIRAs
 STORM-177
 STORM-891
 STORM-899



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Description: 
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to  its enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of STORM-797), see 
its patch 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).

This issue tries to improve all such places in the current codebase. 

  was:
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to  its enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of STORM-797 
(https://issues.apache.org/jira/browse/STORM-797), see its patch 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).

This issue tries to improve all such places in the current codebase. 


 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to  its enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797), see 
 its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-919) Gathering worker and supervisor process information (CPU/Memory)

2015-08-19 Thread Shyam Rajendran (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Shyam Rajendran updated STORM-919:
--
Summary: Gathering worker and supervisor process information (CPU/Memory)  
(was: Gathering worker and supervisor process information (CPU/Memory) and rank 
the components)

 Gathering worker and supervisor process information (CPU/Memory)
 

 Key: STORM-919
 URL: https://issues.apache.org/jira/browse/STORM-919
 Project: Apache Storm
  Issue Type: New Feature
Reporter: Shyam Rajendran
Assignee: Shyam Rajendran
Priority: Minor
 Attachments: WorkerStats With Component Rank.png


 It would be useful to have supervisor and worker process related information 
 such as %cpu utilization, JVM memory and network bandwidth available to 
 NIMBUS which would be useful for resource aware scheduler implementation 
 later on. As a beginning, the information can be piggybacked on the existing 
 heartbeats into the ZK or to the pacemaker as required. 
 Related JIRAs
 STORM-177
 STORM-891
 STORM-899



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-893) Resource Aware Scheduling

2015-08-19 Thread Boyang Jerry Peng (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703632#comment-14703632
 ] 

Boyang Jerry Peng commented on STORM-893:
-

Hello Everyone,

I recently published a paper in ACM Middleware on the subject of Resource Aware 
Scheduling in Storm in which I demonstrated how the scheduling algorithms I 
used can significantly improve performance and stability of Storm.  I have 
created an implementation for open source based off of a implementation I 
worked on a Yahoo. The implementation is on my github. The link is provided 
below:

https://github.com/jerrypeng/storm/tree/opensource_ras

The link to the paper: 

http://web.engr.illinois.edu/~bpeng/files/r-storm.pdf

The paper describes the architecture, algorithms, and API of the Resource Aware 
Scheduler as well as an evaluation of performance.  The research and initial 
implementation was done by me while I was a graduate student at University of 
Illinois, Urbana-champaign.  After I graduated, I joined Yahoo and we came up 
with a better implementation.

The implementation should work straight out of the box.  If you are running 
storm in a multi-rack environment, and you want to leverage the network aware 
portion of the scheduler to improve performance and decrease latency, you can 
implement your own STORM_NETWORK_TOPOLOGY_PLUGIN that maps the underlying 
physical network.  The default plugin that comes with the implementation 
assumes all machines have the same network distance from each other i.e. on the 
same rack.  Contact me if you need more information on this subject.

Please look at this initial implementation and provide me with some feedback, 
since we intend to have a pull request up soon and merge it into master.

People that worked on the implementation at Yahoo with me:

Bobby Evans (Yahoo  Storm PMC)
Derek Dagit (Yahoo  Storm PMC)
Kyle Nusbaum (Yahoo  Storm PMC)
Liu Zhuo (Yahoo)
Sanket Chintapalli (Yahoo)
Reza Fravier (Yahoo  UIUC)

Best,

Boyang Jerry Peng
Software Engineer, Yahoo
http://web.engr.illinois.edu/~bpeng/

 Resource Aware Scheduling
 -

 Key: STORM-893
 URL: https://issues.apache.org/jira/browse/STORM-893
 Project: Apache Storm
  Issue Type: Umbrella
Reporter: Robert Joseph Evans
Assignee: Boyang Jerry Peng

 At Yahoo we have been working on resource aware scheduling in storm, based 
 off of some work done in academia.  This rollup ticket is to track the 
 complete project.  With several sub tasks.  Some that are already done and 
 need to be pushed back, and others that we have not started on yet.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


R-Storm - Resource Aware Scheduling implementation for Storm

2015-08-19 Thread Boyang(Jerry) Peng
Hello Everyone,



I recently published a paper in ACM Middleware on the subject of Resource Aware 
Scheduling in Storm in which I demonstrated how the scheduling algorithms I 
used can significantly improve performance and stability of Storm.  I have 
created an implementation for open source based off of a implementation I 
worked on a Yahoo. The implementation is on my github. The link is provided 
below:
https://github.com/jerrypeng/storm/tree/opensource_ras

The link to the paper: 
http://web.engr.illinois.edu/~bpeng/files/r-storm.pdf

The paper describes the architecture, algorithms, and API of the Resource Aware 
Scheduler as well as an evaluation of performance.  The research and initial 
implementation was done by me while I was a graduate student at University of 
Illinois, Urbana-champaign.  After I graduated, I joined Yahoo and we came up 
with a better implementation.
The implementation should work straight out of the box.  If you are running 
storm in a multi-rack environment, and you want to leverage the network aware 
portion of the scheduler to improve performance and decrease latency, you can 
implement your own STORM_NETWORK_TOPOLOGY_PLUGIN that maps the underlying 
physical network.  The default plugin that comes with the implementation 
assumes all machines have the same network distance from each other i.e. on the 
same rack.  Contact me if you need more information on this subject.
Please look at this initial implementation and provide me with some feedback, 
since we intend to have a pull request up soon and merge it into master.
People that worked on the implementation at Yahoo with me:

Bobby Evans (Yahoo  Storm PMC)Derek Dagit (Yahoo  Storm PMC)Kyle Nusbaum 
(Yahoo  Storm PMC)
Liu Zhuo (Yahoo)Sanket Chintapalli (Yahoo)Reza Fravier (Yahoo  UIUC)
Best,
Boyang Jerry PengSoftware Engineer, Yahoohttp://web.engr.illinois.edu/~bpeng/



   

[GitHub] storm pull request: Storm-166: Nimbus HA design doc and implementa...

2015-08-19 Thread Parth-Brahmbhatt
Github user Parth-Brahmbhatt commented on the pull request:

https://github.com/apache/storm/pull/354#issuecomment-132737685
  
@revans2 Can you please review this PR when you have time? Given you have 
been involved in the original PR I don't want to commit this until I get a 
confirmation from you. 


---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (STORM-996) netty-unit-tests/test-batch demonstrates out-of-order delivery

2015-08-19 Thread Parth Brahmbhatt (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-996?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703522#comment-14703522
 ] 

Parth Brahmbhatt commented on STORM-996:


[~dagit] How are you reproducing this? I just ran this test in a loop for 50 
times and it passed all the time for me. I am on following java version

➜  incubator-storm git:(ha-merge) ✗ java -version
java version 1.8.0_31
Java(TM) SE Runtime Environment (build 1.8.0_31-b13)
Java HotSpot(TM) 64-Bit Server VM (build 25.31-b07, mixed mode)




 netty-unit-tests/test-batch demonstrates out-of-order delivery
 --

 Key: STORM-996
 URL: https://issues.apache.org/jira/browse/STORM-996
 Project: Apache Storm
  Issue Type: Bug
Affects Versions: 0.10.0
Reporter: Derek Dagit
Assignee: Derek Dagit
Priority: Blocker

 backtype.storm.messaging.netty-unit-test/test-batch
 One example of output.  Similar things happen sporadically and vary widely by 
 number of failed assertions.
 Tuples are not just skewed, but actually seem to come in out-of-order.
 {quote}
 actual: (not (= 66040 66041))
 at: test_runner.clj:105
 expected: (= req_msg resp_msg)
 actual: (not (= 66041 66042))
 at: test_runner.clj:105
 expected: (= req_msg resp_msg)
 actual: (not (= 66042 66040))
 at: test_runner.clj:105
 {quote}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] storm pull request: STORM-1000

2015-08-19 Thread YvonneIronberg
GitHub user YvonneIronberg opened a pull request:

https://github.com/apache/storm/pull/691

STORM-1000



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/YvonneIronberg/storm storm-1000

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/storm/pull/691.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #691


commit 6a30be80a895c63d5e0c53183a9807b8e8c3a8b5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:37:31Z

STORM-829.

commit 8d487852e51c67d943ee6ea2b778e9e68da5f062
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:44:29Z

STORM-829.

commit a59823446b89ccce461c72b655e157983be4dca2
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T19:35:42Z

STORM-1000.

commit a7cc363572ae324f5b46e05d7ce2a8efc641812d
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:09:42Z

STORM-1000.

commit 6ae2a9a88443342a6aab12bf5d5dd15e6405907b
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:33:47Z

storm-1000.




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703857#comment-14703857
 ] 

ASF GitHub Bot commented on STORM-1000:
---

GitHub user YvonneIronberg opened a pull request:

https://github.com/apache/storm/pull/691

STORM-1000



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/YvonneIronberg/storm storm-1000

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/storm/pull/691.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #691


commit 6a30be80a895c63d5e0c53183a9807b8e8c3a8b5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:37:31Z

STORM-829.

commit 8d487852e51c67d943ee6ea2b778e9e68da5f062
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:44:29Z

STORM-829.

commit a59823446b89ccce461c72b655e157983be4dca2
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T19:35:42Z

STORM-1000.

commit a7cc363572ae324f5b46e05d7ce2a8efc641812d
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:09:42Z

STORM-1000.

commit 6ae2a9a88443342a6aab12bf5d5dd15e6405907b
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:33:47Z

storm-1000.




 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to  its enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797), see 
 its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-829) Hadoop dependency confusion

2015-08-19 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703856#comment-14703856
 ] 

ASF GitHub Bot commented on STORM-829:
--

GitHub user YvonneIronberg opened a pull request:

https://github.com/apache/storm/pull/690

STORM-829



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/YvonneIronberg/storm storm-829

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/storm/pull/690.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #690


commit 6a30be80a895c63d5e0c53183a9807b8e8c3a8b5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:37:31Z

STORM-829.

commit 8d487852e51c67d943ee6ea2b778e9e68da5f062
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:44:29Z

STORM-829.

commit a59823446b89ccce461c72b655e157983be4dca2
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T19:35:42Z

STORM-1000.

commit 2c8502cc84565d138c97709737dbd60cdb7b2a1a
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T21:00:33Z

STORM-829.

commit f3deb85b8e58069cca26ec87f71f4044e86d50cf
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:23:24Z

STORM-829.

commit 0c8582e453caa12093f47c4b66c084dd28f77cd5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:30:02Z

storm-829.

commit 095c796f6e26e555dfc3f62146721553d3d5cb35
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:32:25Z

storm-829.




 Hadoop dependency confusion
 ---

 Key: STORM-829
 URL: https://issues.apache.org/jira/browse/STORM-829
 Project: Apache Storm
  Issue Type: Bug
Reporter: Robert Joseph Evans

 The hadoop dependencies seem a bit messed up.  We have a hadoop.version set 
 in the main pom.xml to 2.6.0 but it does not really appear to be used.  
 storm-core uses hadoop-auth set to 2.4.0, storm-hdfs hard codes it to 2.2.0, 
 storm-hbase does the same.  We should have all of the versions be consistent 
 and come from the main pom.xml.  Also what are we using hadoop-auth for in 
 storm-core.
 Also it looks like we should remove the hadoop-auth dependency.  When 
 AutoHDFS and AutoHBase moved out of storm-core it looks like it was left 
 there by mistake. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703861#comment-14703861
 ] 

Yvonne Ironberg commented on STORM-1000:


Thanks, [~dagit].

Please refer to the clean version: 
https://github.com/apache/storm/pull/691/files. The patch is solely devoted for 
STORM-1000, not STORM-829. The above 
https://github.com/apache/storm/pull/691.patch is inaccurate.

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to  its enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797), see 
 its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Commented] (STORM-829) Hadoop dependency confusion

2015-08-19 Thread Yvonne Ironberg (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-829?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14703862#comment-14703862
 ] 

Yvonne Ironberg commented on STORM-829:
---

The only changes are in https://github.com/apache/storm/pull/690/files.

 Hadoop dependency confusion
 ---

 Key: STORM-829
 URL: https://issues.apache.org/jira/browse/STORM-829
 Project: Apache Storm
  Issue Type: Bug
Reporter: Robert Joseph Evans

 The hadoop dependencies seem a bit messed up.  We have a hadoop.version set 
 in the main pom.xml to 2.6.0 but it does not really appear to be used.  
 storm-core uses hadoop-auth set to 2.4.0, storm-hdfs hard codes it to 2.2.0, 
 storm-hbase does the same.  We should have all of the versions be consistent 
 and come from the main pom.xml.  Also what are we using hadoop-auth for in 
 storm-core.
 Also it looks like we should remove the hadoop-auth dependency.  When 
 AutoHDFS and AutoHBase moved out of storm-core it looks like it was left 
 there by mistake. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[GitHub] storm pull request: STORM-829

2015-08-19 Thread YvonneIronberg
GitHub user YvonneIronberg opened a pull request:

https://github.com/apache/storm/pull/690

STORM-829



You can merge this pull request into a Git repository by running:

$ git pull https://github.com/YvonneIronberg/storm storm-829

Alternatively you can review and apply these changes as the patch at:

https://github.com/apache/storm/pull/690.patch

To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:

This closes #690


commit 6a30be80a895c63d5e0c53183a9807b8e8c3a8b5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:37:31Z

STORM-829.

commit 8d487852e51c67d943ee6ea2b778e9e68da5f062
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-18T17:44:29Z

STORM-829.

commit a59823446b89ccce461c72b655e157983be4dca2
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T19:35:42Z

STORM-1000.

commit 2c8502cc84565d138c97709737dbd60cdb7b2a1a
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T21:00:33Z

STORM-829.

commit f3deb85b8e58069cca26ec87f71f4044e86d50cf
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:23:24Z

STORM-829.

commit 0c8582e453caa12093f47c4b66c084dd28f77cd5
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:30:02Z

storm-829.

commit 095c796f6e26e555dfc3f62146721553d3d5cb35
Author: YvonneIronberg yvonne.ironb...@gmail.com
Date:   2015-08-19T22:32:25Z

storm-829.




---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[GitHub] storm pull request: [STORM-949] On the topology summary UI page, a...

2015-08-19 Thread jerrypeng
Github user jerrypeng commented on the pull request:

https://github.com/apache/storm/pull/675#issuecomment-132891659
  
Just modified the UI to have error time shown as a time and date.  If you 
hover over that time a tooltip will pop up displaying the elapsed time.

![new_ui](https://cloud.githubusercontent.com/assets/3613359/9376134/9574276e-46ce-11e5-92e8-e3a4ef9b44c9.png)



---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---


[jira] [Commented] (STORM-949) On the topology summary UI page, last shown error should have the time and date

2015-08-19 Thread ASF GitHub Bot (JIRA)

[ 
https://issues.apache.org/jira/browse/STORM-949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14704294#comment-14704294
 ] 

ASF GitHub Bot commented on STORM-949:
--

Github user jerrypeng commented on the pull request:

https://github.com/apache/storm/pull/675#issuecomment-132891659
  
Just modified the UI to have error time shown as a time and date.  If you 
hover over that time a tooltip will pop up displaying the elapsed time.

![new_ui](https://cloud.githubusercontent.com/assets/3613359/9376134/9574276e-46ce-11e5-92e8-e3a4ef9b44c9.png)



 On the topology summary UI page, last shown error should have the time and 
 date
 ---

 Key: STORM-949
 URL: https://issues.apache.org/jira/browse/STORM-949
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Reza Farivar
Assignee: Boyang Jerry Peng
Priority: Minor

 Without showing the time and date, it is not clear whether the error is a 
 recent one or an old stale one. 
 (Error text is colored red when it is in last 5 minutes, but this is not 
 obvious and not enough information)



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Created] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)
Yvonne Ironberg created STORM-1000:
--

 Summary: Use static member classes when permitted
 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor


In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of 
(https://issues.apache.org/jira/browse/STORM-797)[STORM-797], see 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch)[its 
patch]).

This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Description: 
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of STORM-797 
(https://issues.apache.org/jira/browse/STORM-797), see its patch 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).

This issue tries to improve all such places in the current codebase. 

  was:
In Java, the difference between “static member class” and “nonstatic member 
class” is simply a reference to enclosing instance. “Static” here means 
“independent of the enclosing instance”. Or “an enclosed instance can survive 
without an enclosing instance”.
* For an instance of a nonstatic member class, there is a reference from the 
enclosed instance to the enclosing instance. When the enclosing instance 
doesn’t exist, you cannot instantiate the nonstatic member class.
* For an instance of a static member class, there isn’t such a reference from 
the enclosed instance to the enclosing instance. So this helps the enclosing 
instance be garbage-collected.

Favoring static member classes when permitted improves performance because time 
and space for extra references are saved.

This optimization was done before for Storm (e.g., as part of 
(https://issues.apache.org/jira/browse/STORM-797)[STORM-797], see 
(https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch)[its 
patch]).

This issue tries to improve all such places in the current codebase. 


 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor

 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Attachment: STORM-1000.patch

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Attachment: (was: STORM-1000.patch)

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


[jira] [Updated] (STORM-1000) Use static member classes when permitted

2015-08-19 Thread Yvonne Ironberg (JIRA)

 [ 
https://issues.apache.org/jira/browse/STORM-1000?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Yvonne Ironberg updated STORM-1000:
---
Attachment: STORM-1000.patch

 Use static member classes when permitted
 

 Key: STORM-1000
 URL: https://issues.apache.org/jira/browse/STORM-1000
 Project: Apache Storm
  Issue Type: Improvement
Reporter: Yvonne Ironberg
Assignee: Yvonne Ironberg
Priority: Minor
 Attachments: STORM-1000.patch


 In Java, the difference between “static member class” and “nonstatic member 
 class” is simply a reference to enclosing instance. “Static” here means 
 “independent of the enclosing instance”. Or “an enclosed instance can survive 
 without an enclosing instance”.
 * For an instance of a nonstatic member class, there is a reference from the 
 enclosed instance to the enclosing instance. When the enclosing instance 
 doesn’t exist, you cannot instantiate the nonstatic member class.
 * For an instance of a static member class, there isn’t such a reference from 
 the enclosed instance to the enclosing instance. So this helps the enclosing 
 instance be garbage-collected.
 Favoring static member classes when permitted improves performance because 
 time and space for extra references are saved.
 This optimization was done before for Storm (e.g., as part of STORM-797 
 (https://issues.apache.org/jira/browse/STORM-797), see its patch 
 (https://patch-diff.githubusercontent.com/raw/apache/storm/pull/537.patch).
 This issue tries to improve all such places in the current codebase. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)


Re: Cannot run WordCountExample in Intellij

2015-08-19 Thread Matthias J. Sax
Thanks for the explanation! The hint with PYHTONPATH got me to the solution:

The SplitSentence bolt must be configured correctly.

I just change the code from

 builder.setBolt(split, new SplitSentence(), 8).shuffleGrouping(spout);

to

 SplitSentence pythonSplit = new SplitSentence();
 Map env = new HashMap();
 env.put(PYTHONPATH, 
 /home/mjsax/workspace_storm/storm/storm-multilang/python/src/main/resources/resources/);
 pythonSplit.setEnv(env);
 builder.setBolt(split,pythonSplit, 8).shuffleGrouping(spout);


-Matthias

On 08/19/2015 04:29 AM, 임정택 wrote:
 Hi Matthias, sorry to respond lately.
 
 Unfortunately, AFAIK you can't run multilang feature with LocalCluster
 without having packaged file.
 
 ShellProcess relies on codeDir of TopologyContext, which is used by
 supervisor. Workers are serialized to stormcode.ser, but multilang files
 should extracted to outside of serialized file so that python/ruby/node/etc
 can load it.
 
 Accomplishing this with distribute mode is easy because there's always user
 submitted jar, and supervisor can know it is what user submitted.
 
 But accomplishing this with local mode is not easy cause supervisor cannot
 know user submitted jar, and users can run topology to local mode without
 packaging.
 
 So, Supervisor in local mode finds resource directory (resources) from
 each jars (which ends with jar) in classpath, and copy first occurrence
 to codeDir.
 
 storm jar places user topology jar to the first of classpath, so it can be
 run without issue.
 
 So normally, it's natural for ShellProcess to not find splitsentence.py.
 Maybe your working directory or PYTHONPATH do the trick.
 
 Hope this helps.
 
 Best,
 Jungtaek Lim (HeartSaVioR)
 ps.
 I also respond to your SO question with same content.
 http://stackoverflow.com/a/32085316/3480122
 
 2015-08-10 6:49 GMT+09:00 Matthias J. Sax mj...@informatik.hu-berlin.de:
 
 Hi,

 I work with Storm for a while already, but want to get started with
 development. As suggested, I am using Intellij (up to now, I was using
 Eclipse).

 I was also looking at

 https://github.com/apache/storm/tree/master/examples/storm-starter#intellij-idea

 This documentation is not complete. I was not able to run anything in
 Intellij first. I could figure out, that I need to remove the scope of
 storm-core dependency (in storm-starter pom.xml). (found here:

 https://stackoverflow.com/questions/30724424/storm-starter-with-intellij-idea-maven-project-could-not-find-class
 )

 After that I wass able to build the project. I can also run
 ExclamationTopology with no problems within Intellij. However,
 WordCountTopology fails.

 First I got the following error:

 java.lang.RuntimeException: backtype.storm.multilang.NoOutputException:
 Pipe to subprocess seems to be broken! No output read.
 Serializer Exception:
 Traceback (most recent call last):
   File splitsentence.py, line 16, in module
 import storm
 ImportError: No module named storm

 I was able to resolve it via: apt-get install python-storm
 (from StackOverflow)

 However, I don't speak Python and was wondering what the problem is and
 why I could resolve it like this. Just want to get deeper into it. Maybe
 someone can explain.

 Unfortunately, I am getting a different error now:

 java.lang.RuntimeException: backtype.storm.multilang.NoOutputException:
 Pipe to subprocess seems to be broken! No output read.
 Serializer Exception:
 Traceback (most recent call last):
   File splitsentence.py, line 16, in module
 import storm
 ImportError: No module named storm

 I did not find any solution on the Internet. And as I am not familiar
 with Python and never used Storm differently as low-level Java API I am
 stuck now. Because ExclamationTopology runs, I guess my basic setup is
 correct.

 What do I do wrong?

 -Matthias




 
 



signature.asc
Description: OpenPGP digital signature