[jira] [Commented] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106469#comment-15106469 ] ASF GitHub Bot commented on STORM-1478: --- Github user HeartSaVioR commented on the pull request:

[GitHub] storm pull request: [STORM-1478] make bolt's getComponentConfigura...

Github user HeartSaVioR commented on the pull request: https://github.com/apache/storm/pull/1020#issuecomment-172785005 +1 again. --- 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-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106597#comment-15106597 ] ASF GitHub Bot commented on STORM-1478: --- Github user arunmahadevan commented on the pull request:

[GitHub] storm pull request: [STORM-1478] make bolt's getComponentConfigura...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1020 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106598#comment-15106598 ] ASF GitHub Bot commented on STORM-1478: --- Github user asfgit closed the pull request at:

[GitHub] storm pull request: [STORM-1478] make bolt's getComponentConfigura...

Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/1020#issuecomment-172819951 +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

[jira] [Commented] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106600#comment-15106600 ] Arun Mahadevan commented on STORM-1478: --- Thanks [~vesense] merged to master. > make bolt's

[jira] [Resolved] (STORM-1478) make bolt's getComponentConfiguration method cleaner/simpler

[ https://issues.apache.org/jira/browse/STORM-1478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arun Mahadevan resolved STORM-1478. --- Resolution: Fixed Fix Version/s: 2.0.0 > make bolt's getComponentConfiguration method

[jira] [Created] (STORM-1485) DRPC Connectivity Issues

Kishor Patil created STORM-1485: --- Summary: DRPC Connectivity Issues Key: STORM-1485 URL: https://issues.apache.org/jira/browse/STORM-1485 Project: Apache Storm Issue Type: Bug

[GitHub] storm pull request: [STORM-1450] - Fix bugs and refactor code in R...

Github user jerrypeng commented on the pull request: https://github.com/apache/storm/pull/1016#issuecomment-172988575 Will add to CHANGELOG On Tue, Jan 19, 2016 at 3:11 PM, P. Taylor Goetz wrote: > @jerrypeng

[jira] [Commented] (STORM-1485) DRPC Connectivity Issues

[ https://issues.apache.org/jira/browse/STORM-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107431#comment-15107431 ] ASF GitHub Bot commented on STORM-1485: --- GitHub user kishorvpatil opened a pull request:

[GitHub] storm pull request: [STORM-1485] DRPC Connectivity Issues

GitHub user kishorvpatil opened a pull request: https://github.com/apache/storm/pull/1027 [STORM-1485] DRPC Connectivity Issues - ZK-Login-From-AutoTGT thread should not die if TGT in `AutoTGT` has expired. ( It gives grace 10 minutes before killing worker.) This required copying

[jira] [Commented] (STORM-1450) Fix bugs and refactor code in ResourceAwareScheduler

[ https://issues.apache.org/jira/browse/STORM-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107440#comment-15107440 ] ASF GitHub Bot commented on STORM-1450: --- Github user ptgoetz commented on the pull request:

[GitHub] storm pull request: [STORM-1450] - Fix bugs and refactor code in R...

Github user ptgoetz commented on the pull request: https://github.com/apache/storm/pull/1016#issuecomment-172988140 @jerrypeng Can you add this to the CHANGELOG? --- 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

[GitHub] storm pull request: [STORM-1449] Fix Kafka spout to maintain backw...

Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/994#issuecomment-172976476 @priyank5485 you are correct. I didn't look into this in great detail until now. What is more if you submit using an old client you will get deserialization errors

[jira] [Commented] (STORM-1449) Fix Kafka spout to maintain backward compatibility to pass byte[] instead of ByteBuffer

[ https://issues.apache.org/jira/browse/STORM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107372#comment-15107372 ] ASF GitHub Bot commented on STORM-1449: --- Github user revans2 commented on the pull request:

[GitHub] storm pull request: [STORM-1485] DRPC Connectivity Issues

Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/1027#issuecomment-173014223 I just have the one minor comment about the name of the class that we pulled over from Zookeeper. +1 even with the name being a bit confusing to me. --- If

[jira] [Commented] (STORM-1485) DRPC Connectivity Issues

[ https://issues.apache.org/jira/browse/STORM-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107619#comment-15107619 ] ASF GitHub Bot commented on STORM-1485: --- Github user revans2 commented on a diff in the pull

[GitHub] storm pull request: [STORM-1485] DRPC Connectivity Issues

Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/1027#discussion_r50189054 --- Diff: storm-core/src/jvm/org/apache/storm/messaging/netty/KerberosSaslNettyClient.java --- @@ -84,7 +83,7 @@ public KerberosSaslNettyClient(Map

[jira] [Commented] (STORM-1450) Fix bugs and refactor code in ResourceAwareScheduler

[ https://issues.apache.org/jira/browse/STORM-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107444#comment-15107444 ] ASF GitHub Bot commented on STORM-1450: --- Github user jerrypeng commented on the pull request:

[jira] [Commented] (STORM-1485) DRPC Connectivity Issues

[ https://issues.apache.org/jira/browse/STORM-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107623#comment-15107623 ] ASF GitHub Bot commented on STORM-1485: --- Github user revans2 commented on the pull request:

[jira] [Commented] (STORM-1485) DRPC Connectivity Issues

[ https://issues.apache.org/jira/browse/STORM-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107486#comment-15107486 ] ASF GitHub Bot commented on STORM-1485: --- GitHub user kishorvpatil opened a pull request:

[GitHub] storm pull request: [STORM-1485] DRPC Connectivity Issues for 1.-x...

GitHub user kishorvpatil opened a pull request: https://github.com/apache/storm/pull/1028 [STORM-1485] DRPC Connectivity Issues for 1.-x-branch - ZK-Login-From-AutoTGT thread should not die if TGT in `AutoTGT` has expired. ( It gives grace 10 minutes before killing worker.) This

[GitHub] storm pull request: STORM-822 Implement Kafka 0.9 consumer API

Github user hmcl commented on the pull request: https://github.com/apache/storm/pull/986#issuecomment-172962722 @tgravescs I am actively working on this and I am going to conclude my implementation regardless of the status of the proposed patches. This task was and still is my

[jira] [Commented] (STORM-1336) Evalute/Port JStorm cgroup support

[ https://issues.apache.org/jira/browse/STORM-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107291#comment-15107291 ] Boyang Jerry Peng commented on STORM-1336: -- Hello Everyone, Currently at Yahoo, we want to

[jira] [Comment Edited] (STORM-1336) Evalute/Port JStorm cgroup support

[ https://issues.apache.org/jira/browse/STORM-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107291#comment-15107291 ] Boyang Jerry Peng edited comment on STORM-1336 at 1/19/16 7:50 PM: ---

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107244#comment-15107244 ] ASF GitHub Bot commented on STORM-822: -- Github user tgravescs commented on the pull request:

[GitHub] storm pull request: STORM-822 Implement Kafka 0.9 consumer API

Github user tgravescs commented on the pull request: https://github.com/apache/storm/pull/986#issuecomment-172958019 @hmcl just curious your status on this, are you actively working on it and do you have eta? thanks! --- If your project is set up for it, you can reply to this email

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107279#comment-15107279 ] ASF GitHub Bot commented on STORM-822: -- Github user hmcl commented on the pull request:

Re: JStorm CGroup

Hello Everyone, Currently at Yahoo, we want to enable the Resource Aware Scheduler we built to have cgroup support. The CGroup code that is part of JStorm looks good and perhaps we can modify it slightly so that the Resource Aware Scheduler can interact with it. What I would like to do is

[GitHub] storm pull request: [STORM-1485] DRPC Connectivity Issues

Github user kishorvpatil commented on the pull request: https://github.com/apache/storm/pull/1027#issuecomment-173018694 @revans2 I reverted the name to `Login`. --- 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

[jira] [Commented] (STORM-1449) Fix Kafka spout to maintain backward compatibility to pass byte[] instead of ByteBuffer

[ https://issues.apache.org/jira/browse/STORM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107694#comment-15107694 ] ASF GitHub Bot commented on STORM-1449: --- Github user Parth-Brahmbhatt commented on the pull request:

[jira] [Updated] (STORM-1480) Fix broken links & package name in the storm-sql documentations

[ https://issues.apache.org/jira/browse/STORM-1480?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Xin Wang updated STORM-1480: Summary: Fix broken links & package name in the storm-sql documentations (was: Fix broken links in the

[jira] [Commented] (STORM-1480) Fix broken links & package name in the storm-sql documentations

[ https://issues.apache.org/jira/browse/STORM-1480?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107821#comment-15107821 ] ASF GitHub Bot commented on STORM-1480: --- Github user vesense commented on the pull request:

[GitHub] storm pull request: [STORM-1480] Fix broken links & package name i...

Github user vesense commented on the pull request: https://github.com/apache/storm/pull/1022#issuecomment-173060058 Thanks @haohui Updated. --- 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

[GitHub] storm pull request: [STORM-1449] Fix Kafka spout to maintain backw...

Github user priyank5485 commented on the pull request: https://github.com/apache/storm/pull/994#issuecomment-173024682 @revans2 I am fine with the changes except one major concern pointed out by @Parth-Brahmbhatt I confirmed this with him and our main concern would be the rolling

[jira] [Commented] (STORM-1449) Fix Kafka spout to maintain backward compatibility to pass byte[] instead of ByteBuffer

[ https://issues.apache.org/jira/browse/STORM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107681#comment-15107681 ] ASF GitHub Bot commented on STORM-1449: --- Github user priyank5485 commented on the pull request:

[jira] [Commented] (STORM-1214) Trident API Improvements

[ https://issues.apache.org/jira/browse/STORM-1214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107907#comment-15107907 ] ASF GitHub Bot commented on STORM-1214: --- GitHub user ptgoetz opened a pull request:

[jira] [Commented] (STORM-1336) Evalute/Port JStorm cgroup support

[ https://issues.apache.org/jira/browse/STORM-1336?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107911#comment-15107911 ] Basti Liu commented on STORM-1336: -- [~jerrypeng] I think it is NOT difficult to integrate RSA into

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107726#comment-15107726 ] Erik Weathers commented on STORM-822: - [~DeepNekro]: can you please comment on whether your work

[GitHub] storm pull request: [STORM-1449] Fix Kafka spout to maintain backw...

Github user Parth-Brahmbhatt commented on the pull request: https://github.com/apache/storm/pull/994#issuecomment-173027654 We can either just include this as a warning as part of Release Notes or we can roll this change back. I am fine with including just a Release Note to warn all

[GitHub] storm pull request: STORM-1214: add javadoc for Trident Streams an...

GitHub user ptgoetz opened a pull request: https://github.com/apache/storm/pull/1029 STORM-1214: add javadoc for Trident Streams and Operations JIRA: https://issues.apache.org/jira/browse/STORM-1214 This is just a work in progress for STORM-1214, if this is merged, please

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107772#comment-15107772 ] ASF GitHub Bot commented on STORM-822: -- Github user erikdw commented on the pull request:

[GitHub] storm pull request: STORM-822 Implement Kafka 0.9 consumer API

Github user erikdw commented on the pull request: https://github.com/apache/storm/pull/986#issuecomment-173041086 @tgravescs, @hmcl, and @Deepnekroz : @hsun-cnnxty is also working on [a refactor of the kafka-spout, to support the new ZooKeeper-free kafka API]

[GitHub] storm pull request: [STORM-1449] Fix Kafka spout to maintain backw...

Github user arunmahadevan commented on the pull request: https://github.com/apache/storm/pull/994#issuecomment-173077993 @priyank5485 @revans2 @Parth-Brahmbhatt the changes introduced by STORM-1220 has not yet gone out in any releases. It will go out in 1.0 but with the fix in this

[jira] [Commented] (STORM-822) As a storm developer I’d like to use the new kafka consumer API (0.8.3) to reduce dependencies and use long term supported kafka apis

[ https://issues.apache.org/jira/browse/STORM-822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15108040#comment-15108040 ] ASF GitHub Bot commented on STORM-822: -- Github user hsun-cnnxty commented on the pull request:

[GitHub] storm pull request: STORM-822 Implement Kafka 0.9 consumer API

Github user hsun-cnnxty commented on the pull request: https://github.com/apache/storm/pull/986#issuecomment-173093649 I don't have much experience on how the collaborations be done in storm project. Happy to take any advices on what I can help. --- If your project is set up for

[jira] [Commented] (STORM-1449) Fix Kafka spout to maintain backward compatibility to pass byte[] instead of ByteBuffer

[ https://issues.apache.org/jira/browse/STORM-1449?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107941#comment-15107941 ] ASF GitHub Bot commented on STORM-1449: --- Github user arunmahadevan commented on the pull request:

[jira] [Updated] (STORM-1454) UI cannot handle topology names with spaces

[ https://issues.apache.org/jira/browse/STORM-1454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Matthias J. Sax updated STORM-1454: --- Affects Version/s: 0.9.3 > UI cannot handle topology names with spaces >

[jira] [Updated] (STORM-350) Update disruptor to latest version (3.3.2)

[ https://issues.apache.org/jira/browse/STORM-350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Joseph Evans updated STORM-350: -- Fix Version/s: (was: 0.10.0) 1.0.0 > Update disruptor to latest

Emitting to non-declared output stream

Hi, currently, I am using Storm 0.9.3. For first tests on a new topology, I use LocalCluster. It happened to me, that I emitted tuples to an output stream, that I did never declare (and thus not connect to). For this, I would expect an error message in the log. However, I don't get anything which

[GitHub] storm pull request: [STORM-1481] avoid Math.abs(Integer) get a neg...

Github user revans2 commented on the pull request: https://github.com/apache/storm/pull/1023#issuecomment-172883855 OK so Math.abs(Integer.MIN_VALUE) actually returns Integer.MIN_VALUE because of an integer overflow error. That is a good corner case to remember in the future.

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

[ https://issues.apache.org/jira/browse/STORM-834?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106809#comment-15106809 ] Robert Joseph Evans commented on STORM-834: --- [~longtimer], You could put in a check like that

Re: [DISCUSSION] Diverge between master and 1.x-branch

The 1.x branch is supposed to be for stabilizing a 1.x release, while master (2.x) diverges with the JStorm merger.  I thought it would be best to keep 1.x open temporarily to back-port features, as there were several that were close to going in, but didn't quite make it, and because there was

[jira] [Commented] (STORM-350) Update disruptor to latest version (3.3.2)

[ https://issues.apache.org/jira/browse/STORM-350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106793#comment-15106793 ] Robert Joseph Evans commented on STORM-350: --- [~paul.calla...@gmail.com], You are correct. I am

Re: Emitting to non-declared output stream

I think this is something that we should be able to handle efficiently in all cases. https://github.com/apache/storm/blob/master/storm-core/src/clj/org/apache/storm/daemon/task.clj#L120-L167 creates the task function that is used for routing tuples to the correct downstream component.  Not

[GitHub] storm pull request: STORM-1455: Do not reset the emittedOffset for...

GitHub user abhishekagarwal87 opened a pull request: https://github.com/apache/storm/pull/1026 STORM-1455: Do not reset the emittedOffset for offsetOutOfRangeExceptions There are two changes in this PR - If there is a TopicOffsetOutOfRangeException, it can be due to an old

[jira] [Commented] (STORM-1455) kafka spout should not reset to the beginning of partition when offsetoutofrange exception occurs

[ https://issues.apache.org/jira/browse/STORM-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106930#comment-15106930 ] ASF GitHub Bot commented on STORM-1455: --- GitHub user abhishekagarwal87 opened a pull request:

[jira] [Commented] (STORM-1455) kafka spout should not reset to the beginning of partition when offsetoutofrange exception occurs

[ https://issues.apache.org/jira/browse/STORM-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106931#comment-15106931 ] ASF GitHub Bot commented on STORM-1455: --- Github user abhishekagarwal87 commented on the pull

[GitHub] storm pull request: STORM-1455: Do not reset the emittedOffset for...

Github user abhishekagarwal87 commented on the pull request: https://github.com/apache/storm/pull/1026#issuecomment-172904085 @HeartSaVioR @revans2 can you review these changes? --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub

[jira] [Commented] (STORM-1485) DRPC Connectivity Issues

[ https://issues.apache.org/jira/browse/STORM-1485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15107654#comment-15107654 ] ASF GitHub Bot commented on STORM-1485: --- Github user kishorvpatil commented on the pull request:

[jira] [Commented] (STORM-1450) Fix bugs and refactor code in ResourceAwareScheduler

[ https://issues.apache.org/jira/browse/STORM-1450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15106997#comment-15106997 ] ASF GitHub Bot commented on STORM-1450: --- Github user asfgit closed the pull request at:

[GitHub] storm pull request: [STORM-1450] - Fix bugs and refactor code in R...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1016 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is