[jira] [Created] (STORM-1966) Expand metric having Map type as value into multiple metrics based on entries

Jungtaek Lim created STORM-1966: --- Summary: Expand metric having Map type as value into multiple metrics based on entries Key: STORM-1966 URL: https://issues.apache.org/jira/browse/STORM-1966 Project

[jira] [Commented] (STORM-1965) Show warning message when dot ('.') is used for topology name or component name

[ https://issues.apache.org/jira/browse/STORM-1965?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15374226#comment-15374226 ] Jungtaek Lim commented on STORM-1965: - Kafka has similar issue. Kafka allows to use dot for naming

[jira] [Created] (STORM-1965) Show warning message when dot ('.') is used for topology name or component name

Jungtaek Lim created STORM-1965: --- Summary: Show warning message when dot ('.') is used for topology name or component name Key: STORM-1965 URL: https://issues.apache.org/jira/browse/STORM-1965 Project

[jira] [Commented] (STORM-1609) Netty Client is not best effort delivery on failed Connection

[ https://issues.apache.org/jira/browse/STORM-1609?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372971#comment-15372971 ] Jungtaek Lim commented on STORM-1609: - Sorry for chiming in, but have an update for you, suspected

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372766#comment-15372766 ] Jungtaek Lim commented on STORM-1949: - Receive thread in downstream is not blocked at all, so transfer

[jira] [Comment Edited] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372645#comment-15372645 ] Jungtaek Lim edited comment on STORM-1949 at 7/12/16 10:15 AM: --- If my

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15372645#comment-15372645 ] Jungtaek Lim commented on STORM-1949: - If my understanding is right, DisruptorQueue.publish() is only

[jira] [Assigned] (STORM-1959) KafkaPartitionOffsetLag.java does not have license

[ https://issues.apache.org/jira/browse/STORM-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim reassigned STORM-1959: --- Assignee: Jungtaek Lim > KafkaPartitionOffsetLag.java does not have lice

[jira] [Commented] (STORM-1959) KafkaPartitionOffsetLag.java does not have license

[ https://issues.apache.org/jira/browse/STORM-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370952#comment-15370952 ] Jungtaek Lim commented on STORM-1959: - Thanks for finding missed spot, Bobby. I'll create a quick fix

[jira] [Updated] (STORM-1959) KafkaPartitionOffsetLag.java does not have license

[ https://issues.apache.org/jira/browse/STORM-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1959: Affects Version/s: 1.1.0 > KafkaPartitionOffsetLag.java does not have lice

[jira] [Resolved] (STORM-1950) Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition

[ https://issues.apache.org/jira/browse/STORM-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1950. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged by [~sriharsha

[jira] [Resolved] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1933. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370104#comment-15370104 ] Jungtaek Lim commented on STORM-1933: - Intermittent failure is not shown within 20 times build

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370071#comment-15370071 ] Jungtaek Lim commented on STORM-1933: - STORM-1934 is merged. I'll run the test 20 times and close

[jira] [Commented] (STORM-1952) Keeping topology code for supervisor until topology got killed

[ https://issues.apache.org/jira/browse/STORM-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370050#comment-15370050 ] Jungtaek Lim commented on STORM-1952: - Please correct me if I'm wrong. AFAIK, topology code

[jira] [Updated] (STORM-1934) Race condition between sync-supervisor and sync-processes raises several strange issues

[ https://issues.apache.org/jira/browse/STORM-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1934: Fix Version/s: (was: 1.0.0) 1.0.2 > Race condition between sync-supervi

[jira] [Resolved] (STORM-1922) Supervisor summary default order by host

[ https://issues.apache.org/jira/browse/STORM-1922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1922. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Updated] (STORM-1930) Kafka New Client API - Support for Topic Wildcards

[ https://issues.apache.org/jira/browse/STORM-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1930: Fix Version/s: (was: 1.0.2) 1.1.0 > Kafka New Client API - Support for To

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370045#comment-15370045 ] Jungtaek Lim commented on STORM-1949: - I'm OK to disable backpressure by default for short time

[jira] [Commented] (STORM-1737) storm-kafka-client has compilation errors with Apache Kafka 0.10

[ https://issues.apache.org/jira/browse/STORM-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370040#comment-15370040 ] Jungtaek Lim commented on STORM-1737: - If this issue can be fixed by several days I'm OK to mark

Request for reviewing

Given that STORM-1934 has two binding +1 votes, I'd like to wait for several days, and merge if no further discussion is in progress. Thanks in advance for taking your time. Best regards, Jungtaek Lim (HeartSaVioR)

[jira] [Resolved] (STORM-1742) More accurate 'complete latency'

[ https://issues.apache.org/jira/browse/STORM-1742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1742. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged to master, and 1.x

[jira] [Commented] (STORM-1940) Storm Topo is auto re-balance after ZK RECONNECTED

[ https://issues.apache.org/jira/browse/STORM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15367520#comment-15367520 ] Jungtaek Lim commented on STORM-1940: - [~happylu] Sorry but I don't understand it since ser

[jira] [Updated] (STORM-118) Docs: Minor typo in transactional-commit-flow.png

[ https://issues.apache.org/jira/browse/STORM-118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-118: --- Fix Version/s: (was: 1.0.2) > Docs: Minor typo in transactional-commit-flow.

[jira] [Updated] (STORM-1895) blobstore replication-factor argument

[ https://issues.apache.org/jira/browse/STORM-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1895: Fix Version/s: (was: 1.0.2) > blobstore replication-factor argum

[jira] [Resolved] (STORM-118) Docs: Minor typo in transactional-commit-flow.png

[ https://issues.apache.org/jira/browse/STORM-118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-118. Resolution: Fixed Fix Version/s: 1.0.2 1.0.1 2.0.0

[jira] [Resolved] (STORM-1633) Document "storm blobstore" to command-line-client.md

[ https://issues.apache.org/jira/browse/STORM-1633?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1633. - Resolution: Fixed Fix Version/s: 1.0.1 2.0.0 1.0.0

[jira] [Resolved] (STORM-1895) blobstore replication-factor argument

[ https://issues.apache.org/jira/browse/STORM-1895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1895. - Resolution: Fixed Fix Version/s: 1.0.2 1.0.1 2.0.0

[jira] [Resolved] (STORM-1834) Documentation How to Generate Certificates For Local Testing SSL Setup

[ https://issues.apache.org/jira/browse/STORM-1834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1834. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 0.10.2

[jira] [Resolved] (STORM-1899) Release HBase connection when topology shutdown

[ https://issues.apache.org/jira/browse/STORM-1899?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1899. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Resolved] (STORM-1844) Some tests are flaky due to low timeout

[ https://issues.apache.org/jira/browse/STORM-1844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1844. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Resolved] (STORM-1919) Introduce FilterBolt on storm-redis

[ https://issues.apache.org/jira/browse/STORM-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1919. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged into master and 1.x

[jira] [Created] (STORM-1953) [storm-redis] Revisit Mappers to structurize and deprecate/remove unneeded methods

Jungtaek Lim created STORM-1953: --- Summary: [storm-redis] Revisit Mappers to structurize and deprecate/remove unneeded methods Key: STORM-1953 URL: https://issues.apache.org/jira/browse/STORM-1953

[jira] [Resolved] (STORM-1946) ShellBolt.java - On busy system BoltHeartbeatTimerTask fires before setHeartbeat() is executed

[ https://issues.apache.org/jira/browse/STORM-1946?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1946. - Resolution: Fixed Assignee: Slava Andreyev Fix Version/s: 1.1.0

[jira] [Resolved] (STORM-1945) Internal Server Error shown on topology page for topology using KafkaSpout

[ https://issues.apache.org/jira/browse/STORM-1945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1945. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged into master and 1.x

[jira] [Updated] (STORM-1952) Keeping topology code for supervisor until topology got killed

[ https://issues.apache.org/jira/browse/STORM-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1952: Description: It's based on review comment from [~sriharsha]. https://github.com/apache/storm/pull

[jira] [Created] (STORM-1952) Keeping topology code for supervisor until topology got killed

Jungtaek Lim created STORM-1952: --- Summary: Keeping topology code for supervisor until topology got killed Key: STORM-1952 URL: https://issues.apache.org/jira/browse/STORM-1952 Project: Apache Storm

[jira] [Commented] (STORM-1281) port backtype.storm.testing to java

[ https://issues.apache.org/jira/browse/STORM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366852#comment-15366852 ] Jungtaek Lim commented on STORM-1281: - [~abhishek.agarwal] Do you have any update on this? Lots

[jira] [Comment Edited] (STORM-1281) port backtype.storm.testing to java

[ https://issues.apache.org/jira/browse/STORM-1281?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15366852#comment-15366852 ] Jungtaek Lim edited comment on STORM-1281 at 7/7/16 10:00 PM

[jira] [Resolved] (STORM-1238) port backtype.storm.security.auth.ThriftServer-test to java

[ https://issues.apache.org/jira/browse/STORM-1238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1238. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master

[jira] [Resolved] (STORM-1237) port backtype.storm.security.auth.ThriftClient-test to java

[ https://issues.apache.org/jira/browse/STORM-1237?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1237. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master

[jira] [Resolved] (STORM-1236) port backtype.storm.security.auth.SaslTransportPlugin-test to java

[ https://issues.apache.org/jira/browse/STORM-1236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1236. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master

[jira] [Resolved] (STORM-1249) port backtype.storm.security.serialization.BlowfishTupleSerializer-test to java

[ https://issues.apache.org/jira/browse/STORM-1249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1249. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master

[jira] [Resolved] (STORM-1235) port backtype.storm.security.auth.ReqContext-test to java

[ https://issues.apache.org/jira/browse/STORM-1235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1235. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abhishek.agarwal], I merged into master

[jira] [Created] (STORM-1950) Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition

Jungtaek Lim created STORM-1950: --- Summary: Change response json of "Topology Lag" REST API to keyed by spoutId, topic, partition Key: STORM-1950 URL: https://issues.apache.org/jira/browse/

[jira] [Commented] (STORM-1949) Backpressure can cause spout to stop emitting and stall topology

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365705#comment-15365705 ] Jungtaek Lim commented on STORM-1949: - And I think we need to include section to UI representing

[jira] [Resolved] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets and integrate with storm ui

[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1136. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Already merged to master

[jira] [Updated] (STORM-1924) Add a config file parameter to HDFS test topologies

[ https://issues.apache.org/jira/browse/STORM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1924: Fix Version/s: (was: 1.0.3) 1.0.2 > Add a config file parameter to HDFS t

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365571#comment-15365571 ] Jungtaek Lim commented on STORM-1939: - Never mind. I just worked on it and submitted a patch

[jira] [Assigned] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim reassigned STORM-1939: --- Assignee: Jungtaek Lim > Frequent InterruptedException raised by ShellBoltMessageQueue.p

[jira] [Issue Comment Deleted] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1941: Comment: was deleted (was: Sent from my Verizon Wireless 4G LTE smartphone Original

[jira] [Issue Comment Deleted] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1941: Comment: was deleted (was: $$$-×"- Sent from my Verizon Wireless 4G LTE smartphoneSax

[jira] [Issue Comment Deleted] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1941: Comment: was deleted (was: A!@3A2 @!aS×0D£ Sent from my Verizon Wireless 4G LTE smartphone!WF

Re: What is roles of __system-executor?

with other versions. Thanks, Jungtaek Lim (HeartSaVioR) 2016년 7월 6일 (수) 오후 12:32, Junguk Cho <jman...@gmail.com>님이 작성: > Hi, Jungtaek. > > Thank you for reply. > > Just a curious, do you have a reason to disable SystemBolt? > -> Not really. I just want to use the most

[jira] [Resolved] (STORM-1719) Introduce REST API: Topology metric stats for stream

[ https://issues.apache.org/jira/browse/STORM-1719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1719. - Resolution: Fixed Fix Version/s: 2.0.0 Also merged into master branch. > Introduce R

[jira] [Resolved] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1941. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Resolved] (STORM-1832) Consistently slow metrics consumer triggers backpressure which will be never back to normal

[ https://issues.apache.org/jira/browse/STORM-1832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1832. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Relevant issue was marked

[jira] [Commented] (STORM-1940) Storm Topo is auto re-balance after ZK RECONNECTED

[ https://issues.apache.org/jira/browse/STORM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15361184#comment-15361184 ] Jungtaek Lim commented on STORM-1940: - [~happylu] Thanks for providing your logs! Unfortunately we

[jira] [Updated] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1941: Description: When zookeeper reconnect happens, nimbus registry can be deleted though nimbus

[jira] [Resolved] (STORM-1937) trident topologies WindowTridentProcessor cause NullPointerException when using windowing

[ https://issues.apache.org/jira/browse/STORM-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1937. - Resolution: Fixed Fix Version/s: 1.1.0 1.0.2 2.0.0

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15359070#comment-15359070 ] Jungtaek Lim commented on STORM-1939: - OK. That makes sense. Do you have a plan to submit a pull

[jira] [Updated] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

[ https://issues.apache.org/jira/browse/STORM-1941?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1941: Priority: Critical (was: Major) > Nimbus discovery can fail when zookeeper reconnect happ

[jira] [Created] (STORM-1941) Nimbus discovery can fail when zookeeper reconnect happens.

Jungtaek Lim created STORM-1941: --- Summary: Nimbus discovery can fail when zookeeper reconnect happens. Key: STORM-1941 URL: https://issues.apache.org/jira/browse/STORM-1941 Project: Apache Storm

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15359008#comment-15359008 ] Jungtaek Lim commented on STORM-1939: - Yeah than I think it's natural to see it raised, and we don't

[jira] [Commented] (STORM-1940) Storm Topo is auto re-balance after ZK RECONNECTED

[ https://issues.apache.org/jira/browse/STORM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358717#comment-15358717 ] Jungtaek Lim commented on STORM-1940: - [~happylu] Sorry I mean logs for two workers. Your attached

[jira] [Commented] (STORM-1940) Storm Topo is auto re-balance after ZK RECONNECTED

[ https://issues.apache.org/jira/browse/STORM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358639#comment-15358639 ] Jungtaek Lim commented on STORM-1940: - [~happylu] Could you share other worker logs as well if you

[jira] [Updated] (STORM-1940) Storm Topo is auto re-balance after ZK RECONNECTED

[ https://issues.apache.org/jira/browse/STORM-1940?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1940: Removing EPIC since issue seems not clearly stated. When it's clearly stated and easy to fix I'll re

[jira] [Updated] (STORM-1937) trident topologies WindowTridentProcessor cause NullPointerException when using windowing

[ https://issues.apache.org/jira/browse/STORM-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1937: Assignee: perry wang (was: Jungtaek Lim) > trident topologies WindowTridentProcessor ca

[jira] [Updated] (STORM-1937) trident topologies WindowTridentProcessor cause NullPointerException when using windowing

[ https://issues.apache.org/jira/browse/STORM-1937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1937: Assignee: perry wang > trident topologies WindowTridentProcessor cause NullPointerException w

[jira] [Commented] (STORM-1939) Frequent InterruptedException raised by ShellBoltMessageQueue.poll

[ https://issues.apache.org/jira/browse/STORM-1939?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358440#comment-15358440 ] Jungtaek Lim commented on STORM-1939: - Not sure why that thread get interrupted, but we can just cover

Re: [DISCUSS] Maintaining example topologies for external components

Thanks Abhishek for bring good topic to discuss. Personally I'm either fine. The thing I'd just like to see is having a general rule across all external modules. Thanks, Jungtaek Lim (HeartSaVioR) 2016년 6월 30일 (목) 오후 11:09, Satish Duggana <sdugg...@hortonworks.com>님이 작성: > Hi Xin, &g

[jira] [Resolved] (STORM-1228) port backtype.storm.fields-test to java

[ https://issues.apache.org/jira/browse/STORM-1228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1228. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abellina], I merged into master. > p

[jira] [Resolved] (STORM-1233) port backtype.storm.security.auth.AuthUtils-test to java

[ https://issues.apache.org/jira/browse/STORM-1233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1233. - Resolution: Fixed Fix Version/s: 2.0.0 Thanks [~abellina], I merged into master. > p

[jira] [Updated] (STORM-917) Ability to emit messages from a kafka spout to a specific stream

[ https://issues.apache.org/jira/browse/STORM-917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-917: --- Fix Version/s: (was: 1.0.0) > Ability to emit messages from a kafka spout to a specific str

[jira] [Commented] (STORM-1879) Supervisor may not shut down workers cleanly

[ https://issues.apache.org/jira/browse/STORM-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356337#comment-15356337 ] Jungtaek Lim commented on STORM-1879: - [~Srdo] [~nico.meyer] [~kevinconaway] [~fogetti] Sorry

Re: [VOTE] Release Apache Storm 1.0.2 (rc2)

to cancel the vote and trigger new RC ASAP. What do you think? Thanks, Jungtaek Lim (HeartSaVioR) 2016년 6월 21일 (화) 오전 12:18, P. Taylor Goetz <ptgo...@gmail.com>님이 작성: > +1 (binding) > > - Verified build from source archive with `mvn clean install -P all-tests` > - Checked

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354845#comment-15354845 ] Jungtaek Lim commented on STORM-1933: - I think Nico describes the reason of this issue correctly

[jira] [Commented] (STORM-1879) Supervisor may not shut down workers cleanly

[ https://issues.apache.org/jira/browse/STORM-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354803#comment-15354803 ] Jungtaek Lim commented on STORM-1879: - Sorry for late participating. I have been struggling with other

[jira] [Updated] (STORM-1934) Race condition between sync-supervisor and sync-processes raises several strange issues

[ https://issues.apache.org/jira/browse/STORM-1934?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1934: Description: There're some strange issues including STORM-1933 and others (which I will file

[jira] [Created] (STORM-1934) Race condition between sync-supervisor and sync-processes raises several strange issues

Jungtaek Lim created STORM-1934: --- Summary: Race condition between sync-supervisor and sync-processes raises several strange issues Key: STORM-1934 URL: https://issues.apache.org/jira/browse/STORM-1934

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354409#comment-15354409 ] Jungtaek Lim commented on STORM-1933: - I'll create another issue that describes general concern : race

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354282#comment-15354282 ] Jungtaek Lim commented on STORM-1933: - Thanks [~satish.duggana] for giving your opinion. Btw, I'd like

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15353013#comment-15353013 ] Jungtaek Lim commented on STORM-1933: - sync-supervisor relies on zk assignment, and sync-processes

[jira] [Commented] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15352992#comment-15352992 ] Jungtaek Lim commented on STORM-1933: - If there's race condition, sync-processes recognizes disallowed

[jira] [Updated] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

[ https://issues.apache.org/jira/browse/STORM-1933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1933: Attachment: only-thread-1362-and-1363-BUG-60850-intermittent-failure-supervisor-test.txt It is due

[jira] [Created] (STORM-1933) Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test

Jungtaek Lim created STORM-1933: --- Summary: Intermittent test failure on test-multiple-active-storms-multiple-supervisors for supervisor-test Key: STORM-1933 URL: https://issues.apache.org/jira/browse/STORM-1933

[jira] [Resolved] (STORM-1924) Add a config file parameter to HDFS test topologies

[ https://issues.apache.org/jira/browse/STORM-1924?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1924. - Resolution: Fixed Assignee: Sivaguru Kannan Fix Version/s: 1.1.0

[jira] [Updated] (STORM-1928) ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync

[ https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1928: Summary: ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync

[jira] [Commented] (STORM-1919) Introduce FilterBolt on storm-redis

[ https://issues.apache.org/jira/browse/STORM-1919?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15350319#comment-15350319 ] Jungtaek Lim commented on STORM-1919: - STORM-1880 can be closed when this issue gets merged

[jira] [Updated] (STORM-1850) State Checkpointing documentation update regarding spout state management

[ https://issues.apache.org/jira/browse/STORM-1850?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1850: Assignee: Olivier Mallassi > State Checkpointing documentation update regarding spout st

[jira] [Resolved] (STORM-1893) Support OpenTSDB for storing timeseries data.

[ https://issues.apache.org/jira/browse/STORM-1893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1893. - Resolution: Fixed > Support OpenTSDB for storing timeseries d

[jira] [Resolved] (STORM-1888) add description for storm shell command

[ https://issues.apache.org/jira/browse/STORM-1888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1888. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Thanks [~vesense], I

[jira] [Resolved] (STORM-1902) add a simple & flexible FileNameFormat for storm-hdfs

[ https://issues.apache.org/jira/browse/STORM-1902?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1902. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Thanks [~vesense], I

[jira] [Resolved] (STORM-1914) Storm Kafka Field Topic Selector

[ https://issues.apache.org/jira/browse/STORM-1914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1914. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Thanks [~darion], I merged

[jira] [Resolved] (STORM-1907) PartitionedTridentSpoutExecutor has incompatible types that cause ClassCastException

[ https://issues.apache.org/jira/browse/STORM-1907?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1907. - Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Merged into master

[jira] [Updated] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1925: Fix Version/s: 2.0.0 > Nimbus fails to start in secure m

[jira] [Resolved] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1925. - Resolution: Fixed Fix Version/s: 1.1.0 Merged to master and 1.x-branch. > Nimbus fa

[jira] [Commented] (STORM-1928) ShellSpout should send heartbeat tuple while nextTuple() is not called

[ https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346550#comment-15346550 ] Jungtaek Lim commented on STORM-1928: - ShellSpout should be changed to alike ShellBolt, I mean having

[jira] [Created] (STORM-1928) ShellSpout should send heartbeat tuple while nextTuple() is not called

Jungtaek Lim created STORM-1928: --- Summary: ShellSpout should send heartbeat tuple while nextTuple() is not called Key: STORM-1928 URL: https://issues.apache.org/jira/browse/STORM-1928 Project: Apache

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345952#comment-15345952 ] Jungtaek Lim commented on STORM-1925: - Harsha pointed out I'm calling Nimbus thrift API inside

<    2   3   4   5   6   7   8   9   10   11   >