[GitHub] storm issue #1507: STORM-1916: Add ability for worker-first classpath

Github user abhishekagarwal87 commented on the issue: https://github.com/apache/storm/pull/1507 Let's make sure that we squash the commits before merging. --- 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

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

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

[GitHub] storm issue #1536: Storm 1890 ensure we refetch static resources after packa...

Github user abellina commented on the issue: https://github.com/apache/storm/pull/1536 ping --- 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

default configuration new releases

Hi all, In the previous releases of storm, I see that default configuration file is called defaults.yaml. For new release, like Storm 1.0.1, Anyone can help where can look for default configuration as defaults.yaml, rather than storm.yaml? Thank you --Regards  WA

Question about Nimbus Summary- UI

Hi all, I am running topology over production cluster of two nodes: one as Nimbus and ZkServer, the other one as supervisor. Everything is running fine, but I got confused: Why are there two hosts in UI's Nuimbus summary: one is listed as IP address and its status offline, the other one is by

[jira] [Commented] (STORM-1960) Add CORS support to STORM UI Rest api

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

[GitHub] storm issue #1552: STORM-1960. Add CORS support to STORM UI Rest api.

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1552 Same as @arunmahadevan. I'm wondering that we need to open detailed configurations for these, but we can add it later when someone claims he/she needs that. --- If your project is set up for

Fwd: How to use KafkaSpout to consume kafka cluster secured with kerberos

Hi Team, How to use KafkaSpout to consume kafka cluster secured with kerberos? I can't find lots of accurate information about the API. The versions I am using are: - storm: 0.9.3 - storm-kafka: 0.10.0 Thanks, -- Hao

[jira] [Resolved] (STORM-1954) Large Trident topologies can cause memory issues due to DefaultResourceDeclarer object reading config

