[jira] [Commented] (STORM-1859) Late tuples are not acked in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313748#comment-15313748 ] ASF GitHub Bot commented on STORM-1859: --- Github user arunmahadevan commented on the

[GitHub] storm issue #1437: STORM-1859: Ack late tuples in windowed mode

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1437 @abhishej This will be part of the next release i.e. 1.0.2. If you want it now, you could clone the 1.0.x branch (or the 1.0.1 tag and cherry-pick the commit). You can build the distribution by

[jira] [Commented] (STORM-1859) Late tuples are not acked in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1859?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313721#comment-15313721 ] ASF GitHub Bot commented on STORM-1859: --- Github user abhishej commented on the issue

[GitHub] storm issue #1437: STORM-1859: Ack late tuples in windowed mode

2016-06-02 Thread abhishej
Github user abhishej commented on the issue: https://github.com/apache/storm/pull/1437 How can we get this patch. We have storm 1.0.1 release deployed in current production environment, and has the same issue. Can you please provide the link for the patch, or steps to generate

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65659063 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -284,6 +298,10 @@ public void cleanup() { @Overri

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313613#comment-15313613 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313589#comment-15313589 ] ASF GitHub Bot commented on STORM-1723: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1460: STORM-1723 Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1460 Fixed whitespaces, rebased and squashed. --- 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

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313561#comment-15313561 ] ASF GitHub Bot commented on STORM-1723: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1460: STORM-1723 Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1460 whitespace again. I'll take care of this. --- 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 featur

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313556#comment-15313556 ] ASF GitHub Bot commented on STORM-1723: --- GitHub user HeartSaVioR opened a pull reque

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313557#comment-15313557 ] ASF GitHub Bot commented on STORM-1723: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1352 Never mind. Pull request for master is here: #1460. --- 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 t

[GitHub] storm pull request #1460: STORM-1723 Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
GitHub user HeartSaVioR opened a pull request: https://github.com/apache/storm/pull/1460 STORM-1723 Introduce ClusterMetricsConsumer Pull request for 1.x is here: #1352 * ClusterMetricsConsumer publishes cluster-side related metrics into consumers * like MetricsConsu

[jira] [Commented] (STORM-1875) Separate Jedis/JedisCluster Config

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313526#comment-15313526 ] ASF GitHub Bot commented on STORM-1875: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1459: [STORM-1875]Separate Jedis/JedisCluster Config

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1459 One other way without breaking compatibility but not beauty is adding some utility methods to AbstractRedisBolt like, ``` public JedisCluster asJedisCluster(JedisCommands instance) t

[jira] [Commented] (STORM-1875) Separate Jedis/JedisCluster Config

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313522#comment-15313522 ] ASF GitHub Bot commented on STORM-1875: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1459: [STORM-1875]Separate Jedis/JedisCluster Config

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1459 The problem is actually not simple. The blocking point is JedisCommands interface, not config. JedisCommands exposes operations which use only single key. Since some multiple keys operations

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313484#comment-15313484 ] ASF GitHub Bot commented on STORM-1723: --- Github user HeartSaVioR commented on the is

[GitHub] storm issue #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1352 @harshach @hmcl Addressed review comments, and rebased with commits squashed. I feel applying this to 1.0.x seems to be against semantic versioning, so I would not address it. Do we want

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15313462#comment-15313462 ] ASF GitHub Bot commented on STORM-1723: --- Github user HeartSaVioR commented on a diff

[GitHub] storm pull request #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1352#discussion_r65647236 --- Diff: storm-core/src/clj/org/apache/storm/daemon/nimbus.clj --- @@ -1355,48 +1366,843 @@ (defmethod blob-sync :local [conf nimbus] nil)

[GitHub] storm pull request #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1352#discussion_r65641418 --- Diff: storm-core/src/clj/org/apache/storm/daemon/nimbus.clj --- @@ -1355,48 +1366,843 @@ (defmethod blob-sync :local [conf nimbus] nil)

[GitHub] storm pull request #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1352#discussion_r65641444 --- Diff: storm-core/src/clj/org/apache/storm/daemon/nimbus.clj --- @@ -1355,48 +1366,843 @@ (defmethod blob-sync :local [conf nimbus] nil)

[GitHub] storm issue #1442: Adding hdfs-conf.yaml to all test cases to support securi...

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1442 @csivaguru Missing one more thing, you need to submit pull request against master unless there's specific reason to not do. You may want to submit additional pull requests against version branche

[GitHub] storm issue #1442: Adding hdfs-conf.yaml to all test cases to support securi...

2016-06-02 Thread HeartSaVioR
Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1442 @csivaguru Could you file an issue and link it? I think it's not trivial fix so we would want to track. --- If your project is set up for it, you can reply to this email and have your reply appe

Re: [Discussion] Release Apache Storm 1.0.2

2016-06-02 Thread Jungtaek Lim
darion, I'm not sure I'm catching what you mean correctly. Most of recent projects are trying to respect semantic versioning. Please refer here for more details. http://semver.org/ Before Storm 0.10.0, I didn't see the release policy or theory Apache Storm are respecting. New features and improve

Storm and Redis

2016-06-02 Thread Daniela S
Hi I have a question regarding the use of Storm with a cache. Hopefully someone can help me. I have a Kafka spout which reads JSON messages from a Kafka topic. The messages contain an ID, a timestamp and "start" or "end". The next step is a bolt, which stores the "start" messages in Redis and

[GitHub] storm issue #1442: Adding hdfs-conf.yaml to all test cases to support securi...

2016-06-02 Thread csivaguru
Github user csivaguru commented on the issue: https://github.com/apache/storm/pull/1442 @harshach @hmcl @HeartSaVioR Can I get a review on this change? --- 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

[jira] [Commented] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312701#comment-15312701 ] ASF GitHub Bot commented on STORM-1136: --- Github user priyank5485 commented on a diff

[GitHub] storm pull request #1451: STORM-1136: Command line module to return kafka sp...

2016-06-02 Thread priyank5485
Github user priyank5485 commented on a diff in the pull request: https://github.com/apache/storm/pull/1451#discussion_r65582081 --- Diff: external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java --- @@ -0,0 +1,374 @@ +/* + * License

[jira] [Commented] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312693#comment-15312693 ] ASF GitHub Bot commented on STORM-1136: --- Github user priyank5485 commented on a diff

[GitHub] storm pull request #1451: STORM-1136: Command line module to return kafka sp...

2016-06-02 Thread priyank5485
Github user priyank5485 commented on a diff in the pull request: https://github.com/apache/storm/pull/1451#discussion_r65581276 --- Diff: external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java --- @@ -0,0 +1,374 @@ +/* + * License

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312688#comment-15312688 ] ASF GitHub Bot commented on STORM-1873: --- Github user kosii commented on a diff in th

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread kosii
Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65580954 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -284,6 +298,10 @@ public void cleanup() { @Override

[GitHub] storm pull request #1451: STORM-1136: Command line module to return kafka sp...

2016-06-02 Thread hmcl
Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/1451#discussion_r65576345 --- Diff: external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java --- @@ -0,0 +1,374 @@ +/* + * Licensed to th

[jira] [Commented] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312644#comment-15312644 ] ASF GitHub Bot commented on STORM-1136: --- Github user hmcl commented on a diff in the

[jira] [Commented] (STORM-1136) Provide a bin script to check consumer lag from KafkaSpout to Kafka topic offsets

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312639#comment-15312639 ] ASF GitHub Bot commented on STORM-1136: --- Github user hmcl commented on a diff in the

[GitHub] storm pull request #1451: STORM-1136: Command line module to return kafka sp...

2016-06-02 Thread hmcl
Github user hmcl commented on a diff in the pull request: https://github.com/apache/storm/pull/1451#discussion_r65576093 --- Diff: external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagUtil.java --- @@ -0,0 +1,374 @@ +/* + * Licensed to th

[jira] [Commented] (STORM-822) Kafka Spout New Consumer API

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312603#comment-15312603 ] ASF GitHub Bot commented on STORM-822: -- Github user hmcl commented on the issue:

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312600#comment-15312600 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65573427 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,22 @@ public BaseWindowedBolt withTimestampField(St

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312613#comment-15312613 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65574257 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -284,6 +298,10 @@ public void cleanup() { @Overri

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312605#comment-15312605 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65573649 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,22 @@ public BaseWindowedBolt withTimestampField(St

[GitHub] storm issue #1131: STORM-822: Kafka Spout New Consumer API

2016-06-02 Thread hmcl
Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1131 @jianbzhou thanks. Looking at it. --- 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 w

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

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312590#comment-15312590 ] ASF GitHub Bot commented on STORM-1838: --- Github user hmcl commented on the issue:

[GitHub] storm issue #1419: STORM-1838 update OffsetEntry to support EARLIEST/LATEST ...

2016-06-02 Thread hmcl
Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1419 @flisky some stuff came up. Apologies for the delay in my response. I will get back to you today or tomorrow as I am working on this now. --- If your project is set up for it, you can reply to this ema

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312587#comment-15312587 ] ASF GitHub Bot commented on STORM-1723: --- Github user hmcl commented on the issue:

[GitHub] storm issue #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread hmcl
Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1352 +1. I am also in favor of making cluster summary modular. --- 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 th

[GitHub] storm issue #1453: STORM-1873 Implement alternative behaviour for late tuple...

2016-06-02 Thread kosii
Github user kosii commented on the issue: https://github.com/apache/storm/pull/1453 I updated the docs, and I'm going to work on the unit tests while the patch is being reviewed --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312508#comment-15312508 ] ASF GitHub Bot commented on STORM-1873: --- Github user kosii commented on the issue:

[GitHub] storm issue #1458: STORM-1878: Flux can now handle IStatefulBolts

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1458 @sakanaou Thanks for the patch. Can you also add an example flux topology with an IStatefulBolt similar to to existing ones under https://github.com/apache/storm/tree/master/external/

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312444#comment-15312444 ] ASF GitHub Bot commented on STORM-1873: --- Github user kosii commented on a diff in th

[jira] [Commented] (STORM-1878) Flux does not handle stateful bolts

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312445#comment-15312445 ] ASF GitHub Bot commented on STORM-1878: --- Github user arunmahadevan commented on the

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312443#comment-15312443 ] ASF GitHub Bot commented on STORM-1873: --- Github user kosii commented on a diff in th

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread kosii
Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65557613 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String TOPOLOGY_BOLTS_TUPLE_

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread kosii
Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65557653 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -268,8 +277,12 @@ public void execute(Tuple input) { if

[jira] [Commented] (STORM-1875) Separate Jedis/JedisCluster Config

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1875?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312436#comment-15312436 ] ASF GitHub Bot commented on STORM-1875: --- GitHub user darionyaphet opened a pull requ

[GitHub] storm pull request #1459: [STORM-1875]Separate Jedis/JedisCluster Config

2016-06-02 Thread darionyaphet
GitHub user darionyaphet opened a pull request: https://github.com/apache/storm/pull/1459 [STORM-1875]Separate Jedis/JedisCluster Config [STORM-1875](https://issues.apache.org/jira/browse/STORM-1875) Separate Jedis / JedisCluster to provide full operations for each environm

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312426#comment-15312426 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r6185 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String TOPOLOGY_BOLT

[jira] [Updated] (STORM-1880) Support EXISTS Command Storm-Redis

2016-06-02 Thread darion yaphet (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet updated STORM-1880: - Issue Type: New Feature (was: Bug) > Support EXISTS Command Storm-Redis > --

[jira] [Created] (STORM-1880) Support EXISTS Command Storm-Redis

2016-06-02 Thread darion yaphet (JIRA)
darion yaphet created STORM-1880: Summary: Support EXISTS Command Storm-Redis Key: STORM-1880 URL: https://issues.apache.org/jira/browse/STORM-1880 Project: Apache Storm Issue Type: Bug

[jira] [Commented] (STORM-822) Kafka Spout New Consumer API

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312301#comment-15312301 ] ASF GitHub Bot commented on STORM-822: -- Github user jianbzhou commented on the issue:

[GitHub] storm issue #1131: STORM-822: Kafka Spout New Consumer API

2016-06-02 Thread jianbzhou
Github user jianbzhou commented on the issue: https://github.com/apache/storm/pull/1131 @hmcl, today we found one NullpointerException and i applied a fix as below: In method doSeekRetriableTopicPartitions, if one partition was never committed before one message is failed back

[jira] [Commented] (STORM-1874) Update Logger access permissions

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312287#comment-15312287 ] ASF GitHub Bot commented on STORM-1874: --- Github user dossett commented on the issue:

[GitHub] storm issue #1456: [STORM-1874]Update logger private permissions

2016-06-02 Thread dossett
Github user dossett commented on the issue: https://github.com/apache/storm/pull/1456 +1 --- 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

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312206#comment-15312206 ] ASF GitHub Bot commented on STORM-1873: --- Github user kosii commented on a diff in th

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread kosii
Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65527974 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String TOPOLOGY_BOLTS_TUPLE_

[GitHub] storm issue #1419: STORM-1838 update OffsetEntry to support EARLIEST/LATEST ...

2016-06-02 Thread flisky
Github user flisky commented on the issue: https://github.com/apache/storm/pull/1419 friendly ping, @hmcl --- 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, o

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

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1838?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312182#comment-15312182 ] ASF GitHub Bot commented on STORM-1838: --- Github user flisky commented on the issue:

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

2016-06-02 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312147#comment-15312147 ] Stig Rohde Døssing edited comment on STORM-1879 at 6/2/16 11:32 AM:

[jira] [Commented] (STORM-1878) Flux does not handle stateful bolts

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1878?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312149#comment-15312149 ] ASF GitHub Bot commented on STORM-1878: --- GitHub user sakanaou opened a pull request:

[GitHub] storm pull request #1458: STORM-1878: Flux can now handle IStatefulBolts

2016-06-02 Thread sakanaou
GitHub user sakanaou opened a pull request: https://github.com/apache/storm/pull/1458 STORM-1878: Flux can now handle IStatefulBolts We noticed that Flux could not yet handle IStatefulBolts in a topology definition. With this small addition we can successfully build and deploy our

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

2016-06-02 Thread JIRA
[ https://issues.apache.org/jira/browse/STORM-1879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stig Rohde Døssing updated STORM-1879: -- Attachment: nimbus-supervisor.zip The nimbus and supervisor logs for the period. The und

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

2016-06-02 Thread JIRA
Stig Rohde Døssing created STORM-1879: - Summary: Supervisor may not shut down workers cleanly Key: STORM-1879 URL: https://issues.apache.org/jira/browse/STORM-1879 Project: Apache Storm I

[jira] [Created] (STORM-1878) Flux does not handle stateful bolts

2016-06-02 Thread Daniel Klessing (JIRA)
Daniel Klessing created STORM-1878: -- Summary: Flux does not handle stateful bolts Key: STORM-1878 URL: https://issues.apache.org/jira/browse/STORM-1878 Project: Apache Storm Issue Type: Bug

[jira] [Commented] (STORM-1874) Update Logger access permissions

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1874?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15312013#comment-15312013 ] ASF GitHub Bot commented on STORM-1874: --- Github user harshach commented on the issue

[GitHub] storm issue #1456: [STORM-1874]Update logger private permissions

2016-06-02 Thread harshach
Github user harshach commented on the issue: https://github.com/apache/storm/pull/1456 +1 --- 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

[jira] [Commented] (STORM-1755) Revert the kafka client version upgrade in storm-kafka module

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311941#comment-15311941 ] ASF GitHub Bot commented on STORM-1755: --- Github user harshach commented on the issue

[GitHub] storm issue #1386: STORM-1755: Revert the kafka client version to 0.8.x in s...

2016-06-02 Thread harshach
Github user harshach commented on the issue: https://github.com/apache/storm/pull/1386 @abhishekagarwal87 yes. I don't have any better name in mind :) . how about keeping kafka.version as it is for new kafka spout and adding storm-kafka.kafka.version for the old one. --- If your pro

[jira] [Commented] (STORM-1755) Revert the kafka client version upgrade in storm-kafka module

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311937#comment-15311937 ] ASF GitHub Bot commented on STORM-1755: --- Github user abhishekagarwal87 commented on

[GitHub] storm issue #1386: STORM-1755: Revert the kafka client version to 0.8.x in s...

2016-06-02 Thread abhishekagarwal87
Github user abhishekagarwal87 commented on the issue: https://github.com/apache/storm/pull/1386 @harshach do you mean to suggest something like following ``` 0.8.2.1 kafka_2.10 0.9.0.1

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311935#comment-15311935 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on the

[GitHub] storm issue #1453: STORM-1873 Implement alternative behaviour for late tuple...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on the issue: https://github.com/apache/storm/pull/1453 I have gone through the details and have left some comments. Can you update the [documentation](https://github.com/apache/storm/blob/master/docs/Windowing.md) where it references late tuples a

Re:[Discussion] Release Apache Storm 1.0.2

2016-06-02 Thread darion.yaphet
Hi team :In fact , I have a question about release new version . We have received some bug fix , improvement and new features . Which one will include in difference version ? This have some rule ? thanks :D At 2016-06-01 17:43:54, "Jungtaek Lim" wrote: >Hi devs, > >Since we're resolving some c

[jira] [Commented] (STORM-1755) Revert the kafka client version upgrade in storm-kafka module

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1755?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311925#comment-15311925 ] ASF GitHub Bot commented on STORM-1755: --- Github user harshach commented on the issue

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311927#comment-15311927 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311928#comment-15311928 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[jira] [Commented] (STORM-1873) Reemit late tuples in windowed mode

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311926#comment-15311926 ] ASF GitHub Bot commented on STORM-1873: --- Github user arunmahadevan commented on a di

[GitHub] storm issue #1386: STORM-1755: Revert the kafka client version to 0.8.x in s...

2016-06-02 Thread harshach
Github user harshach commented on the issue: https://github.com/apache/storm/pull/1386 @abhishekagarwal87 didn't see this merged in. Instead of overriding the kafka.version for storm-kafka lets add another param to pom.xml and keep it at 0.8.2.1 and use that as kafka version for sto

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500717 --- Diff: storm-core/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java --- @@ -268,8 +277,12 @@ public void execute(Tuple input) {

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500709 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1872,6 +1872,13 @@ @isString public static final String TOPOLOGY_BOLT

[GitHub] storm pull request #1453: STORM-1873 Implement alternative behaviour for lat...

2016-06-02 Thread arunmahadevan
Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1453#discussion_r65500739 --- Diff: storm-core/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java --- @@ -255,6 +255,17 @@ public BaseWindowedBolt withTimestampField(St

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311919#comment-15311919 ] ASF GitHub Bot commented on STORM-1723: --- Github user harshach commented on the issue

[GitHub] storm issue #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread harshach
Github user harshach commented on the issue: https://github.com/apache/storm/pull/1352 +1 . If possible we should move extracting cluster summary to a common file and use that in ui and nimbus --- If your project is set up for it, you can reply to this email and have your reply appea

[jira] [Commented] (STORM-1723) Introduce ClusterMetricsConsumer

2016-06-02 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/STORM-1723?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15311916#comment-15311916 ] ASF GitHub Bot commented on STORM-1723: --- Github user harshach commented on a diff in

[GitHub] storm pull request #1352: STORM-1723 (1.x) Introduce ClusterMetricsConsumer

2016-06-02 Thread harshach
Github user harshach commented on a diff in the pull request: https://github.com/apache/storm/pull/1352#discussion_r65499343 --- Diff: storm-core/src/clj/org/apache/storm/daemon/nimbus.clj --- @@ -1355,48 +1366,843 @@ (defmethod blob-sync :local [conf nimbus] nil)

  1   2   >