[storm] Git Push Summary

2016-04-25 Thread ptgoetz
Repository: storm
Updated Tags:  refs/tags/v1.0.1 [created] 48b6a843f


storm git commit: [maven-release-plugin] prepare for next development iteration

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 7520b9ae1 -> 7c6355df9


[maven-release-plugin] prepare for next development iteration


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7c6355df
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7c6355df
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7c6355df

Branch: refs/heads/1.x-branch
Commit: 7c6355df92cee04854dab46977d2dea47a8c47fb
Parents: 7520b9a
Author: P. Taylor Goetz 
Authored: Mon Apr 25 17:02:39 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 17:02:39 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/sql/pom.xml | 2 +-
 external/sql/storm-sql-core/pom.xml  | 2 +-
 external/sql/storm-sql-kafka/pom.xml | 2 +-
 external/sql/storm-sql-runtime/pom.xml   | 2 +-
 external/storm-cassandra/pom.xml | 2 +-
 external/storm-elasticsearch/pom.xml | 2 +-
 external/storm-eventhubs/pom.xml | 4 ++--
 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-client/pom.xml  | 2 +-
 external/storm-kafka/pom.xml | 2 +-
 external/storm-metrics/pom.xml   | 2 +-
 external/storm-mongodb/pom.xml   | 2 +-
 external/storm-mqtt/core/pom.xml | 2 +-
 external/storm-mqtt/examples/pom.xml | 2 +-
 external/storm-mqtt/pom.xml  | 2 +-
 external/storm-redis/pom.xml | 2 +-
 external/storm-solr/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 +-
 storm-rename-hack/pom.xml| 2 +-
 35 files changed, 37 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/7c6355df/examples/storm-starter/pom.xml
--
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 788075e..62c262f 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
   
   storm
   org.apache.storm
-  1.0.1
+  1.0.2-SNAPSHOT
   ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7c6355df/external/flux/flux-core/pom.xml
--
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index bbde342..3f86dbf 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1
+1.0.2-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7c6355df/external/flux/flux-examples/pom.xml
--
diff --git a/external/flux/flux-examples/pom.xml 
b/external/flux/flux-examples/pom.xml
index 1a16e12..1edfaa3 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1
+1.0.2-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7c6355df/external/flux/flux-wrappers/pom.xml
--
diff --git a/external/flux/flux-wrappers/pom.xml 
b/external/flux/flux-wrappers/pom.xml
index af5aa15..6f875ea 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-  

[2/3] storm git commit: Revert "Added distributionManagement repoUrl." since it broke the release process.

2016-04-25 Thread ptgoetz
Revert "Added distributionManagement repoUrl." since it broke the release 
process.

This reverts commit 705951ebf33e84b28af345b7680abf94264d8b68.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/1c60553f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/1c60553f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/1c60553f

Branch: refs/heads/1.x-branch
Commit: 1c60553f0cd5723daff247305f6f679f343e35fa
Parents: 187fc37
Author: P. Taylor Goetz 
Authored: Mon Apr 25 16:49:53 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 16:49:53 2016 -0400

--
 pom.xml | 5 -
 1 file changed, 5 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/1c60553f/pom.xml
--
diff --git a/pom.xml b/pom.xml
index 2a8ca0e..33da388 100644
--- a/pom.xml
+++ b/pom.xml
@@ -486,11 +486,6 @@
 Storm Website
 file:///tmp/site
 
-
-  ${repoid}
-  ${reponame}
-  ${repourl}
-
 
 
 



[3/3] storm git commit: [maven-release-plugin] prepare release v1.0.1

2016-04-25 Thread ptgoetz
[maven-release-plugin] prepare release v1.0.1


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7520b9ae
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7520b9ae
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7520b9ae

