[
https://issues.apache.org/jira/browse/STORM-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117578#comment-15117578
]
ASF GitHub Bot commented on STORM-1501:
---
Github user revans2 commented on the pull r
https://issues.apache.org/jira/browse/STORM-1502 -- Kyle
On Sunday, January 24, 2016 4:29 PM, Jungtaek Lim wrote:
+1 for having version specific docs.
We move docs to asf-site branch, and now we have only one REST API doc. for
1.0.0 and later versions.
It would also great to describe a
Kyle Nusbaum created STORM-1502:
---
Summary: Create per-version document scheme
Key: STORM-1502
URL: https://issues.apache.org/jira/browse/STORM-1502
Project: Apache Storm
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/STORM-1501?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117584#comment-15117584
]
ASF GitHub Bot commented on STORM-1501:
---
Github user revans2 commented on a diff in
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1046#discussion_r50867596
--- Diff: storm-core/src/clj/org/apache/storm/util.clj ---
@@ -553,7 +553,8 @@
(catch InterruptedException e
(log-mes
Since the github repo is read-only, I think this has to be an INFRA ticket.
It would probably be best to come up with a complete list of branches to delete
so it can be done in one shot by INFRA.
-Taylor
> On Jan 26, 2016, at 12:00 PM, Kyle Nusbaum wrote:
>
> Great.
>
> I quit deleting bran
Kishor Patil created STORM-1503:
---
Summary: PacemakerClient Reconnection issue
Key: STORM-1503
URL: https://issues.apache.org/jira/browse/STORM-1503
Project: Apache Storm
Issue Type: Bug
Aff
GitHub user kishorvpatil opened a pull request:
https://github.com/apache/storm/pull/1048
[STORM-1503] Worker should not crash on failure to send heartbeats to
Pacemaker/ZK
- Worker should catch and log Exception related to sending worker
heartbeats to ZK/pacemaker.
- `Pacemake
[
https://issues.apache.org/jira/browse/STORM-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117635#comment-15117635
]
ASF GitHub Bot commented on STORM-1503:
---
GitHub user kishorvpatil opened a pull requ
Github user knusbaum commented on the pull request:
https://github.com/apache/storm/pull/1048#issuecomment-175144958
+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 an
[
https://issues.apache.org/jira/browse/STORM-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117656#comment-15117656
]
ASF GitHub Bot commented on STORM-1503:
---
Github user knusbaum commented on the pull
[
https://issues.apache.org/jira/browse/STORM-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117660#comment-15117660
]
ASF GitHub Bot commented on STORM-1455:
---
Github user abhishekagarwal87 commented on
Github user abhishekagarwal87 commented on the pull request:
https://github.com/apache/storm/pull/1026#issuecomment-175146222
Thanks @revans2 . Fixed the compilation error. I had missed some changes.
To put these changes in 1.0 release, do I need to open another pull request?
---
If
Github user revans2 commented on the pull request:
https://github.com/apache/storm/pull/1026#issuecomment-175148840
Typically you don't need a separate pull request. Just ask for it and we
will cherry-pick it. If there are merge conflicts we may come back and ask for
a separate pull
[
https://issues.apache.org/jira/browse/STORM-1455?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117672#comment-15117672
]
ASF GitHub Bot commented on STORM-1455:
---
Github user revans2 commented on the pull r
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Yegor Tokmakov reassigned STORM-1494:
-
Assignee: Yegor Tokmakov
> Storm UI - Add link to supervisor log
> --
[
https://issues.apache.org/jira/browse/STORM-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117743#comment-15117743
]
ASF GitHub Bot commented on STORM-1503:
---
Github user redsanket commented on the pull
Github user redsanket commented on the pull request:
https://github.com/apache/storm/pull/1048#issuecomment-175175561
+1 NB
---
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
enable
GitHub user yegortokmakov opened a pull request:
https://github.com/apache/storm/pull/1049
STORM-1494 Link to supervisor logs form UI
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/yegortokmakov/storm STORM-1494
Alternatively y
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117758#comment-15117758
]
ASF GitHub Bot commented on STORM-1494:
---
GitHub user yegortokmakov opened a pull req
Github user yegortokmakov commented on the pull request:
https://github.com/apache/storm/pull/1049#issuecomment-175180562
I've also removed not used argument in nimbus-log-link
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as we
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15117760#comment-15117760
]
ASF GitHub Bot commented on STORM-1494:
---
Github user yegortokmakov commented on the
Github user d2r commented on the pull request:
https://github.com/apache/storm/pull/1048#issuecomment-175186654
+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 wis
[
https://issues.apache.org/jira/browse/STORM-1503?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=1511#comment-1511
]
ASF GitHub Bot commented on STORM-1503:
---
Github user d2r commented on the pull reque
Github user revans2 commented on the pull request:
https://github.com/apache/storm/pull/1043#issuecomment-175205323
First off RAT is complaining about 3 files. Please take a look into that.
---
If your project is set up for it, you can reply to this email and have your
reply appear o
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893250
--- Diff:
storm-core/src/clj/org/apache/storm/cluster_state/zookeeper_state_factory.clj
---
@@ -90,7 +91,7 @@
(if (zk/exists zk-writer path false
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893638
--- Diff: storm-core/src/clj/org/apache/storm/config.clj ---
@@ -91,25 +91,25 @@
(let [storm-home (System/getProperty "storm.home")
path (c
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893784
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -80,6 +83,17 @@
(fn [list-of-executors]
(into [] list-of-executo
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893744
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -71,6 +72,8 @@
(:worker->res
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893895
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -131,6 +151,9 @@
(if (:num-workers rebalance-options)
(.set_num_work
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893939
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -178,18 +201,25 @@
(.set_enable (get options :enable false))
(.set_samplin
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893972
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -201,17 +231,28 @@
(.get_owner storm-base)
(clojurify-topology-action-
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50893958
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -201,17 +231,28 @@
(.get_owner storm-base)
(clojurify-topology-action-
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894007
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -201,17 +231,28 @@
(.get_owner storm-base)
(clojurify-topology-action-
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894044
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -201,17 +231,28 @@
(.get_owner storm-base)
(clojurify-topology-action-
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894025
--- Diff: storm-core/src/clj/org/apache/storm/converter.clj ---
@@ -201,17 +231,28 @@
(.get_owner storm-base)
(clojurify-topology-action-
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894663
--- Diff: storm-core/src/clj/org/apache/storm/local_state.clj ---
@@ -104,17 +105,24 @@
(->executor-list (.get_executors thrift-local-assignment))
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894670
--- Diff: storm-core/src/clj/org/apache/storm/local_state.clj ---
@@ -104,17 +105,24 @@
(->executor-list (.get_executors thrift-local-assignment))
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894778
--- Diff:
storm-core/src/clj/org/apache/storm/scheduler/IsolationScheduler.clj ---
@@ -41,6 +51,7 @@
(map vector (repeat-seq (range (.getNumWorker
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50894857
--- Diff: storm-core/src/clj/org/apache/storm/stats.clj ---
@@ -702,11 +713,16 @@
:acked (sum-or-0 (:acked acc-spout-stats) (:acked spout-stats))
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50895014
--- Diff: storm-core/src/clj/org/apache/storm/testing.clj ---
@@ -519,10 +556,12 @@
;; TODO: the idea of mocking for transactional topologies should be
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50895133
--- Diff: storm-core/src/clj/org/apache/storm/util.clj ---
@@ -48,21 +48,21 @@
(:require [ring.util.codec :as codec])
(:use [org.apache.storm log
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50895476
--- Diff: storm-core/src/jvm/org/apache/storm/utils/IFn.java ---
@@ -0,0 +1,8 @@
+package org.apache.storm.utils;
+
+/**
+ * Created by rfariva
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50895500
--- Diff: storm-core/src/jvm/org/apache/storm/utils/IPredicate.java ---
@@ -0,0 +1,8 @@
+package org.apache.storm.utils;
--- End diff --
Apach
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50896029
--- Diff: storm-core/src/jvm/org/apache/storm/utils/IPredicate.java ---
@@ -0,0 +1,8 @@
+package org.apache.storm.utils;
+
+/**
+ * Created by
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50896065
--- Diff: storm-core/src/jvm/org/apache/storm/utils/StaticMockable.java ---
@@ -0,0 +1,6 @@
+package org.apache.storm.utils;
--- End diff --
A
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50896559
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Time.java ---
@@ -102,6 +102,14 @@ public static long currentTimeMillis() {
public static int curr
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50896659
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -530,6 +559,10 @@ private static boolean
downloadResourcesAsSupervisorAttempt(ClientBlob
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50896874
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50897000
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50897241
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50897502
--- Diff: storm-core/src/clj/org/apache/storm/util.clj ---
@@ -48,21 +48,21 @@
(:require [ring.util.codec :as codec])
(:use [org.apache.storm log
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50897886
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898011
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50897100
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898231
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898272
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898419
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898350
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898579
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898645
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50898732
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50899023
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50899194
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50899355
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50899281
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50900303
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50900498
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50901067
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50900760
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1382,5 +1422,438 @@ public static TopologyInfo getTopologyInfo(String
name, String asUs
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50902361
--- Diff: storm-core/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -1050,6 +1083,12 @@ public String getBackupConnectionString() throws
Exception {
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50902614
--- Diff: storm-core/test/clj/org/apache/storm/logviewer_test.clj ---
@@ -360,23 +367,24 @@
;; match.
exp-offset-fn #(- (/ logviewer/
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/1043#discussion_r50903820
--- Diff: storm-core/test/clj/org/apache/storm/supervisor_test.clj ---
@@ -545,13 +569,14 @@
(stubbing [uptime-computer nil
cl
Github user revans2 commented on the pull request:
https://github.com/apache/storm/pull/1043#issuecomment-175242193
Finished with my first pass through the code. For the most part things are
looking very good.
---
If your project is set up for it, you can reply to this email and hav
Github user zhuoliu commented on the pull request:
https://github.com/apache/storm/pull/1049#issuecomment-175250031
LGTM! +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
enabl
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118131#comment-15118131
]
ASF GitHub Bot commented on STORM-1494:
---
Github user zhuoliu commented on the pull r
Github user revans2 commented on the pull request:
https://github.com/apache/storm/pull/1049#issuecomment-175263760
+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
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118182#comment-15118182
]
ASF GitHub Bot commented on STORM-1494:
---
Github user revans2 commented on the pull r
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118229#comment-15118229
]
ASF GitHub Bot commented on STORM-1494:
---
Github user HeartSaVioR commented on the pu
Github user HeartSaVioR commented on the pull request:
https://github.com/apache/storm/pull/1049#issuecomment-175275852
+1
Since this modifies clj file, we may want to decide how to apply this to
master.
Would it better to merge to 1.x first and just leave notice? Or do we just
I set in the code
conf.put(Config.DRPC_SERVERS, dprcServers);
conf.put(Config.DRPC_PORT, 3772);
but when i submit topolgoy i found at the end of the file
b.s.d.drpc [INFO] Starting Distributed RPC servers...
i checked port 3772 by
sudo netstat -ap | grep 3772
i got
tcp 00 *:377
hey,
The DRPC server is up and listening on port 3772. Why do you expect
established connections?
I'm not familiar with using Storm's DRPC feature, but I'm sure you need to
write code that interacts with the DRPC server, and you've made no mention
of doing so in your email. I'd start here:
thanks for replying , i read the documentation before , i imported project
supposed to work well but not working with me
i checked port by lsof -i gave me all ports i connected it for storm
java 10675 root 20u IPv4 98126 0t0 TCP *:52022 (LISTEN)
java 10675 root 26u IPv4
[
https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118407#comment-15118407
]
ASF GitHub Bot commented on STORM-1257:
---
Github user hustfxj commented on a diff in
Github user hustfxj commented on a diff in the pull request:
https://github.com/apache/storm/pull/1047#discussion_r50929299
--- Diff:
storm-core/src/jvm/org/apache/storm/zookeeper/LeaderElectorImp.java ---
@@ -0,0 +1,135 @@
+/**
+ * Licensed to the Apache Software Foundatio
Github user hustfxj commented on a diff in the pull request:
https://github.com/apache/storm/pull/1047#discussion_r50929871
--- Diff:
storm-core/src/jvm/org/apache/storm/callback/DefaultWatcherCallBack.java ---
@@ -0,0 +1,35 @@
+/**
+ * Licensed to the Apache Software Found
[
https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118419#comment-15118419
]
ASF GitHub Bot commented on STORM-1257:
---
Github user hustfxj commented on a diff in
[
https://issues.apache.org/jira/browse/STORM-1245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Basti Liu reassigned STORM-1245:
Assignee: Basti Liu
> port backtype.storm.daemon.acker to java
> --
Aaron Dossett created STORM-1504:
Summary: AvroGenericRecordBolt will not work in a topology with
multiple workers
Key: STORM-1504
URL: https://issues.apache.org/jira/browse/STORM-1504
Project: Apache
[
https://issues.apache.org/jira/browse/STORM-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aaron Dossett updated STORM-1504:
-
Description:
It receives Avro GenericRecord objects, which leads to serialization errors in
a mul
[
https://issues.apache.org/jira/browse/STORM-1504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aaron Dossett reassigned STORM-1504:
Assignee: Aaron Dossett
> AvroGenericRecordBolt will not work in a topology with multiple w
What does the client code that is supposed to make the DRPC connection
telling you? i.e., you should see some exception or log about not
establishing the connection, right?
Alternatively, perhaps the connections aren't persistent and there's no
actual problem?
- Erik
On Tue, Jan 26, 2016 at 4:5
There is no error except the statement of drpc server trying to connect . I
guess I have problem with Dns . if you have any idea about this pleaes help
I want to submit topology with single machine
Only on my laptop without any other devices as a first step so
What this file /etc/hosts should co
Github user hustfxj commented on a diff in the pull request:
https://github.com/apache/storm/pull/1047#discussion_r50937532
--- Diff: storm-core/src/jvm/org/apache/storm/zookeeper/Zookeeper.java ---
@@ -0,0 +1,355 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF)
[
https://issues.apache.org/jira/browse/STORM-1257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118570#comment-15118570
]
ASF GitHub Bot commented on STORM-1257:
---
Github user hustfxj commented on a diff in
Github user ptgoetz commented on the pull request:
https://github.com/apache/storm/pull/1049#issuecomment-175378568
+1
For now I'd say it should be applied to the 1.x branch. Master should be
considered as well, since the .clj files involved haven't really come into play
ye
[
https://issues.apache.org/jira/browse/STORM-1494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118597#comment-15118597
]
ASF GitHub Bot commented on STORM-1494:
---
Github user ptgoetz commented on the pull r
You said: "except the statement of drpc server trying to connect"
Maybe you are confused about what "b.s.d.drpc [INFO] Starting Distributed
RPC servers..." implies?
That is just saying that the server is being started. It's a server, not
a client, so it's basic operation is *not* to connect to s
[
https://issues.apache.org/jira/browse/STORM-1342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15118650#comment-15118650
]
Erik Weathers commented on STORM-1342:
--
STORM-1494 is adding support for the supervis
yes i tried in local and worked well
and about /etc/hosts . i'm feeling that this file has a mistake , i made
alot of changes in this file and didn't remember what was default
In nimbus log file when it connected zookeeper i got
2016-01-27 01:41:00 c.n.c.f.i.CuratorFrameworkImpl [INFO] Starting
20
101 - 200 of 201 matches
Mail list logo
