You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@storm.apache.org by pt...@apache.org on 2016/04/27 19:54:08 UTC
[1/4] storm git commit: STORM-1731 Avoid looking up debug /
backpressure enable flags within critical path
Repository: storm
Updated Branches:
refs/heads/0.10.x-branch 67542a3b3 -> 8179921a5
STORM-1731 Avoid looking up debug / backpressure enable flags within critical path
* preload the value of flags and use that value
* topology.debug
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1cc5228e
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1cc5228e
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1cc5228e
Branch: refs/heads/0.10.x-branch
Commit: 1cc5228e3195826836e353342407fea290ea9122
Parents: efdc711
Author: Jungtaek Lim <ka...@gmail.com>
Authored: Wed Apr 27 10:03:04 2016 +0900
Committer: Jungtaek Lim <ka...@gmail.com>
Committed: Wed Apr 27 10:03:04 2016 +0900
----------------------------------------------------------------------
.../src/clj/backtype/storm/daemon/executor.clj | 69 ++++++++++----------
1 file changed, 34 insertions(+), 35 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/1cc5228e/storm-core/src/clj/backtype/storm/daemon/executor.clj
----------------------------------------------------------------------
diff --git a/storm-core/src/clj/backtype/storm/daemon/executor.clj b/storm-core/src/clj/backtype/storm/daemon/executor.clj
index ee1ebf5..12fec2a 100644
--- a/storm-core/src/clj/backtype/storm/daemon/executor.clj
+++ b/storm-core/src/clj/backtype/storm/daemon/executor.clj
@@ -195,24 +195,24 @@
;; in its own function so that it can be mocked out by tracked topologies
(defn mk-executor-transfer-fn [batch-transfer->worker storm-conf]
- (fn this
- ([task tuple block? ^ConcurrentLinkedQueue overflow-buffer]
- (when (= true (storm-conf TOPOLOGY-DEBUG))
- (log-message "TRANSFERING tuple TASK: " task " TUPLE: " tuple))
- (if (and overflow-buffer (not (.isEmpty overflow-buffer)))
- (.add overflow-buffer [task tuple])
- (try-cause
- (disruptor/publish batch-transfer->worker [task tuple] block?)
- (catch InsufficientCapacityException e
- (if overflow-buffer
- (.add overflow-buffer [task tuple])
- (throw e))
- ))))
- ([task tuple overflow-buffer]
- (this task tuple (nil? overflow-buffer) overflow-buffer))
- ([task tuple]
- (this task tuple nil)
- )))
+ (let [debug? (= true (storm-conf TOPOLOGY-DEBUG))]
+ (fn this
+ ([task tuple block? ^ConcurrentLinkedQueue overflow-buffer]
+ (when debug?
+ (log-message "TRANSFERING tuple TASK: " task " TUPLE: " tuple))
+ (if (and overflow-buffer (not (.isEmpty overflow-buffer)))
+ (.add overflow-buffer [task tuple])
+ (try-cause
+ (disruptor/publish batch-transfer->worker [task tuple] block?)
+ (catch InsufficientCapacityException e
+ (if overflow-buffer
+ (.add overflow-buffer [task tuple])
+ (throw e))
+ ))))
+ ([task tuple overflow-buffer]
+ (this task tuple (nil? overflow-buffer) overflow-buffer))
+ ([task tuple]
+ (this task tuple nil)))))
(defn mk-executor-data [worker executor-id]
(let [worker-context (worker-context worker)
@@ -397,12 +397,12 @@
(log-message "Shut down executor " component-id ":" (pr-str executor-id)))
)))
-(defn- fail-spout-msg [executor-data task-data msg-id tuple-info time-delta reason id]
+(defn- fail-spout-msg [executor-data task-data msg-id tuple-info time-delta reason id debug?]
(let [^ISpout spout (:object task-data)
storm-conf (:storm-conf executor-data)
task-id (:task-id task-data)]
;;TODO: need to throttle these when there's lots of failures
- (when (= true (storm-conf TOPOLOGY-DEBUG))
+ (when debug?
(log-message "SPOUT Failing " id ": " tuple-info " REASON: " reason " MSG-ID: " msg-id))
(.fail spout msg-id)
(task/apply-hooks (:user-context task-data) .spoutFail (SpoutFailInfo. msg-id task-id time-delta))
@@ -410,11 +410,10 @@
(builtin-metrics/spout-failed-tuple! (:builtin-metrics task-data) (:stats executor-data) (:stream tuple-info))
(stats/spout-failed-tuple! (:stats executor-data) (:stream tuple-info) time-delta))))
-(defn- ack-spout-msg [executor-data task-data msg-id tuple-info time-delta id]
- (let [storm-conf (:storm-conf executor-data)
- ^ISpout spout (:object task-data)
+(defn- ack-spout-msg [executor-data task-data msg-id tuple-info time-delta id debug?]
+ (let [^ISpout spout (:object task-data)
task-id (:task-id task-data)]
- (when (= true (storm-conf TOPOLOGY-DEBUG))
+ (when debug?
(log-message "SPOUT Acking message " id " " msg-id))
(.ack spout msg-id)
(task/apply-hooks (:user-context task-data) .spoutAck (SpoutAckInfo. msg-id task-id time-delta))
@@ -458,6 +457,7 @@
last-active (atom false)
spouts (ArrayList. (map :object (vals task-datas)))
rand (Random. (Utils/secureRandomLong))
+ debug? (= true (storm-conf TOPOLOGY-DEBUG))
;; the overflow buffer is used to ensure that spouts never block when emitting
;; this ensures that the spout can always clear the incoming buffer (acks and fails), which
@@ -473,7 +473,7 @@
(reify RotatingMap$ExpiredCallback
(expire [this id [task-id spout-id tuple-info start-time-ms]]
(let [time-delta (if start-time-ms (time-delta-ms start-time-ms))]
- (fail-spout-msg executor-data (get task-datas task-id) spout-id tuple-info time-delta "TIMEOUT" id)
+ (fail-spout-msg executor-data (get task-datas task-id) spout-id tuple-info time-delta "TIMEOUT" id debug?)
))))
tuple-action-fn (fn [task-id ^TupleImpl tuple]
(let [stream-id (.getSourceStreamId tuple)]
@@ -493,9 +493,9 @@
(let [time-delta (if start-time-ms (time-delta-ms start-time-ms))]
(condp = stream-id
ACKER-ACK-STREAM-ID (ack-spout-msg executor-data (get task-datas task-id)
- spout-id tuple-finished-info time-delta id)
+ spout-id tuple-finished-info time-delta id debug?)
ACKER-FAIL-STREAM-ID (fail-spout-msg executor-data (get task-datas task-id)
- spout-id tuple-finished-info time-delta "FAIL-STREAM" id)
+ spout-id tuple-finished-info time-delta "FAIL-STREAM" id debug?)
)))
;; TODO: on failure, emit tuple to failure stream
))))
@@ -550,7 +550,7 @@
(when message-id
(ack-spout-msg executor-data task-data message-id
{:stream out-stream-id :values values}
- (if (sampler) 0) "0:")))
+ (if (sampler) 0) "0:" debug?)))
(or out-tasks [])
))]]
(builtin-metrics/register-all (:builtin-metrics task-data) storm-conf (:user-context task-data))
@@ -637,12 +637,12 @@
(.put pending key (bit-xor curr id))))
(defmethod mk-threads :bolt [executor-data task-datas initial-credentials]
- (let [storm-conf (:storm-conf executor-data)
+ (let [{:keys [storm-conf component-id worker-context transfer-fn report-error sampler
+ open-or-prepare-was-called?]} executor-data
execute-sampler (mk-stats-sampler storm-conf)
executor-stats (:stats executor-data)
- {:keys [storm-conf component-id worker-context transfer-fn report-error sampler
- open-or-prepare-was-called?]} executor-data
rand (Random. (Utils/secureRandomLong))
+ debug? (= true (storm-conf TOPOLOGY-DEBUG))
;; the overflow buffer is used to ensure that bolts do not block when emitting
;; this ensures that the bolt can always clear the incoming messages, which
@@ -689,7 +689,7 @@
(.setExecuteSampleStartTime tuple now))
(.execute bolt-obj tuple)
(let [delta (tuple-execute-time-delta! tuple)]
- (when (= true (storm-conf TOPOLOGY-DEBUG))
+ (when debug?
(log-message "Execute done TUPLE " tuple " TASK: " task-id " DELTA: " delta))
(task/apply-hooks user-context .boltExecute (BoltExecuteInfo. tuple task-id delta))
@@ -771,8 +771,7 @@
ACKER-ACK-STREAM-ID
[root (bit-xor id ack-val)] overflow-buffer)
))
- (let [delta (tuple-time-delta! tuple)
- debug? (= true (storm-conf TOPOLOGY-DEBUG))]
+ (let [delta (tuple-time-delta! tuple)]
(when debug?
(log-message "BOLT ack TASK: " task-id " TIME: " delta " TUPLE: " tuple))
(task/apply-hooks user-context .boltAck (BoltAckInfo. tuple task-id delta))
@@ -824,7 +823,7 @@
(transfer-fn out-task out-tuple false nil)
(.poll overflow-buffer)))
(catch InsufficientCapacityException e
- (when (= true (storm-conf TOPOLOGY-DEBUG))
+ (when debug?
(log-message "Insufficient Capacity on queue to emit by bolt " component-id ":" (keys task-datas) ))
))
0)))
[2/4] storm git commit: Merge branch 'STORM-1731-0.10.x-branch' of
github.com:HeartSaVioR/storm into 0.10.x-branch
Posted by pt...@apache.org.
Merge branch 'STORM-1731-0.10.x-branch' of github.com:HeartSaVioR/storm into 0.10.x-branch
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/5310e146
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/5310e146
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/5310e146
Branch: refs/heads/0.10.x-branch
Commit: 5310e1465eb98df6caeb6c6e5759abd2b2eae3c8
Parents: 67542a3 1cc5228
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Apr 27 13:27:02 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Apr 27 13:27:02 2016 -0400
----------------------------------------------------------------------
.../src/clj/backtype/storm/daemon/executor.clj | 69 ++++++++++----------
1 file changed, 34 insertions(+), 35 deletions(-)
----------------------------------------------------------------------
[4/4] storm git commit: [maven-release-plugin] prepare release v0.10.1
Posted by pt...@apache.org.
[maven-release-plugin] prepare release v0.10.1
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/8179921a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/8179921a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/8179921a
Branch: refs/heads/0.10.x-branch
Commit: 8179921a569b6cf1d97798eed8e7b03b131bc495
Parents: 828a32f
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Apr 27 13:54:02 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Apr 27 13:54:02 2016 -0400
----------------------------------------------------------------------
examples/storm-starter/pom.xml | 2 +-
external/flux/flux-core/pom.xml | 2 +-
external/flux/flux-examples/pom.xml | 2 +-
external/flux/flux-wrappers/pom.xml | 2 +-
external/flux/pom.xml | 2 +-
external/storm-eventhubs/pom.xml | 2 +-
external/storm-hbase/pom.xml | 2 +-
external/storm-hdfs/pom.xml | 2 +-
external/storm-hive/pom.xml | 2 +-
external/storm-jdbc/pom.xml | 2 +-
external/storm-kafka/pom.xml | 2 +-
external/storm-redis/pom.xml | 2 +-
pom.xml | 4 ++--
storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
storm-buildtools/storm-maven-plugins/pom.xml | 2 +-
storm-core/pom.xml | 2 +-
storm-dist/binary/pom.xml | 2 +-
storm-dist/source/pom.xml | 2 +-
storm-multilang/javascript/pom.xml | 2 +-
storm-multilang/python/pom.xml | 2 +-
storm-multilang/ruby/pom.xml | 2 +-
21 files changed, 22 insertions(+), 22 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/examples/storm-starter/pom.xml
----------------------------------------------------------------------
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index f524062..a174b6a 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/flux/flux-core/pom.xml
----------------------------------------------------------------------
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index 90f9e6a..d132645 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.storm</groupId>
<artifactId>flux</artifactId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/flux/flux-examples/pom.xml
----------------------------------------------------------------------
diff --git a/external/flux/flux-examples/pom.xml b/external/flux/flux-examples/pom.xml
index 4e8d67d..cdf575f 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.storm</groupId>
<artifactId>flux</artifactId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/flux/flux-wrappers/pom.xml
----------------------------------------------------------------------
diff --git a/external/flux/flux-wrappers/pom.xml b/external/flux/flux-wrappers/pom.xml
index 9b60526..34048fd 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
<parent>
<groupId>org.apache.storm</groupId>
<artifactId>flux</artifactId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/flux/pom.xml
----------------------------------------------------------------------
diff --git a/external/flux/pom.xml b/external/flux/pom.xml
index cd356cf..039ff12 100644
--- a/external/flux/pom.xml
+++ b/external/flux/pom.xml
@@ -26,7 +26,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-eventhubs/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-eventhubs/pom.xml b/external/storm-eventhubs/pom.xml
index b036fec..528e502 100755
--- a/external/storm-eventhubs/pom.xml
+++ b/external/storm-eventhubs/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-hbase/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-hbase/pom.xml b/external/storm-hbase/pom.xml
index 94625fd..2eea53b 100644
--- a/external/storm-hbase/pom.xml
+++ b/external/storm-hbase/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-hdfs/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-hdfs/pom.xml b/external/storm-hdfs/pom.xml
index 05e7aa1..ac9e212 100644
--- a/external/storm-hdfs/pom.xml
+++ b/external/storm-hdfs/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-hive/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-hive/pom.xml b/external/storm-hive/pom.xml
index 919fa81..b4be89c 100644
--- a/external/storm-hive/pom.xml
+++ b/external/storm-hive/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-jdbc/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-jdbc/pom.xml b/external/storm-jdbc/pom.xml
index d744d77..a673245 100644
--- a/external/storm-jdbc/pom.xml
+++ b/external/storm-jdbc/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-kafka/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-kafka/pom.xml b/external/storm-kafka/pom.xml
index 2805f2a..99e865f 100644
--- a/external/storm-kafka/pom.xml
+++ b/external/storm-kafka/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/external/storm-redis/pom.xml
----------------------------------------------------------------------
diff --git a/external/storm-redis/pom.xml b/external/storm-redis/pom.xml
index 30397e0..dfbb3ea 100644
--- a/external/storm-redis/pom.xml
+++ b/external/storm-redis/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/pom.xml
----------------------------------------------------------------------
diff --git a/pom.xml b/pom.xml
index 71c39d7..dfd4d9d 100644
--- a/pom.xml
+++ b/pom.xml
@@ -27,7 +27,7 @@
<groupId>org.apache.storm</groupId>
<artifactId>storm</artifactId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<packaging>pom</packaging>
<name>Storm</name>
<description>Distributed and fault-tolerant realtime computation</description>
@@ -157,7 +157,7 @@
<scm>
<connection>scm:git:https://git-wip-us.apache.org/repos/asf/storm.git</connection>
<developerConnection>scm:git:https://git-wip-us.apache.org/repos/asf/storm.git</developerConnection>
- <tag>HEAD</tag>
+ <tag>v0.10.1</tag>
<url>https://git-wip-us.apache.org/repos/asf/storm</url>
</scm>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/maven-shade-clojure-transformer/pom.xml b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
index 71c2a18..43a711c 100644
--- a/storm-buildtools/maven-shade-clojure-transformer/pom.xml
+++ b/storm-buildtools/maven-shade-clojure-transformer/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-buildtools/storm-maven-plugins/pom.xml
----------------------------------------------------------------------
diff --git a/storm-buildtools/storm-maven-plugins/pom.xml b/storm-buildtools/storm-maven-plugins/pom.xml
index ed5ae1a..58fa2dd 100644
--- a/storm-buildtools/storm-maven-plugins/pom.xml
+++ b/storm-buildtools/storm-maven-plugins/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-core/pom.xml
----------------------------------------------------------------------
diff --git a/storm-core/pom.xml b/storm-core/pom.xml
index b7f1791..513d341 100644
--- a/storm-core/pom.xml
+++ b/storm-core/pom.xml
@@ -20,7 +20,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>..</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-dist/binary/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 42d7379..1f77daa 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-dist/source/pom.xml
----------------------------------------------------------------------
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index 273e82c..29059b4 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-multilang/javascript/pom.xml
----------------------------------------------------------------------
diff --git a/storm-multilang/javascript/pom.xml b/storm-multilang/javascript/pom.xml
index f72e571..3702ab8 100644
--- a/storm-multilang/javascript/pom.xml
+++ b/storm-multilang/javascript/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-multilang/python/pom.xml
----------------------------------------------------------------------
diff --git a/storm-multilang/python/pom.xml b/storm-multilang/python/pom.xml
index 837604e..e0f6f34 100644
--- a/storm-multilang/python/pom.xml
+++ b/storm-multilang/python/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
http://git-wip-us.apache.org/repos/asf/storm/blob/8179921a/storm-multilang/ruby/pom.xml
----------------------------------------------------------------------
diff --git a/storm-multilang/ruby/pom.xml b/storm-multilang/ruby/pom.xml
index c54aafd..d79ae57 100644
--- a/storm-multilang/ruby/pom.xml
+++ b/storm-multilang/ruby/pom.xml
@@ -21,7 +21,7 @@
<parent>
<artifactId>storm</artifactId>
<groupId>org.apache.storm</groupId>
- <version>0.10.1-SNAPSHOT</version>
+ <version>0.10.1</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<groupId>org.apache.storm</groupId>
[3/4] storm git commit: add STORM-1731 to changelog
Posted by pt...@apache.org.
add STORM-1731 to changelog
Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/828a32f8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/828a32f8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/828a32f8
Branch: refs/heads/0.10.x-branch
Commit: 828a32f8f2cc49e668716596c12b4a00e5ad38b5
Parents: 5310e14
Author: P. Taylor Goetz <pt...@gmail.com>
Authored: Wed Apr 27 13:33:07 2016 -0400
Committer: P. Taylor Goetz <pt...@gmail.com>
Committed: Wed Apr 27 13:33:07 2016 -0400
----------------------------------------------------------------------
CHANGELOG.md | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/storm/blob/828a32f8/CHANGELOG.md
----------------------------------------------------------------------
diff --git a/CHANGELOG.md b/CHANGELOG.md
index c69ee51..7c9bf06 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
## 0.10.1
+ * STORM-1731: Avoid looking up debug enable flags within critical path
* STORM-1645: convert nimbus.thrift.port to int to avoid ClassCastException
* STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors
* STORM-584: Fix logging for LoggingMetricsConsumer metrics.log file