Branch: refs/heads/1.x-branch
Commit: 7520b9ae13c4a4fcd823e2d636e9b2cc1cbb7e6f
Parents: 1c60553
Author: P. Taylor Goetz 
Authored: Mon Apr 25 17:02:30 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 17:02:30 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/sql/pom.xml | 2 +-
 external/sql/storm-sql-core/pom.xml  | 2 +-
 external/sql/storm-sql-kafka/pom.xml | 2 +-
 external/sql/storm-sql-runtime/pom.xml   | 2 +-
 external/storm-cassandra/pom.xml | 2 +-
 external/storm-elasticsearch/pom.xml | 2 +-
 external/storm-eventhubs/pom.xml | 4 ++--
 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-client/pom.xml  | 2 +-
 external/storm-kafka/pom.xml | 2 +-
 external/storm-metrics/pom.xml   | 2 +-
 external/storm-mongodb/pom.xml   | 2 +-
 external/storm-mqtt/core/pom.xml | 2 +-
 external/storm-mqtt/examples/pom.xml | 2 +-
 external/storm-mqtt/pom.xml  | 2 +-
 external/storm-redis/pom.xml | 2 +-
 external/storm-solr/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 +-
 storm-rename-hack/pom.xml| 2 +-
 35 files changed, 37 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/7520b9ae/examples/storm-starter/pom.xml
--
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 8e2ebfe..788075e 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
   
   storm
   org.apache.storm
-  1.0.1-SNAPSHOT
+  1.0.1
   ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7520b9ae/external/flux/flux-core/pom.xml
--
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index 135ea56..bbde342 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT
+1.0.1
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7520b9ae/external/flux/flux-examples/pom.xml
--
diff --git a/external/flux/flux-examples/pom.xml 
b/external/flux/flux-examples/pom.xml
index 2ba72df..1a16e12 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT
+1.0.1
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7520b9ae/external/flux/flux-wrappers/pom.xml
--
diff --git a/external/flux/flux-wrappers/pom.xml 
b/external/flux/flux-wrappers/pom.xml
index 516f8a0..af5aa15 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT
+1.0.1
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/s

[1/3] storm git commit: rollback version in dist poms

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 2e9905675 -> 7520b9ae1


rollback version in dist poms


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/187fc370
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/187fc370
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/187fc370

Branch: refs/heads/1.x-branch
Commit: 187fc3702dddc1621772a1096ed203f03be8b1ba
Parents: 2e99056
Author: P. Taylor Goetz 
Authored: Mon Apr 25 16:48:47 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 16:48:47 2016 -0400

--
 storm-dist/binary/pom.xml | 2 +-
 storm-dist/source/pom.xml | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/187fc370/storm-dist/binary/pom.xml
--
diff --git a/storm-dist/binary/pom.xml b/storm-dist/binary/pom.xml
index 5e19961..0219670 100644
--- a/storm-dist/binary/pom.xml
+++ b/storm-dist/binary/pom.xml
@@ -21,7 +21,7 @@
 
 storm
 org.apache.storm
-1.0.2-SNAPSHOT
+1.0.1-SNAPSHOT
 ../../pom.xml
 
 org.apache.storm

http://git-wip-us.apache.org/repos/asf/storm/blob/187fc370/storm-dist/source/pom.xml
--
diff --git a/storm-dist/source/pom.xml b/storm-dist/source/pom.xml
index eb88065..393d92b 100644
--- a/storm-dist/source/pom.xml
+++ b/storm-dist/source/pom.xml
@@ -21,7 +21,7 @@
 
 storm
 org.apache.storm
-1.0.2-SNAPSHOT
+1.0.1-SNAPSHOT
 ../../pom.xml
 
 org.apache.storm



[storm] Git Push Summary

2016-04-25 Thread ptgoetz
Repository: storm
Updated Tags:  refs/tags/v1.0.1 [deleted] f52c716ac


storm git commit: [maven-release-plugin] rollback the release of v1.0.1

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 0a12b2608 -> 2e9905675


[maven-release-plugin] rollback the release of v1.0.1


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2e990567
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2e990567
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2e990567

