[jira] [Created] (STORM-2936) Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch (targeted for 1.1.2)

Jungtaek Lim created STORM-2936: --- Summary: Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch (targeted for 1.1.2) Key: STORM-2936 URL: https://issues.apache.org/jira/browse/STORM-2936 Project:

[jira] [Updated] (STORM-2936) Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch

[ https://issues.apache.org/jira/browse/STORM-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2936: Summary: Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch (was: Overwrite

[jira] [Created] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

Jungtaek Lim created STORM-2937: --- Summary: Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch Key: STORM-2937 URL: https://issues.apache.org/jira/browse/STORM-2937 Project: Apache Storm

[jira] [Resolved] (STORM-2913) STORM-2844 made autocommit and at-most-once storm-kafka-client spouts log warnings on every emit, because those modes don't commit the right metadata to Kafka

[ https://issues.apache.org/jira/browse/STORM-2913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2913. - Resolution: Fixed Fix Version/s: 1.2.0 > STORM-2844 made autocommit and at-most-once

[jira] [Resolved] (STORM-2914) Remove enable.auto.commit support from storm-kafka-client

[ https://issues.apache.org/jira/browse/STORM-2914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2914. - Resolution: Fixed Fix Version/s: 1.2.0 > Remove enable.auto.commit support from

[jira] [Created] (STORM-2943) Binary distribution includes storm-kafka-monitor source/javadoc in toollib directory

Jungtaek Lim created STORM-2943: --- Summary: Binary distribution includes storm-kafka-monitor source/javadoc in toollib directory Key: STORM-2943 URL: https://issues.apache.org/jira/browse/STORM-2943

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354746#comment-16354746 ] Jungtaek Lim edited comment on STORM-2937 at 2/6/18 11:53 PM: -- [~erikdw]

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354746#comment-16354746 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 12:12 AM: -- [~erikdw]

[jira] [Commented] (STORM-2853) Deactivated topologies cause high cpu utilization

[ https://issues.apache.org/jira/browse/STORM-2853?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354766#comment-16354766 ] Jungtaek Lim commented on STORM-2853: - [~vorin] I guess you're saying stateful implemented by user

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354781#comment-16354781 ] Jungtaek Lim commented on STORM-2937: - {quote}Gigantic commits are often a problem for this,

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354791#comment-16354791 ] Jungtaek Lim commented on STORM-2937: - [~erikdw] Ah you need to change root pom.xml to update

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354679#comment-16354679 ] Jungtaek Lim commented on STORM-2937: - And I'm sorry but "if possible", I'm eager to get this in ASAP

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354685#comment-16354685 ] Jungtaek Lim commented on STORM-2937: - Unlike what I'm at least doing it with reading/writing,

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354746#comment-16354746 ] Jungtaek Lim commented on STORM-2937: - [~erikdw] That was fairly simple for 1.1.x-branch, whereas I

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354781#comment-16354781 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 12:31 AM: --

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354667#comment-16354667 ] Jungtaek Lim commented on STORM-2937: - [~erikdw] Suppose we squash all the commits being done for

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354752#comment-16354752 ] Jungtaek Lim edited comment on STORM-2937 at 2/6/18 11:59 PM: -- That's based

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354758#comment-16354758 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 12:05 AM: -- That is just a

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354758#comment-16354758 ] Jungtaek Lim commented on STORM-2937: - That is just a sequence of steps I did which I feel very handy

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354752#comment-16354752 ] Jungtaek Lim commented on STORM-2937: - That's based on the assumption that modifying storm-core due to

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354752#comment-16354752 ] Jungtaek Lim edited comment on STORM-2937 at 2/6/18 11:58 PM: -- That's based

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354781#comment-16354781 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 12:27 AM: --

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354781#comment-16354781 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 12:32 AM: --

[jira] [Commented] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354814#comment-16354814 ] Jungtaek Lim commented on STORM-2937: - [~erikdw] {quote}The main difference in my strategy being that

[jira] [Comment Edited] (STORM-2937) Overwrite storm-kafka-client 1.x-branch into 1.0.x-branch

[ https://issues.apache.org/jira/browse/STORM-2937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16354814#comment-16354814 ] Jungtaek Lim edited comment on STORM-2937 at 2/7/18 1:04 AM: - [~erikdw]

[jira] [Updated] (STORM-2944) Eliminate these deprecated methods in Storm 3

[ https://issues.apache.org/jira/browse/STORM-2944?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2944: Affects Version/s: 3.0.0 > Eliminate these deprecated methods in Storm 3 >

[jira] [Assigned] (STORM-2841) testNoAcksIfFlushFails UT fails with NullPointerException

[ https://issues.apache.org/jira/browse/STORM-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim reassigned STORM-2841: --- Assignee: Jungtaek Lim > testNoAcksIfFlushFails UT fails with NullPointerException >

[jira] [Commented] (STORM-2841) testNoAcksIfFlushFails UT fails with NullPointerException

[ https://issues.apache.org/jira/browse/STORM-2841?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16360448#comment-16360448 ] Jungtaek Lim commented on STORM-2841: - This is actually super odd, because it shouldn't call the real

[jira] [Resolved] (STORM-2940) Increase the CAPACITY value in LoadAwareShuffleGrouping

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

[jira] [Resolved] (STORM-2841) testNoAcksIfFlushFails UT fails with NullPointerException

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

[jira] [Updated] (STORM-2945) Nail down and document how to support background emits in Spouts and Bolts

[ https://issues.apache.org/jira/browse/STORM-2945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2945: Affects Version/s: 2.0.0 > Nail down and document how to support background emits in Spouts and

[jira] [Updated] (STORM-2945) Nail down and document how to support background emits in Spouts and Bolts

[ https://issues.apache.org/jira/browse/STORM-2945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2945: Fix Version/s: (was: 2.0.0) > Nail down and document how to support background emits in Spouts

[jira] [Resolved] (STORM-2932) topology.localityaware.higher/lower.bound.percent configs are confusing

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

[jira] [Resolved] (STORM-2936) Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch

[ https://issues.apache.org/jira/browse/STORM-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2936. - Resolution: Fixed Fix Version/s: 1.2.0 > Overwrite storm-kafka-client 1.x-branch into

[jira] [Commented] (STORM-2936) Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch

[ https://issues.apache.org/jira/browse/STORM-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363545#comment-16363545 ] Jungtaek Lim commented on STORM-2936: - [~erikdw] Thanks for the correction! Just fixed. > Overwrite

[jira] [Updated] (STORM-2947) Review and fix/remove deprecated things in Storm 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2947: Description: We've been deprecating the things but haven't have time to replace/get rid of them.

[jira] [Commented] (STORM-2947) Review and fix/remove deprecated things in Storm 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363664#comment-16363664 ] Jungtaek Lim commented on STORM-2947: - Many of deprecated annotation don't have deprecated javadoc tag

[jira] [Updated] (STORM-2936) Overwrite storm-kafka-client 1.x-branch into 1.1.x-branch

[ https://issues.apache.org/jira/browse/STORM-2936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2936: Fix Version/s: (was: 1.2.0) 1.1.2 > Overwrite storm-kafka-client 1.x-branch

[jira] [Commented] (STORM-2947) Review and fix/remove deprecated things in Storm 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363548#comment-16363548 ] Jungtaek Lim commented on STORM-2947: - I just wrote a page "Deprecated annotation in master branch

[jira] [Resolved] (STORM-2761) JoinBolt.java 's paradigm is new model of stream join?

[ https://issues.apache.org/jira/browse/STORM-2761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2761. - Resolution: Not A Problem > JoinBolt.java 's paradigm is new model of stream join? >

[jira] [Resolved] (STORM-1732) Resources are deleted when worker dies

[ https://issues.apache.org/jira/browse/STORM-1732?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1732. - Resolution: Invalid We introduced Supervisor V2 in 1.0.3 which completely renew the code on

[jira] [Updated] (STORM-2878) Supervisor collapse continuously when there is a expired assignment for overdue storm

[ https://issues.apache.org/jira/browse/STORM-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2878: Fix Version/s: (was: 2.0.0) > Supervisor collapse continuously when there is a expired

[jira] [Resolved] (STORM-2436) Custom Log4j2 appender not working with storm

[ https://issues.apache.org/jira/browse/STORM-2436?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2436. - Resolution: Won't Fix The version is not we're tracking now. Closing. > Custom Log4j2 appender

[jira] [Updated] (STORM-2382) log4j and slf4j conflicting libraries issue

[ https://issues.apache.org/jira/browse/STORM-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2382: Priority: Minor (was: Blocker) > log4j and slf4j conflicting libraries issue >

[jira] [Commented] (STORM-2382) log4j and slf4j conflicting libraries issue

[ https://issues.apache.org/jira/browse/STORM-2382?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363470#comment-16363470 ] Jungtaek Lim commented on STORM-2382: - Lower the priority since it is specific to the case and answer

[jira] [Resolved] (STORM-1621) [Storm][DRPC] Request failed after 60 seconds

[ https://issues.apache.org/jira/browse/STORM-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-1621. - Resolution: Won't Fix Too old version which we don't track now, and also it is rather a kind of

[jira] [Resolved] (STORM-617) In Storm secure mode re-deploying trident topology causes zookeeper ACL issue

[ https://issues.apache.org/jira/browse/STORM-617?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-617. Resolution: Won't Fix Closing due to inactivity. It is also based on the version we don't track as

[jira] [Created] (STORM-2947) Review and fix/remove deprecated things in Storm 2.0.0

Jungtaek Lim created STORM-2947: --- Summary: Review and fix/remove deprecated things in Storm 2.0.0 Key: STORM-2947 URL: https://issues.apache.org/jira/browse/STORM-2947 Project: Apache Storm

[jira] [Commented] (STORM-1898) MAX_BATCH_SIZE_CONF not working in Trident storm Spout

[ https://issues.apache.org/jira/browse/STORM-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16363490#comment-16363490 ] Jungtaek Lim commented on STORM-1898: - The issue doesn't look like blocker. Lowering priority. >

[jira] [Updated] (STORM-1898) MAX_BATCH_SIZE_CONF not working in Trident storm Spout

[ https://issues.apache.org/jira/browse/STORM-1898?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1898: Priority: Major (was: Blocker) > MAX_BATCH_SIZE_CONF not working in Trident storm Spout >

[jira] [Resolved] (STORM-2306) Redesign Messaging Subsystem and switch to JCTools Queues

[ https://issues.apache.org/jira/browse/STORM-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2306. - Resolution: Fixed Fix Version/s: 2.0.0 Marking as resolved since [~revans2] merged this

[jira] [Resolved] (STORM-2933) Add a storm-perf topology that uses storm-kafka-client, so we can benchmark that module

[ https://issues.apache.org/jira/browse/STORM-2933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2933. - Resolution: Fixed Thanks [~Srdo], I merged into master. > Add a storm-perf topology that uses

[jira] [Updated] (STORM-2938) Share CuratorFramework instance in a process (daemons/worker)

[ https://issues.apache.org/jira/browse/STORM-2938?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2938: Priority: Minor (was: Major) > Share CuratorFramework instance in a process (daemons/worker) >

[jira] [Created] (STORM-2938) Share CuratorFramework instance in a process (daemons/worker)

Jungtaek Lim created STORM-2938: --- Summary: Share CuratorFramework instance in a process (daemons/worker) Key: STORM-2938 URL: https://issues.apache.org/jira/browse/STORM-2938 Project: Apache Storm

[jira] [Resolved] (STORM-2948) Add -XX:+HeapDumpOnOutOfMemoryError for maven-surefire-plugin in pom.xml

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

[jira] [Resolved] (STORM-2950) ArrayIndexOutOfBoundsException in FieldsGrouper.chooseTasks function

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

[jira] [Created] (STORM-2964) Deprecate old Spout wait strategy model in 1.x version line

Jungtaek Lim created STORM-2964: --- Summary: Deprecate old Spout wait strategy model in 1.x version line Key: STORM-2964 URL: https://issues.apache.org/jira/browse/STORM-2964 Project: Apache Storm

[jira] [Commented] (STORM-2958) Use new wait strategies for Spout as well

[ https://issues.apache.org/jira/browse/STORM-2958?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16369735#comment-16369735 ] Jungtaek Lim commented on STORM-2958: - [~roshan_naik] I filed new issue (STORM-2964) about deprecating

[jira] [Created] (STORM-2962) KeyValue State Resharding

Jungtaek Lim created STORM-2962: --- Summary: KeyValue State Resharding Key: STORM-2962 URL: https://issues.apache.org/jira/browse/STORM-2962 Project: Apache Storm Issue Type: Improvement

[jira] [Resolved] (STORM-2958) Use new wait strategies for Spout as well

[ https://issues.apache.org/jira/browse/STORM-2958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2958. - Resolution: Fixed Thanks [~roshan_naik], I merged into master. > Use new wait strategies for

[jira] [Commented] (STORM-2964) Deprecate old Spout wait strategy model in 1.x version line

[ https://issues.apache.org/jira/browse/STORM-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16370885#comment-16370885 ] Jungtaek Lim commented on STORM-2964: - [~roshan_naik] OK thanks. It might be better to convert this

[jira] [Updated] (STORM-2964) Deprecate removed configs/interfaces/classes from Storm 2.0.0 to 1.x version line

[ https://issues.apache.org/jira/browse/STORM-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2964: Summary: Deprecate removed configs/interfaces/classes from Storm 2.0.0 to 1.x version line (was:

[jira] [Resolved] (STORM-2961) Refactoring duplicate code in Topology Builder classes

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

[jira] [Updated] (STORM-2964) Deprecate removed configs/interfaces/classes from Storm 2.0.0 to 1.x version line

[ https://issues.apache.org/jira/browse/STORM-2964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2964: Description: This is to track the effort on deprecating removed configs/interfaces/classes from

[jira] [Commented] (STORM-2947) Review and fix/remove deprecated things in Storm 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16368706#comment-16368706 ] Jungtaek Lim commented on STORM-2947: - storm.local.mode.zmq is not annotated as deprecated, but it is

[jira] [Created] (STORM-2960) Better to stress importance of setting up proper OS account for Storm processes

Jungtaek Lim created STORM-2960: --- Summary: Better to stress importance of setting up proper OS account for Storm processes Key: STORM-2960 URL: https://issues.apache.org/jira/browse/STORM-2960 Project:

[jira] [Resolved] (STORM-2939) Create interface for processing worker metrics

[ https://issues.apache.org/jira/browse/STORM-2939?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2939. - Resolution: Fixed Marking as resolved as [~agresch] stated the work for issue is finished. >

[jira] [Commented] (STORM-2952) Deprecate storm-kafka in 1.x

[ https://issues.apache.org/jira/browse/STORM-2952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16375488#comment-16375488 ] Jungtaek Lim commented on STORM-2952: - [~Srdo] Could you work on following up task: removing

[jira] [Resolved] (STORM-2969) remove @isDerivedFrom validation for topology.spout/bolt/backpressure.wait.strategy

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

[jira] [Updated] (STORM-2953) Remove storm-kafka in 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2953?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2953: Priority: Blocker (was: Minor) > Remove storm-kafka in 2.0.0 > --- > >

[jira] [Created] (STORM-2965) Interpret wildcard in classpath correctly when reading config from classpath

Jungtaek Lim created STORM-2965: --- Summary: Interpret wildcard in classpath correctly when reading config from classpath Key: STORM-2965 URL: https://issues.apache.org/jira/browse/STORM-2965 Project:

[jira] [Updated] (STORM-2965) Interpret wildcard in classpath correctly when reading config from classpath

[ https://issues.apache.org/jira/browse/STORM-2965?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2965: Description: While reading configuration file from classpath at Utils.getConfigFromClasspath(), it

[jira] [Closed] (STORM-2878) Supervisor collapse continuously when there is a expired assignment for overdue storm

[ https://issues.apache.org/jira/browse/STORM-2878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim closed STORM-2878. --- Resolution: Duplicate Assignee: Yuzhao Chen > Supervisor collapse continuously when there is a

[jira] [Resolved] (STORM-2965) Interpret wildcard in classpath correctly when reading config from classpath

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

[jira] [Closed] (STORM-1433) StormSQL Phase II

[ https://issues.apache.org/jira/browse/STORM-1433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim closed STORM-1433. --- Resolution: Fixed All subtasks completed. > StormSQL Phase II > - > >

[jira] [Commented] (STORM-2909) New Metrics Reporting API - for 2.0.0

[ https://issues.apache.org/jira/browse/STORM-2909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16376376#comment-16376376 ] Jungtaek Lim commented on STORM-2909: - [~ptgoetz] Could you spend time to work on this issue? This is

[jira] [Resolved] (STORM-2863) Some ras tests fail because of static resource caching

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

[jira] [Resolved] (STORM-2690) resurrect invocation of ISupervisor.assigned() & make Supervisor.launchDaemon() accessible

[ https://issues.apache.org/jira/browse/STORM-2690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-2690. - Resolution: Fixed Fix Version/s: 1.0.6 1.1.2 1.2.0

[jira] [Resolved] (STORM-2843) Flux: properties file not found when loading resources from classpath

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

[jira] [Commented] (STORM-2862) More flexible logging in multilang (Python, Ruby, JS)

[ https://issues.apache.org/jira/browse/STORM-2862?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16303483#comment-16303483 ] Jungtaek Lim commented on STORM-2862: - [~hmcc] You can extract component name and task ID from thread

[jira] [Resolved] (STORM-2869) KafkaSpout discards all pending records when adjusting the consumer position after a commit

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

[jira] [Created] (STORM-2870) FileBasedEventLogger leaks non-daemon ExecutorService which prevents process to be finished

Jungtaek Lim created STORM-2870: --- Summary: FileBasedEventLogger leaks non-daemon ExecutorService which prevents process to be finished Key: STORM-2870 URL: https://issues.apache.org/jira/browse/STORM-2870

[jira] [Commented] (STORM-1188) PartialKeyGrouping missing from storm.thrift (and can't use it via custom_object)

[ https://issues.apache.org/jira/browse/STORM-1188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16304176#comment-16304176 ] Jungtaek Lim commented on STORM-1188: - [~dan.blanchard] How do you define the topology with accessing

[jira] [Updated] (STORM-442) multilang ShellBolt/ShellSpout die() can be hang when Exception happened

[ https://issues.apache.org/jira/browse/STORM-442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-442: --- Fix Version/s: 0.9.7 > multilang ShellBolt/ShellSpout die() can be hang when Exception happened >

[jira] [Updated] (STORM-2311) A browser which is outside the cluster cant's access storm ui when storm cluster in a security mode

[ https://issues.apache.org/jira/browse/STORM-2311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2311: Fix Version/s: (was: 1.0.2) > A browser which is outside the cluster cant's access storm ui

[jira] [Updated] (STORM-1838) [storm-kafka-client] the resumed OffsetEntry goes different

[ https://issues.apache.org/jira/browse/STORM-1838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1838: Fix Version/s: (was: 1.0.1) > [storm-kafka-client] the resumed OffsetEntry goes different >

[jira] [Updated] (STORM-1776) Error when processing event java.io.FileNotFoundException

[ https://issues.apache.org/jira/browse/STORM-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1776: Fix Version/s: (was: 1.0.0) > Error when processing event java.io.FileNotFoundException >

[jira] [Updated] (STORM-1689) set request headersize for logviewer

[ https://issues.apache.org/jira/browse/STORM-1689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1689: Fix Version/s: (was: 2.0.0) (was: 1.0.0) > set request headersize for

[jira] [Updated] (STORM-1367) Issue with OpaqueTridentKafkaSpout - TridentKafkaConfig getting (java.lang.RuntimeException: kafka.common.OffsetOutOfRangeException)

[ https://issues.apache.org/jira/browse/STORM-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1367: Fix Version/s: (was: 1.0.0) > Issue with OpaqueTridentKafkaSpout - TridentKafkaConfig getting

[jira] [Updated] (STORM-1469) Unable to deploy large topologies on apache storm

[ https://issues.apache.org/jira/browse/STORM-1469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1469: Fix Version/s: (was: 1.0.0) > Unable to deploy large topologies on apache storm >

[jira] [Updated] (STORM-838) Upgrade Jackson

[ https://issues.apache.org/jira/browse/STORM-838?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-838: --- Fix Version/s: (was: 1.0.0) > Upgrade Jackson > --- > > Key: STORM-838

[jira] [Updated] (STORM-1777) Backport KafkaBolt from Storm 1.0.0 to 0.10.0 to support properties configuration method

[ https://issues.apache.org/jira/browse/STORM-1777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1777: Fix Version/s: (was: 0.10.0) > Backport KafkaBolt from Storm 1.0.0 to 0.10.0 to support

[jira] [Updated] (STORM-586) Trident kafka spout fails instead of updating offset when kafka offset is out of range.

[ https://issues.apache.org/jira/browse/STORM-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-586: --- Fix Version/s: (was: 0.10.0) > Trident kafka spout fails instead of updating offset when kafka

[jira] [Updated] (STORM-2292) Kafka spout enhancement, for our of range edge cases

[ https://issues.apache.org/jira/browse/STORM-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-2292: Fix Version/s: (was: 0.10.0) > Kafka spout enhancement, for our of range edge cases >

[jira] [Updated] (STORM-1021) HeartbeatExecutorService issue in Shell Spout\Bolt

[ https://issues.apache.org/jira/browse/STORM-1021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1021: Fix Version/s: (was: 0.10.0) > HeartbeatExecutorService issue in Shell Spout\Bolt >

[jira] [Resolved] (STORM-487) Remove storm.cmd, no need to duplicate work python runs on windows too.

[ https://issues.apache.org/jira/browse/STORM-487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-487. Resolution: Fixed Assignee: Jungtaek Lim It was fixed via letting "storm" script be compatible

[jira] [Resolved] (STORM-586) Trident kafka spout fails instead of updating offset when kafka offset is out of range.

[ https://issues.apache.org/jira/browse/STORM-586?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim resolved STORM-586. Resolution: Fixed Fix Version/s: 0.10.0 Marking as resolved since the patch got merged. >

[jira] [Updated] (STORM-755) An exception occured while executing the Java class. fyp-storm-try.src.jvm.Topology

[ https://issues.apache.org/jira/browse/STORM-755?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-755: --- Fix Version/s: (was: 0.9.4) > An exception occured while executing the Java class. >

[jira] [Updated] (STORM-469) Storm UI Last Error Detail Insufficient for debugging

[ https://issues.apache.org/jira/browse/STORM-469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-469: --- Fix Version/s: (was: 0.10.0) > Storm UI Last Error Detail Insufficient for debugging >

[jira] [Updated] (STORM-705) Add BigPetStore stream to examples/

[ https://issues.apache.org/jira/browse/STORM-705?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-705: --- Fix Version/s: (was: 0.9.4) > Add BigPetStore stream to examples/ >

<    3   4   5   6   7   8   9   10   >