Github user srishtyagrawal commented on the issue:
https://github.com/apache/storm/pull/2637
@srdo thanks for explaining that. I was looking at the GitHub file links
that's why they were giving 404s.
I have also modified the `socketTimeoutMs` setting map to not be supported
Github user ptgoetz commented on the issue:
https://github.com/apache/storm/pull/2518
+1
---
Github user hustfxj commented on the issue:
https://github.com/apache/storm/pull/2518
+1 Thank you for @vesense
---
Github user roshannaik commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182909146
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -305,8 +305,9 @@ private void setupFlushTupleTimer(final Map
Github user srdo commented on the issue:
https://github.com/apache/storm/pull/2638
Sorry if I'm nitpicking you to death, but I don't think moving the log line
is better. Now everyone gets an error level log, even if the exception is due
to an interrupt. I'd prefer if we just include
Github user kishorvpatil commented on the issue:
https://github.com/apache/storm/pull/2638
@srdo Moved the `LOG.error` before changing exception Cause.
---
Github user kishorvpatil commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182847223
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -109,6 +109,8 @@
import javax.security.auth.Subject;
Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182844665
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -361,6 +363,7 @@ public void run() {
Time.sleep(s);
Github user kishorvpatil commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182843808
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -361,6 +363,7 @@ public void run() {
Github user revans2 closed the pull request at:
https://github.com/apache/storm/pull/2630
---
GitHub user arunmahadevan opened a pull request:
https://github.com/apache/storm/pull/2639
STORM-3035: fix the issue in JmsSpout.ack when toCommit is empty
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/arunmahadevan/storm
Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182833894
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -361,6 +363,7 @@ public void run() {
Time.sleep(s);
Github user srdo commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182833344
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -109,6 +109,8 @@
import javax.security.auth.Subject;
+import static
Github user srdo commented on the issue:
https://github.com/apache/storm/pull/2621
+1, thanks for fixing this.
---
Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/2627
---
Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2638#discussion_r182765656
--- Diff: storm-client/src/jvm/org/apache/storm/utils/Utils.java ---
@@ -109,6 +109,8 @@
import javax.security.auth.Subject;
+import
GitHub user kishorvpatil opened a pull request:
https://github.com/apache/storm/pull/2638
[STORM-3034] Adding exception stacktrace for executor failures in worker
You can merge this pull request into a Git repository by running:
$ git pull
Github user asfgit closed the pull request at:
https://github.com/apache/storm/pull/2631
---
Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182758538
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -305,8 +305,9 @@ private void setupFlushTupleTimer(final Map
Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182757546
--- Diff: storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java
---
@@ -305,8 +305,9 @@ private void setupFlushTupleTimer(final Map
Github user Ethanlm commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182755817
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -3032,9 +3019,19 @@ public void submitTopologyWithOpts(String
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182750384
--- Diff:
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java ---
@@ -3032,9 +3019,19 @@ public void submitTopologyWithOpts(String
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2634#discussion_r182747281
--- Diff: docs/Resource_Aware_Scheduler_overview.md ---
@@ -184,6 +184,10 @@ The user can set some default configurations for the
Resource Aware Scheduler
Github user revans2 commented on a diff in the pull request:
https://github.com/apache/storm/pull/2635#discussion_r182745958
--- Diff:
external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/HBaseSecurityUtil.java
---
@@ -52,24 +54,27 @@ private HBaseSecurityUtil()
Github user srdo commented on the issue:
https://github.com/apache/storm/pull/2637
I read the documentation for maxOffsetBehind you linked, and I think it is
confusingly phrased. It says
> If a failing tuple's offset is less than maxOffsetBehind, the spout stops
retrying
25 matches
Mail list logo