[ https://issues.apache.org/jira/browse/STORM-1954?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum resolved STORM-1954. - Resolution: Fixed Fix Version/s: 2.0.0 > Large Trident topologies can cause memory issues

[jira] [Resolved] (STORM-1916) Add ability for worker-first classpath

[ https://issues.apache.org/jira/browse/STORM-1916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum resolved STORM-1916. - Resolution: Fixed Fix Version/s: 2.0.0 > Add ability for worker-first classpath >

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

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

[GitHub] storm pull request #1507: STORM-1916: Add ability for worker-first classpath

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1507 --- 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-1916) Add ability for worker-first classpath

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

[GitHub] storm issue #1507: STORM-1916: Add ability for worker-first classpath

Github user d2r commented on the issue: https://github.com/apache/storm/pull/1507 +1 after we fix the javadoc. --- 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

[jira] [Commented] (STORM-1674) Idle KafkaSpout consumes more bandwidth than needed

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

[jira] [Commented] (STORM-1674) Idle KafkaSpout consumes more bandwidth than needed

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

[jira] [Commented] (STORM-1954) Large Trident topologies can cause memory issues due to DefaultResourceDeclarer object reading config

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

[GitHub] storm pull request #1287: STORM-1674: Addresses network flood from KafkaSpou...

Github user moesol closed the pull request at: https://github.com/apache/storm/pull/1287 --- 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

[GitHub] storm pull request #1547: STORM-1954: Large Trident topologies can cause mem...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1547 --- 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

[GitHub] storm issue #1287: STORM-1674: Addresses network flood from KafkaSpout to ka...

Github user moesol commented on the issue: https://github.com/apache/storm/pull/1287 Merged via different PR. Closing this PR. --- 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-1916) Add ability for worker-first classpath

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

[GitHub] storm pull request #1507: STORM-1916: Add ability for worker-first classpath

Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/1507#discussion_r70338254 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1835,6 +1835,21 @@ public static final String TOPOLOGY_CLASSPATH="topology.classpath";

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

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

[GitHub] storm pull request #1507: STORM-1916: Add ability for worker-first classpath

Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/1507#discussion_r70338370 --- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java --- @@ -2092,6 +2092,11 @@ public static String addToClasspath(String classpath,

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

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

[GitHub] storm pull request #1507: STORM-1916: Add ability for worker-first classpath

Github user d2r commented on a diff in the pull request: https://github.com/apache/storm/pull/1507#discussion_r70338269 --- Diff: storm-core/src/jvm/org/apache/storm/Config.java --- @@ -1835,6 +1835,21 @@ public static final String TOPOLOGY_CLASSPATH="topology.classpath";

[GitHub] storm pull request #1554: adjusted Flux documentation to show new flux-wrapp...

GitHub user slava92 opened a pull request: https://github.com/apache/storm/pull/1554 adjusted Flux documentation to show new flux-wrapper library Two Flux-related documents are outdated. This PR introduces new flux-wrappers library and fixes class names of `GenericShellSpout` and

[jira] [Resolved] (STORM-1913) Additions and Improvements for Trident RAS API

[ https://issues.apache.org/jira/browse/STORM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum resolved STORM-1913. - Resolution: Fixed > Additions and Improvements for Trident RAS API >

[jira] [Updated] (STORM-1913) Additions and Improvements for Trident RAS API

[ https://issues.apache.org/jira/browse/STORM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum updated STORM-1913: Fix Version/s: 2.0.0 > Additions and Improvements for Trident RAS API >

[jira] [Closed] (STORM-1913) Additions and Improvements for Trident RAS API

[ https://issues.apache.org/jira/browse/STORM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum closed STORM-1913. --- Resolution: Fixed > Additions and Improvements for Trident RAS API >

[jira] [Reopened] (STORM-1913) Additions and Improvements for Trident RAS API

[ https://issues.apache.org/jira/browse/STORM-1913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Kyle Nusbaum reopened STORM-1913: - > Additions and Improvements for Trident RAS API > -- > >

[jira] [Commented] (STORM-1962) python storm integration does not run on python 3

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

[GitHub] storm pull request #1553: STORM-1962: support python 3 and 2 in multilang

GitHub user revans2 opened a pull request: https://github.com/apache/storm/pull/1553 STORM-1962: support python 3 and 2 in multilang You can merge this pull request into a Git repository by running: $ git pull https://github.com/revans2/incubator-storm STORM-1962

[jira] [Commented] (STORM-1960) Add CORS support to STORM UI Rest api

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

[jira] [Commented] (STORM-1916) Add ability for worker-first classpath

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

[GitHub] storm issue #1507: STORM-1916: Add ability for worker-first classpath

Github user knusbaum commented on the issue: https://github.com/apache/storm/pull/1507 @d2r Sorry about missing that. Ready for a check. --- 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

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

[ https://issues.apache.org/jira/browse/STORM-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371323#comment-15371323 ] Hugo Louro commented on STORM-1737: --- [~kabhwan] as of release 0.10.0 the @InterfaceStability.Unstable

[jira] [Commented] (STORM-1876) Provide option to build storm-kafka against different kafka clients

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

[GitHub] storm issue #1482: STORM-1876: Option to build storm-kafka and storm-kafka-c...

Github user ptgoetz commented on the issue: https://github.com/apache/storm/pull/1482 The README needs to be updated for this change with instructions on how to use different Kafka client and scala versions. I'm okay with either leaving or removing the `provided` scope for

[GitHub] storm pull request #1552: STORM-1960. Add CORS support to STORM UI Rest api.

GitHub user harshach opened a pull request: https://github.com/apache/storm/pull/1552 STORM-1960. Add CORS support to STORM UI Rest api. You can merge this pull request into a Git repository by running: $ git pull https://github.com/harshach/incubator-storm STORM-1960

[jira] [Commented] (STORM-1960) Add CORS support to STORM UI Rest api

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

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371086#comment-15371086 ] Sriharsha Chintalapani commented on STORM-1949: --- [~knusbaum] another issue that we've seen

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371055#comment-15371055 ] Abhishek Agarwal commented on STORM-1949: - ok. my understanding was that spout will continue

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

[ https://issues.apache.org/jira/browse/STORM-1959?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Joseph Evans closed STORM-1959. -- Resolution: Fixed Fix Version/s: 1.1.0 2.0.0 Thanks

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

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

[GitHub] storm pull request #1551: STORM-1959 Add missing license header to KafkaPart...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1551 --- 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

[GitHub] storm issue #1551: STORM-1959 Add missing license header to KafkaPartitionOf...

Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1551 Travis passed this is just a comment/documentation change, not a code change so I will push this in without waiting 24 hours. --- If your project is set up for it, you can reply to this email and

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

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

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371017#comment-15371017 ] Kyle Nusbaum commented on STORM-1949: - I'm okay with polling ZK for changes as a fix (for now) so we

[jira] [Commented] (STORM-1096) UI tries to impersonate wrong user when getting topology conf for authorization, impersonation is allowed by default

[ https://issues.apache.org/jira/browse/STORM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371011#comment-15371011 ] Sriharsha Chintalapani commented on STORM-1096: --- [~revans2] not sure if we are talking about

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15371002#comment-15371002 ] Sriharsha Chintalapani commented on STORM-1949: --- [~abhishek.agarwal] we don't have

[jira] [Commented] (STORM-1096) UI tries to impersonate wrong user when getting topology conf for authorization, impersonation is allowed by default

[ https://issues.apache.org/jira/browse/STORM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370999#comment-15370999 ] Robert Joseph Evans commented on STORM-1096: [~harsha_ch], Then it sounds like we are trying

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370998#comment-15370998 ] Abhishek Agarwal commented on STORM-1949: - [~sriharsha] We can disable the back-pressure. But I

[jira] [Created] (STORM-1960) Add CORS support to STORM UI Rest api

Sriharsha Chintalapani created STORM-1960: - Summary: Add CORS support to STORM UI Rest api Key: STORM-1960 URL: https://issues.apache.org/jira/browse/STORM-1960 Project: Apache Storm

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

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

[GitHub] storm issue #1551: STORM-1959 Add missing license header to KafkaPartitionOf...

Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1551 +1 pending travis --- 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

[jira] [Commented] (STORM-1876) Provide option to build storm-kafka against different kafka clients

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

[GitHub] storm issue #1482: STORM-1876: Option to build storm-kafka and storm-kafka-c...

Github user abhishekagarwal87 commented on the issue: https://github.com/apache/storm/pull/1482 @harshach @hmcl - can you guys take a look? --- 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

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

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

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

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

[GitHub] storm pull request #1551: STORM-1959 Add missing license header to KafkaPart...

GitHub user HeartSaVioR opened a pull request: https://github.com/apache/storm/pull/1551 STORM-1959 Add missing license header to KafkaPartitionOffsetLag This is just an addition of missing license header (not code change), so I think it can be merged without waiting one day rule.

Re: Can't Run Topology in Production Cluster

Hi, Supervisors have already connected with zookeeper, that is in the same machine with nimbus. Thanks From: Abhishek Agarwal To: u...@storm.apache.org; Walid Aljoby Cc: "dev@storm.apache.org" Sent: Monday, July 11,

Re: Can't Run Topology in Production Cluster

It looks like supervisor is not able to connect to nimbus server. You should check the connectivity from supervisor to nimbus On Mon, Jul 11, 2016 at 5:09 PM, Walid Aljoby wrote: > > >

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370955#comment-15370955 ] Sriharsha Chintalapani commented on STORM-1949: --- [~abhishek.agarwal] [~kabhwan] As we can

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

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

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

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

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370949#comment-15370949 ] Abhishek Agarwal commented on STORM-1949: - I have the same concern as Jungtake with disabling

[jira] [Commented] (STORM-1096) UI tries to impersonate wrong user when getting topology conf for authorization, impersonation is allowed by default

[ https://issues.apache.org/jira/browse/STORM-1096?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370946#comment-15370946 ] Sriharsha Chintalapani commented on STORM-1096: --- [~revans2] Agree. It looks confusing and

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

[ https://issues.apache.org/jira/browse/STORM-1950?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370924#comment-15370924 ] Robert Joseph Evans commented on STORM-1950: [~sriharsha] and [~kabhwan], Could you please

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

Robert Joseph Evans created STORM-1959: -- Summary: KafkaPartitionOffsetLag.java does not have license Key: STORM-1959 URL: https://issues.apache.org/jira/browse/STORM-1959 Project: Apache Storm

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

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

[GitHub] storm issue #1526: STORM-1928 ShellSpout should check heartbeat while ShellS...

Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1526 The file without a license is external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaPartitionOffsetLag.java I'll file a separate JIRA for that. --- If your project

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

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

[GitHub] storm issue #1526: STORM-1928 ShellSpout should check heartbeat while ShellS...

Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1526 +1 but all 4 CI jobs failed. They look unrelated to this, as some of them are failing because of a RAT problem. Lets fix the build ASAP before we merge in much more. --- If your project is set

[jira] [Closed] (STORM-1943) Support loading properties from a file

[ https://issues.apache.org/jira/browse/STORM-1943?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet closed STORM-1943. Resolution: Not A Problem > Support loading properties from a file >

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

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

[GitHub] storm pull request #1526: STORM-1928 ShellSpout should check heartbeat while...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1526#discussion_r70263885 --- Diff: storm-core/src/jvm/org/apache/storm/spout/ShellSpout.java --- @@ -47,6 +50,8 @@ private String[] _command; private Map

[jira] [Reopened] (STORM-1957) Support Storm JDBC batch insert

[ https://issues.apache.org/jira/browse/STORM-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet reopened STORM-1957: -- > Support Storm JDBC batch insert > --- > > Key:

[jira] [Commented] (STORM-1957) Support Storm JDBC batch insert

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

[GitHub] storm pull request #1550: [STORM-1957] Support Storm JDBC batch insert

GitHub user darionyaphet opened a pull request: https://github.com/apache/storm/pull/1550 [STORM-1957] Support Storm JDBC batch insert [STORM-1957 Support Storm JDBC batch insert](https://issues.apache.org/jira/browse/STORM-1957?jql=project%20%3D%20STORM) Batch insert

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

[ https://issues.apache.org/jira/browse/STORM-1949?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370729#comment-15370729 ] Robert Joseph Evans commented on STORM-1949: I am not sure that we can use our internal

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

[ https://issues.apache.org/jira/browse/STORM-1952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15370716#comment-15370716 ] Robert Joseph Evans commented on STORM-1952: There are two situations here. 1) The topology

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

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

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

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

[GitHub] storm issue #1526: STORM-1928 ShellSpout should check heartbeat while ShellS...

Github user revans2 commented on the issue: https://github.com/apache/storm/pull/1526 one minor nit, but overall I am +1 with or without the 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

Can't Run Topology in Production Cluster

| | Hi all, Please see that, I have a topology that runs well on a Local cluster.But when I try to run it on a production cluster the following things happens: - The nimbus is up - The storm UI is up - The two workers I use are up - Zookeper is up - I run storm withstorm

[jira] [Created] (STORM-1958) storm-config.cmd doesn't handle spaces in JAVA_HOME

Paul Milliken created STORM-1958: Summary: storm-config.cmd doesn't handle spaces in JAVA_HOME Key: STORM-1958 URL: https://issues.apache.org/jira/browse/STORM-1958 Project: Apache Storm

[GitHub] storm pull request #1445: [STORM-1277] port backtype.storm.daemon.executor t...

Github user unsleepy22 commented on a diff in the pull request: https://github.com/apache/storm/pull/1445#discussion_r70237264 --- Diff: storm-core/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java --- @@ -0,0 +1,155 @@ +/** + * Licensed to the Apache

[jira] [Commented] (STORM-1277) port backtype.storm.daemon.executor to java

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

[jira] [Commented] (STORM-1277) port backtype.storm.daemon.executor to java

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

[GitHub] storm pull request #1445: [STORM-1277] port backtype.storm.daemon.executor t...

Github user lujinhong commented on a diff in the pull request: https://github.com/apache/storm/pull/1445#discussion_r70235783 --- Diff: storm-core/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java --- @@ -0,0 +1,155 @@ +/** + * Licensed to the Apache

[jira] [Commented] (STORM-1239) port backtype.storm.scheduler.IsolationScheduler to java

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

[GitHub] storm pull request #1359: STORM-1239: port backtype.storm.scheduler.Isolatio...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1359#discussion_r70231398 --- Diff: storm-core/src/jvm/org/apache/storm/scheduler/IsolationScheduler.java --- @@ -0,0 +1,417 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request #1359: STORM-1239: port backtype.storm.scheduler.Isolatio...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1359#discussion_r70230499 --- Diff: storm-core/src/jvm/org/apache/storm/scheduler/IsolationScheduler.java --- @@ -0,0 +1,417 @@ +/** + * Licensed to the Apache Software

[GitHub] storm pull request #1359: STORM-1239: port backtype.storm.scheduler.Isolatio...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1359#discussion_r70228042 --- Diff: storm-core/src/jvm/org/apache/storm/scheduler/IsolationScheduler.java --- @@ -0,0 +1,417 @@ +/** + * Licensed to the Apache Software

[jira] [Commented] (STORM-1239) port backtype.storm.scheduler.IsolationScheduler to java

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

[jira] [Commented] (STORM-1883) FileReader extends Closeable Interface

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

[GitHub] storm pull request #1462: [STORM-1883] FileReader extends Closeable Interfac...

Github user darionyaphet commented on a diff in the pull request: https://github.com/apache/storm/pull/1462#discussion_r70212495 --- Diff: external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileReader.java --- @@ -20,10 +20,11 @@ import

[GitHub] storm issue #1526: STORM-1928 ShellSpout should check heartbeat while ShellS...

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1526 Could anyone review this? This is critical issue on multilang spout. --- 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-1928) ShellSpout should check heartbeat while ShellSpout is waiting for subprocess to sync

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

  1   2   >