Branch: refs/heads/1.x-branch
Commit: 2e990567529f8a9759a39ffeb5da0c452d923f3b
Parents: 0a12b26
Author: P. Taylor Goetz 
Authored: Mon Apr 25 16:46:37 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 16:46:37 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/sql/pom.xml | 2 +-
 external/sql/storm-sql-core/pom.xml  | 2 +-
 external/sql/storm-sql-kafka/pom.xml | 2 +-
 external/sql/storm-sql-runtime/pom.xml   | 2 +-
 external/storm-cassandra/pom.xml | 2 +-
 external/storm-elasticsearch/pom.xml | 2 +-
 external/storm-eventhubs/pom.xml | 4 ++--
 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-client/pom.xml  | 2 +-
 external/storm-kafka/pom.xml | 2 +-
 external/storm-metrics/pom.xml   | 2 +-
 external/storm-mongodb/pom.xml   | 2 +-
 external/storm-mqtt/core/pom.xml | 2 +-
 external/storm-mqtt/examples/pom.xml | 2 +-
 external/storm-mqtt/pom.xml  | 2 +-
 external/storm-redis/pom.xml | 2 +-
 external/storm-solr/pom.xml  | 2 +-
 pom.xml  | 2 +-
 storm-buildtools/maven-shade-clojure-transformer/pom.xml | 2 +-
 storm-buildtools/storm-maven-plugins/pom.xml | 2 +-
 storm-core/pom.xml   | 2 +-
 storm-multilang/javascript/pom.xml   | 2 +-
 storm-multilang/python/pom.xml   | 2 +-
 storm-multilang/ruby/pom.xml | 2 +-
 storm-rename-hack/pom.xml| 2 +-
 33 files changed, 34 insertions(+), 34 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/2e990567/examples/storm-starter/pom.xml
--
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 62c262f..8e2ebfe 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
   
   storm
   org.apache.storm
-  1.0.2-SNAPSHOT
+  1.0.1-SNAPSHOT
   ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/storm/blob/2e990567/external/flux/flux-core/pom.xml
--
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index 3f86dbf..135ea56 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.2-SNAPSHOT
+1.0.1-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/2e990567/external/flux/flux-examples/pom.xml
--
diff --git a/external/flux/flux-examples/pom.xml 
b/external/flux/flux-examples/pom.xml
index 1edfaa3..2ba72df 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.2-SNAPSHOT
+1.0.1-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/2e990567/external/flux/flux-wrappers/pom.xml
--
diff --git a/external/flux/flux-wrappers/pom.xml 
b/external/flux/flux-wrappers/pom.xml
index 6f875ea..516f8a0 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.2-SNAPSHOT
+1.0.1-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/stor

storm git commit: [maven-release-plugin] prepare for next development iteration

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 7d9e01962 -> 0a12b2608


[maven-release-plugin] prepare for next development iteration


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0a12b260
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0a12b260
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0a12b260

Branch: refs/heads/1.x-branch
Commit: 0a12b2608bf0c92f0023d3d7c149dce9e96bd133
Parents: 7d9e019
Author: P. Taylor Goetz 
Authored: Mon Apr 25 16:40:12 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 16:40:12 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/sql/pom.xml | 2 +-
 external/sql/storm-sql-core/pom.xml  | 2 +-
 external/sql/storm-sql-kafka/pom.xml | 2 +-
 external/sql/storm-sql-runtime/pom.xml   | 2 +-
 external/storm-cassandra/pom.xml | 2 +-
 external/storm-elasticsearch/pom.xml | 2 +-
 external/storm-eventhubs/pom.xml | 4 ++--
 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-client/pom.xml  | 2 +-
 external/storm-kafka/pom.xml | 2 +-
 external/storm-metrics/pom.xml   | 2 +-
 external/storm-mongodb/pom.xml   | 2 +-
 external/storm-mqtt/core/pom.xml | 2 +-
 external/storm-mqtt/examples/pom.xml | 2 +-
 external/storm-mqtt/pom.xml  | 2 +-
 external/storm-redis/pom.xml | 2 +-
 external/storm-solr/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 +-
 storm-rename-hack/pom.xml| 2 +-
 35 files changed, 37 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/0a12b260/examples/storm-starter/pom.xml
--
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 788075e..62c262f 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
   
   storm
   org.apache.storm
