Re: [DISCUSS] Release Storm 1.1.0

Apache Zeppelin provides 700 MB of full set and 272 MB of netinst via Apache download page so there should be ways to do it, but for me 200MB is already too huge. I have been wondering why we package external connectors, which other projects don't. When we didn't make uber jar for connectors

[GitHub] storm issue #1831: STORM-2249: Make Distribution Scripts Put Examples to the...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1831 Also could you check how big binary dist (tar.gz / zip) will be? It's already over 200MB so IMHO it would be better to reduce/restrict the size of binary dist. --- If your project is set up

[GitHub] storm issue #1939: STORM-1363: TridentKafkaState should handle null values f...

Github user pasalkarsachin1 commented on the issue: https://github.com/apache/storm/pull/1939 Can someone take a look at 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 feature

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101696141 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -722,19 +703,10 @@ private FileReader

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101697143 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -105,87 +105,87 @@ private String configKey

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101696530 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -409,9 +409,14 @@ public void open(Map conf,

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user pasalkarsachin1 commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101698425 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -722,19 +703,10 @@ private FileReader

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user pasalkarsachin1 commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101698420 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -409,9 +409,14 @@ public void open(Map conf,

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user pasalkarsachin1 commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101699216 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -105,87 +105,87 @@ private String

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user arunmahadevan commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101698782 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -722,19 +703,10 @@ private FileReader

[GitHub] storm issue #1924: STORM-2343: New Kafka spout can stop emitting tuples if m...

Github user srdo commented on the issue: https://github.com/apache/storm/pull/1924 @hmcl I think this is ready for another look when you get a chance. --- 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

[GitHub] storm issue #1938: STORM-2360: Storm-Hive: Thrift version mismatch with stor...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1938 +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

[GitHub] storm issue #1939: STORM-1363: TridentKafkaState should handle null values f...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1939 @pasalkarsachin1 We don't use 8 spaces for indentation from other java files. If the indentation spaces was 4, it should be 4 unless we set brand new style guide. Code style is important as

[GitHub] storm issue #1944: [STORM-2365] Support for specifying output stream in even...

Github user satishd commented on the issue: https://github.com/apache/storm/pull/1944 +1 LGTM --- 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

[GitHub] storm pull request #1944: [STORM-2365] Support for specifying output stream ...

GitHub user arunmahadevan opened a pull request: https://github.com/apache/storm/pull/1944 [STORM-2365] Support for specifying output stream in event hubs spout You can merge this pull request into a Git repository by running: $ git pull https://github.com/arunmahadevan/storm

[GitHub] storm issue #1924: STORM-2343: New Kafka spout can stop emitting tuples if m...

Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1924 @srdo Thanks for the note. I will take a look later today. --- 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

storm stops recieving events suddenly

Hi, We are facing problem in apache storm frequently after few hours of continuous message receive. we are using architecture like Kafka---> storm --> solr. Storm continuously received message from Kafka but after 1 day of continuousness receiving message storm suddenly stops

[GitHub] storm issue #1939: STORM-1363: TridentKafkaState should handle null values f...

Github user pasalkarsachin1 commented on the issue: https://github.com/apache/storm/pull/1939 @HeartSaVioR I did my best. Can you take a look at it now --- 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

Re: [DISCUSS] Release Storm 1.1.0

Now all issues on the Storm 1.1.0 epic got resolved. :) There're still some bugfix pull requests for storm-kafka-client, but releasing Storm 1.1.0 has been tremendously dragged (I initiated this at Sep. 2016) so unless they're critical, I'm +1 on starting release phase on Storm 1.1.0 ASAP. -

[GitHub] storm issue #1939: STORM-1363: TridentKafkaState should handle null values f...

Github user pasalkarsachin1 commented on the issue: https://github.com/apache/storm/pull/1939 @HeartSaVioR Done --- 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

[GitHub] storm issue #1939: STORM-1363: TridentKafkaState should handle null values f...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1939 @pasalkarsachin1 Indentation is still off. Could you please check the diff on PR? https://github.com/apache/storm/pull/1939/files --- If your project is set up for it, you can reply to

[GitHub] storm issue #1944: [STORM-2365] Support for specifying output stream in even...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1944 +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

Re: Cassandra spout

For me, I'm OK to adopt the Spout implementation if it can be used for general purpose, and also can meet at-least-once semantic. I didn't add Redis spout (using pubsub or list) because it can't meet at-least-once semantic. Do you have any sketches or design doc for Cassandra spout? Thanks,

Re: Cassandra spout

There is a JIRA filed for this: https://issues.apache.org/jira/browse/STORM-2362 SG, can you please add any requirements that you may have in mind to the JIRA. Thanks, Hugo On Feb 16, 2017, at 8:48 AM, Jungtaek Lim > wrote: For me, I'm OK to adopt

Re: storm stops recieving events suddenly

Hi Ganesh, You can try enabling http://storm.apache.org/releases/1.0.0/Eventlogging.html if you are using 1.x version of storm. You can also try using http://storm.apache.org/releases/1.0.0/dynamic-log-level-settings.html to debug the solr-bolt -SG On Thu, Feb 16, 2017 at 1:22 AM, Ganesh Kumar

Re: [DISCUSS] Release Storm 1.1.0

I have a release candidate for 1.1.0 built, but I can’t stage the convenience binaries because they are now over the ASF subversion size limit of 200MB. I’ll work with infra to figure out a solution. -Taylor > On Feb 16, 2017, at 9:46 AM, Jungtaek Lim wrote: > > Now all

[GitHub] storm pull request #1942: STORM-2358: Update storm hdfs spout to remove spec...

Github user pasalkarsachin1 commented on a diff in the pull request: https://github.com/apache/storm/pull/1942#discussion_r101702796 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HDFSSpout.java --- @@ -105,87 +105,87 @@ private String