[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm pull request #1514: STORM-1925 Remove Nimbus thrift call from Nimbus i...

Github user asfgit closed the pull request at: https://github.com/apache/storm/pull/1514 --- 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 #1436: add hadoop-common dependency in README for storm-hdfs

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1436 I'm not clearly saying that it is, but hadoop-auth is added at pom.xml now and it also refers to same version so version of hadoop-auth also should be changed when users want to exclude and

[GitHub] storm issue #1436: add hadoop-common dependency in README for storm-hdfs

Github user mazhechao commented on the issue: https://github.com/apache/storm/pull/1436 @HeartSaVioR Is hadoop-auth necessary? --- 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-1929) Check when create topology

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

[GitHub] storm pull request #1515: [STORM-1929] Check when create topology

Github user darionyaphet commented on a diff in the pull request: https://github.com/apache/storm/pull/1515#discussion_r68347350 --- Diff: storm-core/src/jvm/org/apache/storm/topology/TopologyBuilder.java --- @@ -113,6 +113,15 @@ public StormTopology createTopology() {

[GitHub] storm issue #1474: support for wildcard topics ( storm-kafka-client )

Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1474 @nabhanelrahman your patch enlightened that it would be better to add the `emit` and `getOutputFields` methods to `KafkaSpoutStream`. Furthermore, there were a couple of design decisions that would be

[jira] [Commented] (STORM-1930) Kafka New Client API - Support for Topic Wildcards

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

[GitHub] storm issue #1516: STORM-1930: Kafka New Client API - Support for Topic Wild...

Github user hmcl commented on the issue: https://github.com/apache/storm/pull/1516 @harshach Should this patch be merged onto 1.x-branch as well. Thanks. --- 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-1930) Kafka New Client API - Support for Topic Wildcards

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

[GitHub] storm pull request #1516: STORM-1930: Kafka New Client API - Support for Top...

GitHub user hmcl opened a pull request: https://github.com/apache/storm/pull/1516 STORM-1930: Kafka New Client API - Support for Topic Wildcards - Interfaces for TuplesBuilder and KafkaSpoutStreams and implementations for named topics and wildcards - Test topologies for named

[jira] [Updated] (STORM-1930) Kafka New Client API - Support for Topic Wildcards

[ https://issues.apache.org/jira/browse/STORM-1930?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hugo Louro updated STORM-1930: -- Summary: Kafka New Client API - Support for Topic Wildcards (was: Kafka New Client API Support for

[jira] [Created] (STORM-1930) Kafka New Client API Support for Topic Wildcards

Hugo Louro created STORM-1930: - Summary: Kafka New Client API Support for Topic Wildcards Key: STORM-1930 URL: https://issues.apache.org/jira/browse/STORM-1930 Project: Apache Storm Issue Type:

[jira] [Commented] (STORM-1885) python script for squashing and merging prs

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

[GitHub] storm issue #1468: STORM-1885. python script for squashing and merging prs.

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1468 We may have to modify lots of part of script since... - We don't have develop branch so all about develop branch should be modified. Spark merge script also doesn't have handling with

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

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1512 +1 once my comments are addressed. --- 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 #1512: Adding hdfs-conf.yaml to all test cases to support...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1512#discussion_r68336175 --- Diff: external/storm-hdfs/src/test/java/org/apache/storm/hdfs/trident/TridentSequenceTopology.java --- @@ -73,14 +75,20 @@ public static

[GitHub] storm pull request #1512: Adding hdfs-conf.yaml to all test cases to support...

Github user HeartSaVioR commented on a diff in the pull request: https://github.com/apache/storm/pull/1512#discussion_r68336156 --- Diff: external/storm-hdfs/src/test/java/org/apache/storm/hdfs/trident/TridentFileTopology.java --- @@ -75,14 +78,20 @@ public static StormTopology

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm issue #1513: STORM-1925 Remove Nimbus thrift call from Nimbus itself

Github user harshach commented on the issue: https://github.com/apache/storm/pull/1513 +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 pull request #1515: [STORM-1929] Check when create topology

Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/1515#discussion_r68280266 --- Diff: storm-core/src/jvm/org/apache/storm/topology/TopologyBuilder.java --- @@ -339,8 +353,13 @@ public SpoutDeclarer setSpout(String id, IRichSpout

[jira] [Commented] (STORM-1929) Check when create topology

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

[jira] [Commented] (STORM-1929) Check when create topology

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

[GitHub] storm pull request #1515: [STORM-1929] Check when create topology

Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/1515#discussion_r68280207 --- Diff: storm-core/src/jvm/org/apache/storm/topology/TopologyBuilder.java --- @@ -179,8 +188,13 @@ public BoltDeclarer setBolt(String id, IRichBolt bolt)

[jira] [Commented] (STORM-1929) Check when create topology

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

[GitHub] storm pull request #1515: [STORM-1929] Check when create topology

Github user revans2 commented on a diff in the pull request: https://github.com/apache/storm/pull/1515#discussion_r68279943 --- Diff: storm-core/src/jvm/org/apache/storm/topology/TopologyBuilder.java --- @@ -113,6 +113,15 @@ public StormTopology createTopology() {

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68263894 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -203,12 +237,14 @@ public void commit() {

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68263881 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -184,15 +216,17 @@ public void commit(long txid) {

[jira] [Commented] (STORM-1929) Check when create topology

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

[GitHub] storm pull request #1515: [STORM-1929] Check when create topology

GitHub user darionyaphet opened a pull request: https://github.com/apache/storm/pull/1515 [STORM-1929] Check when create topology [STORM-1929](https://issues.apache.org/jira/browse/STORM-1929) Add some check when create topology : 1. Spout and Bolt id shouldn't

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68261133 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -77,7 +81,8 @@ public RedisKeyValueState(String

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68260812 --- Diff: storm-core/src/jvm/org/apache/storm/state/KeyValueState.java --- @@ -45,4 +45,11 @@ * @return the value or defaultValue if no mapping is

[jira] [Commented] (STORM-1886) Extend KeyValueState interface with delete method

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

[jira] [Created] (STORM-1929) Check when create topology

darion yaphet created STORM-1929: Summary: Check when create topology Key: STORM-1929 URL: https://issues.apache.org/jira/browse/STORM-1929 Project: Apache Storm Issue Type: Improvement

[GitHub] storm pull request #1470: STORM-1886 Extend KeyValueState iface with delete

Github user kosii commented on a diff in the pull request: https://github.com/apache/storm/pull/1470#discussion_r68260007 --- Diff: external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java --- @@ -163,15 +190,20 @@ public void prepareCommit(long

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

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

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm issue #1514: STORM-1925 Remove Nimbus thrift call from Nimbus itself (...

Github user harshach commented on the issue: https://github.com/apache/storm/pull/1514 +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: Will storm 2.0 be completely rewritten in java?

The plan is to have the clojure API moved to the storm-clojure package and storm-core will no longer depend on clojure.  - Bobby On Thursday, June 23, 2016 10:02 AM, Junguk Cho wrote: Hi, Just to be clear,  since  it is in the ongoing process to replace clojure

Re: Will storm 2.0 be completely rewritten in java?

Hi, Just to be clear, since it is in the ongoing process to replace clojure codes with java codes, I still can see storm-core/clj/ directory in this git (https://github.com/apache/storm). However, when you release storm 2.0 stable version, files in storm-core/clj/ will be removed. Is it

[jira] [Commented] (STORM-1770) Pluggable status storage in storm-Kafka

[ https://issues.apache.org/jira/browse/STORM-1770?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346553#comment-15346553 ] darion yaphet commented on STORM-1770: -- HI [~abhishek.agarwal] I found a lot Spout (not only

[jira] [Commented] (STORM-1928) ShellSpout should send heartbeat tuple while nextTuple() is not called

[ https://issues.apache.org/jira/browse/STORM-1928?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346550#comment-15346550 ] Jungtaek Lim commented on STORM-1928: - ShellSpout should be changed to alike ShellBolt, I mean having

[jira] [Created] (STORM-1928) ShellSpout should send heartbeat tuple while nextTuple() is not called

Jungtaek Lim created STORM-1928: --- Summary: ShellSpout should send heartbeat tuple while nextTuple() is not called Key: STORM-1928 URL: https://issues.apache.org/jira/browse/STORM-1928 Project: Apache

Re: Storm UI local eclipse mode

Not that I know of, but better dev tool integration would be a great thing to have On Wednesday, June 22, 2016 6:22 PM, Arjun Rao wrote: This might be a question answered before, but is there a way (or maybe an open ticket)  to see the Storm UI while running

Re: Can storm pin executor threads to CPU cores?

There is only one thread associated with an input queue and that is the one the executor runs on. The output queue has a separate thread that all it does is pop messages off of the output queue and routes them to where they need to be.  In my experience this runs fairly infrequently.  I would

[jira] [Closed] (STORM-1926) Upgrade Jetty and Ring

[ https://issues.apache.org/jira/browse/STORM-1926?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] darion yaphet closed STORM-1926. Resolution: Won't Fix > Upgrade Jetty and Ring > -- > > Key:

[jira] [Created] (STORM-1927) Upgrade Jetty and Ring

darion yaphet created STORM-1927: Summary: Upgrade Jetty and Ring Key: STORM-1927 URL: https://issues.apache.org/jira/browse/STORM-1927 Project: Apache Storm Issue Type: Improvement

Re: Storm UI

Hi Jacob,  Supervisor node is running, however, it still could not display topology summary, number of tasks and executors are not displayed. Is it required to write any code in order for submitted topology to appear in storm UI? Thank you--Regards WA From: Jacob Johansen

Storm UI

Hi all, I have submitted ExclamationTopology into single-node cluster Storm 1.0.1, as following: storm jar target/storm-starter-*.jar org.apache.storm.starter.ExclamationTopology I have three basic questions:1- In sotrm UI, http://localhost:8080/index.html , the running topology and the number

[jira] [Created] (STORM-1926) Upgrade Jetty and Ring

darion yaphet created STORM-1926: Summary: Upgrade Jetty and Ring Key: STORM-1926 URL: https://issues.apache.org/jira/browse/STORM-1926 Project: Apache Storm Issue Type: Bug

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm issue #1513: STORM-1925 Remove Nimbus thrift call from Nimbus itself

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1513 Confirmed that before patch Nimbus has crashed in kerberized environment, and this patch fixes that issue. --- If your project is set up for it, you can reply to this email and have your reply

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm pull request #1514: STORM-1925 Remove Nimbus thrift call from Nimbus i...

GitHub user HeartSaVioR opened a pull request: https://github.com/apache/storm/pull/1514 STORM-1925 Remove Nimbus thrift call from Nimbus itself (1.x) * Nimbus fails to start in secure mode since authrization is not passed * Extract the logic of getClusterInfo to new function

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

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

[GitHub] storm pull request #1513: STORM-1925 Remove Nimbus thrift call from Nimbus i...

GitHub user HeartSaVioR opened a pull request: https://github.com/apache/storm/pull/1513 STORM-1925 Remove Nimbus thrift call from Nimbus itself * Nimbus fails to start in secure mode since authrization is not passed Extract the logic of getClusterInfo to new function

Re: Can storm pin executor threads to CPU cores?

Hi! Thanks for your pointers! I want to make sure the I/O message queue also being pined together with the corresponding executor, is it possible to do in Storm? Follow Bobby's "easier solution" suggestion, in a machine with multiple CPU sockets, if I pin the executor thread to one CPU socket

[jira] [Commented] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345952#comment-15345952 ] Jungtaek Lim commented on STORM-1925: - Harsha pointed out I'm calling Nimbus thrift API inside of

[GitHub] storm issue #1468: STORM-1885. python script for squashing and merging prs.

Github user HeartSaVioR commented on the issue: https://github.com/apache/storm/pull/1468 Here's my understanding regarding this script. > main() * get latest branch (highest version) from github mirror * it assumes that prefix of release branch is `release

[jira] [Commented] (STORM-1885) python script for squashing and merging prs

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

[jira] [Updated] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1925: Component/s: storm-core > Nimbus fails to start in secure mode >

[jira] [Updated] (STORM-1925) Nimbus fails to start in secure mode

[ https://issues.apache.org/jira/browse/STORM-1925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jungtaek Lim updated STORM-1925: Affects Version/s: 1.1.0 2.0.0 > Nimbus fails to start in secure mode >

[jira] [Created] (STORM-1925) Nimbus fails to start in secure mode

Sriharsha Chintalapani created STORM-1925: - Summary: Nimbus fails to start in secure mode Key: STORM-1925 URL: https://issues.apache.org/jira/browse/STORM-1925 Project: Apache Storm