-  1.0.1
+  1.0.2-SNAPSHOT
   ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/storm/blob/0a12b260/external/flux/flux-core/pom.xml
--
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index bbde342..3f86dbf 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1
+1.0.2-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/0a12b260/external/flux/flux-examples/pom.xml
--
diff --git a/external/flux/flux-examples/pom.xml 
b/external/flux/flux-examples/pom.xml
index 1a16e12..1edfaa3 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1
+1.0.2-SNAPSHOT
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/0a12b260/external/flux/flux-wrappers/pom.xml
--
diff --git a/external/flux/flux-wrappers/pom.xml 
b/external/flux/flux-wrappers/pom.xml
index af5aa15..6f875ea 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-  

[storm] Git Push Summary

2016-04-25 Thread ptgoetz
Repository: storm
Updated Tags:  refs/tags/v1.0.1 [created] f52c716ac


storm git commit: [maven-release-plugin] prepare release v1.0.1

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 70fdf486e -> 7d9e01962


[maven-release-plugin] prepare release v1.0.1


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/7d9e0196
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/7d9e0196
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/7d9e0196

Branch: refs/heads/1.x-branch
Commit: 7d9e019622e0ef8daa30e2be54744d7efc409201
Parents: 70fdf48
Author: P. Taylor Goetz 
Authored: Mon Apr 25 16:40:02 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 16:40: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/sql/pom.xml | 2 +-
 external/sql/storm-sql-core/pom.xml  | 2 +-
 external/sql/storm-sql-kafka/pom.xml | 2 +-
 external/sql/storm-sql-runtime/pom.xml   | 2 +-
 external/storm-cassandra/pom.xml | 2 +-
 external/storm-elasticsearch/pom.xml | 2 +-
 external/storm-eventhubs/pom.xml | 4 ++--
 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-client/pom.xml  | 2 +-
 external/storm-kafka/pom.xml | 2 +-
 external/storm-metrics/pom.xml   | 2 +-
 external/storm-mongodb/pom.xml   | 2 +-
 external/storm-mqtt/core/pom.xml | 2 +-
 external/storm-mqtt/examples/pom.xml | 2 +-
 external/storm-mqtt/pom.xml  | 2 +-
 external/storm-redis/pom.xml | 2 +-
 external/storm-solr/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 +-
 storm-rename-hack/pom.xml| 2 +-
 35 files changed, 37 insertions(+), 37 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/7d9e0196/examples/storm-starter/pom.xml
--
diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml
index 8e2ebfe..788075e 100644
--- a/examples/storm-starter/pom.xml
+++ b/examples/storm-starter/pom.xml
@@ -20,7 +20,7 @@
   
   storm
   org.apache.storm
-  1.0.1-SNAPSHOT
+  1.0.1
   ../../pom.xml
   
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7d9e0196/external/flux/flux-core/pom.xml
--
diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml
index 135ea56..bbde342 100644
--- a/external/flux/flux-core/pom.xml
+++ b/external/flux/flux-core/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT
+1.0.1
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7d9e0196/external/flux/flux-examples/pom.xml
--
diff --git a/external/flux/flux-examples/pom.xml 
b/external/flux/flux-examples/pom.xml
index 2ba72df..1a16e12 100644
--- a/external/flux/flux-examples/pom.xml
+++ b/external/flux/flux-examples/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT
+1.0.1
 ../pom.xml
 
 

http://git-wip-us.apache.org/repos/asf/storm/blob/7d9e0196/external/flux/flux-wrappers/pom.xml
--
diff --git a/external/flux/flux-wrappers/pom.xml 
b/external/flux/flux-wrappers/pom.xml
index 516f8a0..af5aa15 100644
--- a/external/flux/flux-wrappers/pom.xml
+++ b/external/flux/flux-wrappers/pom.xml
@@ -21,7 +21,7 @@
 
 org.apache.storm
 flux
-1.0.1-SNAPSHOT

[3/3] storm git commit: add STORM-1535 to changelog

2016-04-25 Thread ptgoetz
add STORM-1535 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/80aef130
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/80aef130
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/80aef130

Branch: refs/heads/0.10.x-branch
Commit: 80aef1306423a82e06f615c28643a426f73ae391
Parents: 534b388
Author: P. Taylor Goetz 
Authored: Mon Apr 25 15:46:22 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:46:22 2016 -0400

--
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/80aef130/CHANGELOG.md
--
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 74670d4..37a4b4b 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 0.10.1
+ * STORM-1535: Make sure hdfs key tab login happens only once for multiple 
bolts/executors
  * STORM-584: Fix logging for LoggingMetricsConsumer metrics.log file
  * STORM-1603: Storm UT fails on supervisor test in Windows (0.10.x)
  * STORM-1596: Do not use single Kerberos TGT instance between multiple threads



[2/3] storm git commit: STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors.

2016-04-25 Thread ptgoetz
STORM-1535: Make sure hdfs key tab login happens only once for multiple 
bolts/executors.

Signed-off-by: P. Taylor Goetz 


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/603a077a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/603a077a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/603a077a

Branch: refs/heads/0.10.x-branch
Commit: 603a077aec3d8b6495f0f84694c2d21577ae4520
Parents: 22b4543
Author: Priyank 
Authored: Thu Mar 31 12:46:25 2016 -0700
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:35:28 2016 -0400

--
 .../hdfs/common/security/HdfsSecurityUtil.java  | 25 
 1 file changed, 15 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/603a077a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index 86e7e3d..33fd0ec 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -28,6 +28,7 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import static backtype.storm.Config.TOPOLOGY_AUTO_CREDENTIALS;
 
@@ -40,23 +41,27 @@ public class HdfsSecurityUtil {
 public static final String STORM_USER_NAME_KEY = "hdfs.kerberos.principal";
 
 private static final Logger LOG = 
LoggerFactory.getLogger(HdfsSecurityUtil.class);
-
+private static AtomicBoolean isLoggedIn = new AtomicBoolean();
 public static void login(Map conf, Configuration hdfsConfig) throws 
IOException {
 //If AutoHDFS is specified, do not attempt to login using keytabs, 
only kept for backward compatibility.
 if(conf.get(TOPOLOGY_AUTO_CREDENTIALS) == null ||
 
(!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoHDFS.class.getName()))
 &&
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
-LOG.info("Logging in using keytab as AutoHDFS is not specified 
for " + TOPOLOGY_AUTO_CREDENTIALS);
-String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
-if (keytab != null) {
-hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
-}
-String userName = (String) conf.get(STORM_USER_NAME_KEY);
-if (userName != null) {
-hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+// compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
+// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
+if (isLoggedIn.compareAndSet(false, true)) {
+LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
+String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
+if (keytab != null) {
+hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
+}
+String userName = (String) conf.get(STORM_USER_NAME_KEY);
+if (userName != null) {
+hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+}
+SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
-SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
 }
 }



[1/3] storm git commit: STORM-1535: Removing the unnecessary comment.

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/0.10.x-branch 22b4543c7 -> 80aef1306


STORM-1535: Removing the unnecessary comment.

Signed-off-by: P. Taylor Goetz 


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/534b388a
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/534b388a
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/534b388a

Branch: refs/heads/0.10.x-branch
Commit: 534b388a179896c0876400107030350621f085a9
Parents: 603a077
Author: Priyank 
Authored: Thu Apr 21 10:10:26 2016 -0700
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:35:28 2016 -0400

--
 .../org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java | 1 -
 1 file changed, 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/534b388a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index 33fd0ec..569cb0c 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -49,7 +49,6 @@ public class HdfsSecurityUtil {
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
 // compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
-// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
 if (isLoggedIn.compareAndSet(false, true)) {
 LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
 String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);



[1/3] storm git commit: STORM-1535: Removing the unnecessary comment.

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch 49fade1f0 -> 70fdf486e


STORM-1535: Removing the unnecessary comment.

Signed-off-by: P. Taylor Goetz 


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/9ac4c3f3
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/9ac4c3f3
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/9ac4c3f3

Branch: refs/heads/1.x-branch
Commit: 9ac4c3f3c06a0d3f3e0bbbfe8b9eb6a44a32557a
Parents: 6ce8fa8
Author: Priyank 
Authored: Thu Apr 21 10:10:26 2016 -0700
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:28:49 2016 -0400

--
 .../org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java | 1 -
 1 file changed, 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/9ac4c3f3/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index d2f6273..f380b38 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -49,7 +49,6 @@ public class HdfsSecurityUtil {
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
 // compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
-// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
 if (isLoggedIn.compareAndSet(false, true)) {
 LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
 String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);



[2/3] storm git commit: STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors.

2016-04-25 Thread ptgoetz
STORM-1535: Make sure hdfs key tab login happens only once for multiple 
bolts/executors.

Signed-off-by: P. Taylor Goetz 


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/6ce8fa81
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/6ce8fa81
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/6ce8fa81

Branch: refs/heads/1.x-branch
Commit: 6ce8fa812301ddb727c9a6e7f40473e37b74f1a2
Parents: 49fade1
Author: Priyank 
Authored: Thu Mar 31 12:46:25 2016 -0700
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:28:49 2016 -0400

--
 .../hdfs/common/security/HdfsSecurityUtil.java  | 25 
 1 file changed, 15 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/6ce8fa81/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index 993214a..d2f6273 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -28,6 +28,7 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.apache.storm.Config.TOPOLOGY_AUTO_CREDENTIALS;
 
@@ -40,23 +41,27 @@ public class HdfsSecurityUtil {
 public static final String STORM_USER_NAME_KEY = "hdfs.kerberos.principal";
 
 private static final Logger LOG = 
LoggerFactory.getLogger(HdfsSecurityUtil.class);
-
+private static AtomicBoolean isLoggedIn = new AtomicBoolean();
 public static void login(Map conf, Configuration hdfsConfig) throws 
IOException {
 //If AutoHDFS is specified, do not attempt to login using keytabs, 
only kept for backward compatibility.
 if(conf.get(TOPOLOGY_AUTO_CREDENTIALS) == null ||
 
(!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoHDFS.class.getName()))
 &&
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
-LOG.info("Logging in using keytab as AutoHDFS is not specified 
for " + TOPOLOGY_AUTO_CREDENTIALS);
-String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
-if (keytab != null) {
-hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
-}
-String userName = (String) conf.get(STORM_USER_NAME_KEY);
-if (userName != null) {
-hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+// compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
+// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
+if (isLoggedIn.compareAndSet(false, true)) {
+LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
+String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
+if (keytab != null) {
+hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
+}
+String userName = (String) conf.get(STORM_USER_NAME_KEY);
+if (userName != null) {
+hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+}
+SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
-SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
 }
 }



[3/3] storm git commit: add STORM-1351 to changelog

2016-04-25 Thread ptgoetz
add STORM-1351 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/70fdf486
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/70fdf486
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/70fdf486

Branch: refs/heads/1.x-branch
Commit: 70fdf486eece628df78f939e5bd1119fdad0d565
Parents: 9ac4c3f
Author: P. Taylor Goetz 
Authored: Mon Apr 25 15:29:54 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:29:54 2016 -0400

--
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/70fdf486/CHANGELOG.md
--
diff --git a/CHANGELOG.md b/CHANGELOG.md
index fa6357e..8f83201 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 1.0.1
+ * STORM-1535: Make sure hdfs key tab login happens only once for multiple 
bolts/executors.
  * STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponential 
Backoff method should use HashMap instead of TreeMap not to throw Exception
  * STORM-1544: Document Debug/Sampling of Topologies
  * STORM-1679: add storm Scheduler documents



[1/4] storm git commit: STORM-1535: Make sure hdfs key tab login happens only once for multiple bolts/executors.

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/master 4e3c5bd54 -> 4ea884071


STORM-1535: Make sure hdfs key tab login happens only once for multiple 
bolts/executors.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/bc488c23
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/bc488c23
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/bc488c23

Branch: refs/heads/master
Commit: bc488c23420215db847fd8dde5a1006e319521de
Parents: 1a09da5
Author: Priyank 
Authored: Thu Mar 31 12:46:25 2016 -0700
Committer: Priyank 
Committed: Wed Apr 20 18:19:41 2016 -0700

--
 .../hdfs/common/security/HdfsSecurityUtil.java  | 25 
 1 file changed, 15 insertions(+), 10 deletions(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/bc488c23/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index 993214a..d2f6273 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -28,6 +28,7 @@ import org.slf4j.LoggerFactory;
 import java.io.IOException;
 import java.util.List;
 import java.util.Map;
+import java.util.concurrent.atomic.AtomicBoolean;
 
 import static org.apache.storm.Config.TOPOLOGY_AUTO_CREDENTIALS;
 
@@ -40,23 +41,27 @@ public class HdfsSecurityUtil {
 public static final String STORM_USER_NAME_KEY = "hdfs.kerberos.principal";
 
 private static final Logger LOG = 
LoggerFactory.getLogger(HdfsSecurityUtil.class);
-
+private static AtomicBoolean isLoggedIn = new AtomicBoolean();
 public static void login(Map conf, Configuration hdfsConfig) throws 
IOException {
 //If AutoHDFS is specified, do not attempt to login using keytabs, 
only kept for backward compatibility.
 if(conf.get(TOPOLOGY_AUTO_CREDENTIALS) == null ||
 
(!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoHDFS.class.getName()))
 &&
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
-LOG.info("Logging in using keytab as AutoHDFS is not specified 
for " + TOPOLOGY_AUTO_CREDENTIALS);
-String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
-if (keytab != null) {
-hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
-}
-String userName = (String) conf.get(STORM_USER_NAME_KEY);
-if (userName != null) {
-hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+// compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
+// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
+if (isLoggedIn.compareAndSet(false, true)) {
+LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
+String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);
+if (keytab != null) {
+hdfsConfig.set(STORM_KEYTAB_FILE_KEY, keytab);
+}
+String userName = (String) conf.get(STORM_USER_NAME_KEY);
+if (userName != null) {
+hdfsConfig.set(STORM_USER_NAME_KEY, userName);
+}
+SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
-SecurityUtil.login(hdfsConfig, STORM_KEYTAB_FILE_KEY, 
STORM_USER_NAME_KEY);
 }
 }
 }



[4/4] storm git commit: add STORM-1535 to changelog

2016-04-25 Thread ptgoetz
add STORM-1535 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/4ea88407
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/4ea88407
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/4ea88407

Branch: refs/heads/master
Commit: 4ea88407199af25282b84dbeed972659d62f161b
Parents: a3c0d5d
Author: P. Taylor Goetz 
Authored: Mon Apr 25 15:08:25 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:08:25 2016 -0400

--
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/4ea88407/CHANGELOG.md
--
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 9420e54..c2ab151 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 2.0.0
+ * STORM-1535: Make sure hdfs key tab login happens only once for multiple 
components
  * STORM-1544: Document Debug/Sampling of Topologies
  * STORM-1681: Bug in scheduling cyclic topologies when scheduling with RAS
  * STORM-1679: add storm Scheduler documents



[3/4] storm git commit: Merge branch 'STORM-1535' of github.com:priyank5485/storm

2016-04-25 Thread ptgoetz
Merge branch 'STORM-1535' of github.com:priyank5485/storm


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/a3c0d5d9
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/a3c0d5d9
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/a3c0d5d9

Branch: refs/heads/master
Commit: a3c0d5d99a4e2882e7647c97cd0919279bf0bf65
Parents: 4e3c5bd 87b0f3c
Author: P. Taylor Goetz 
Authored: Mon Apr 25 15:07:03 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:07:03 2016 -0400

--
 .../hdfs/common/security/HdfsSecurityUtil.java  | 24 
 1 file changed, 14 insertions(+), 10 deletions(-)
--




[2/4] storm git commit: STORM-1535: Removing the unnecessary comment.

2016-04-25 Thread ptgoetz
STORM-1535: Removing the unnecessary comment.


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/87b0f3c8
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/87b0f3c8
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/87b0f3c8

Branch: refs/heads/master
Commit: 87b0f3c895f54b87e0265f7f28984e0e3f310b58
Parents: bc488c2
Author: Priyank 
Authored: Thu Apr 21 10:10:26 2016 -0700
Committer: Priyank 
Committed: Thu Apr 21 10:10:26 2016 -0700

--
 .../org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java | 1 -
 1 file changed, 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/87b0f3c8/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
--
diff --git 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
index d2f6273..f380b38 100644
--- 
a/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
+++ 
b/external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/security/HdfsSecurityUtil.java
@@ -49,7 +49,6 @@ public class HdfsSecurityUtil {
  
!(((List)conf.get(TOPOLOGY_AUTO_CREDENTIALS)).contains(AutoTGT.class.getName()
 {
 if (UserGroupInformation.isSecurityEnabled()) {
 // compareAndSet added because of 
https://issues.apache.org/jira/browse/STORM-1535
-// need to test it first during ERIE release testing since the 
JIRA says "might" be and port it to apache.
 if (isLoggedIn.compareAndSet(false, true)) {
 LOG.info("Logging in using keytab as AutoHDFS is not 
specified for " + TOPOLOGY_AUTO_CREDENTIALS);
 String keytab = (String) conf.get(STORM_KEYTAB_FILE_KEY);



[2/2] storm git commit: add STORM-1725 to changelog

2016-04-25 Thread ptgoetz
add STORM-1725 to changelog


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/49fade1f
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/49fade1f
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/49fade1f

Branch: refs/heads/1.x-branch
Commit: 49fade1f0296cd5c077402670d46145c3458080b
Parents: 701a904
Author: P. Taylor Goetz 
Authored: Mon Apr 25 15:02:53 2016 -0400
Committer: P. Taylor Goetz 
Committed: Mon Apr 25 15:02:53 2016 -0400

--
 CHANGELOG.md | 1 +
 1 file changed, 1 insertion(+)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/49fade1f/CHANGELOG.md
--
diff --git a/CHANGELOG.md b/CHANGELOG.md
index 8898e3c..fa6357e 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,4 +1,5 @@
 ## 1.0.1
+ * STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponential 
Backoff method should use HashMap instead of TreeMap not to throw Exception
  * STORM-1544: Document Debug/Sampling of Topologies
  * STORM-1679: add storm Scheduler documents
  * STORM-1704: When logviewer_search.html opens daemon file, next search 
always show no result



[1/2] storm git commit: STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff method should use HashMap instead of TreeMap not to throw Exception - Replace TreeMap with HashMap

2016-04-25 Thread ptgoetz
Repository: storm
Updated Branches:
  refs/heads/1.x-branch ed2848fff -> 49fade1f0


STORM-1725: Kafka Spout New Consumer API - KafkaSpoutRetryExponentialBackoff 
method should use HashMap instead of TreeMap not to throw Exception
 - Replace TreeMap with HashMap


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/701a9045
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/701a9045
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/701a9045

Branch: refs/heads/1.x-branch
Commit: 701a9045f62e3a61f7021f79a765ea89c1afa69d
Parents: ed2848f
Author: Hugo Louro 
Authored: Fri Apr 22 10:16:31 2016 -0700
Committer: Hugo Louro 
Committed: Fri Apr 22 10:16:31 2016 -0700

--
 .../storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
--


http://git-wip-us.apache.org/repos/asf/storm/blob/701a9045/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
--
diff --git 
a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
 
b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
index 208cef4..78fd265 100644
--- 
a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
+++ 
b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java
@@ -162,7 +162,7 @@ public class KafkaSpoutRetryExponentialBackoff implements 
KafkaSpoutRetryService
 
 @Override
 public Set retriableTopicPartitions() {
-final Set tps = new TreeSet<>();
+final Set tps = new HashSet<>();
 final long currentTimeNanos = System.nanoTime();
 for (RetrySchedule retrySchedule : retrySchedules) {
 if (retrySchedule.retry(currentTimeNanos)) {