[3/3] storm git commit: add STORM-1434 to CHANGELOG
add STORM-1434 to CHANGELOG Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/067c79cf Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/067c79cf Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/067c79cf Branch: refs/heads/1.x-branch Commit: 067c79cf9d3a9af11e1723704b51b3f86617a5b9 Parents: 0226dd4 Author: Jungtaek Lim Authored: Thu Aug 25 07:02:24 2016 +0900 Committer: Jungtaek Lim Committed: Thu Aug 25 07:02:24 2016 +0900 -- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/storm/blob/067c79cf/CHANGELOG.md -- diff --git a/CHANGELOG.md b/CHANGELOG.md index 88c4332..12cb157 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -1,4 +1,5 @@ ## 1.1.0 + * STORM-1434: Support the GROUP BY clause in StormSQL * STORM-2016: Topology submission improvement: support adding local jars and maven artifacts on submission * STORM-1994: Add table with per-topology & worker resource usage and components in (new) supervisor and topology pages * STORM-2042: Nimbus client connections not closed properly causing connection leaks
[1/4] storm git commit: STORM-1434 Support the GROUP BY clause in StormSQL
Repository: storm
Updated Branches:
refs/heads/master 0b080fcf6 -> 989b00811
http://git-wip-us.apache.org/repos/asf/storm/blob/28eefbef/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
--
diff --git
a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
new file mode 100644
index 000..ced4201
--- /dev/null
+++
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
@@ -0,0 +1,68 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.storm.sql.runtime.trident.operations;
+
+import clojure.lang.Numbers;
+import org.apache.storm.sql.runtime.trident.NumberConverter;
+import org.apache.storm.sql.runtime.trident.TridentUtils;
+import org.apache.storm.trident.operation.CombinerAggregator;
+import org.apache.storm.trident.tuple.TridentTuple;
+
+public class MinBy implements CombinerAggregator {
+
+private final String inputFieldName;
+private final Class targetClazz;
+
+public MinBy(String inputFieldName, Class targetClazz) {
+this.inputFieldName = inputFieldName;
+this.targetClazz = targetClazz;
+}
+
+@Override
+public Object init(TridentTuple tuple) {
+return TridentUtils.valueFromTuple(tuple, inputFieldName);
+}
+
+@Override
+public Object combine(Object val1, Object val2) {
+if (val1 == null) {
+return val2;
+}
+
+if (Number.class.isAssignableFrom(targetClazz)) {
+return NumberConverter.convert((Number) Numbers.min(val1, val2),
(Class) targetClazz);
+}
+
+if (!val1.getClass().equals(val2.getClass())) {
+throw new IllegalArgumentException("The type of values are
different! - class of val1: " +
+val1.getClass().getCanonicalName() + " and class of val2:
" +
+val2.getClass().getCanonicalName());
+} else if (!(val1 instanceof Comparable)) {
+throw new IllegalArgumentException("Value is not Comparable -
class of value: " +
+val1.getClass().getCanonicalName());
+}
+
+return ((Comparable)val1).compareTo(val2) > 0 ? val2 : val1;
+}
+
+@Override
+public Object zero() {
+return null;
+}
+}
http://git-wip-us.apache.org/repos/asf/storm/blob/28eefbef/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
--
diff --git
a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
new file mode 100644
index 000..77300c3
--- /dev/null
+++
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
@@ -0,0 +1,60 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.storm.sql.runtime.trident.operations;
+
+import clojure.lang.Numbers;
+import org.apache.storm.sql.runtime.trident.NumberConverter;
+import org.apache.storm.sql.runtime.trident.TridentUtils;
+import org.apache.storm.trident.operation.CombinerAggregator;
+
[2/4] storm git commit: STORM-1434 Support the GROUP BY clause in StormSQL
STORM-1434 Support the GROUP BY clause in StormSQL * Support GROUP BY for Trident * Implement basic functions for aggregation * Change the way of converting Calcite logical plan to Trident logical plan ** before: creating codes and compile them ** after: use Trident features, only creating code block if evaluation is needed *** Janino comes in to help evaluating code block in runtime * expand PostOrderRelNodeVisitor to be generalized version of TridentPostOrderRelNodeVisitor * Change the way to join results of aggregation functions via chaining ** Trident handles chained aggregator via applying each tuple to all aggregators, get rid of multiple reading for input tuples * Remove the empty check for tuple ** Crash fast if input fields for aggregation / function is not set rather than giving wrong result * add comment why we package empty topology and how sql topology works * Add test for scalar UDF with Trident Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/28eefbef Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/28eefbef Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/28eefbef Branch: refs/heads/master Commit: 28eefbef90900f715e19a55da9d48fcec1f32947 Parents: da5c3ac Author: Jungtaek Lim Authored: Thu Aug 18 16:32:46 2016 +0900 Committer: Jungtaek Lim Committed: Thu Aug 25 06:58:38 2016 +0900 -- external/sql/README.md | 6 +- external/sql/storm-sql-core/pom.xml | 5 + .../jvm/org/apache/storm/sql/StormSqlImpl.java | 19 +- .../apache/storm/sql/compiler/ExprCompiler.java | 16 +- .../sql/compiler/PostOrderRelNodeVisitor.java | 100 ++--- .../backends/standalone/RelNodeCompiler.java| 14 +- .../compiler/backends/trident/PlanCompiler.java | 222 +++- .../backends/trident/RelNodeCompiler.java | 116 -- .../trident/TridentLogicalPlanCompiler.java | 363 +++ .../storm/sql/compiler/TestCompilerUtils.java | 32 +- .../storm/sql/compiler/TestExprCompiler.java| 2 +- .../standalone/TestRelNodeCompiler.java | 7 +- .../backends/trident/TestPlanCompiler.java | 62 +++- external/sql/storm-sql-runtime/pom.xml | 5 + .../sql/runtime/trident/NumberConverter.java| 47 +++ .../storm/sql/runtime/trident/TridentUtils.java | 35 ++ .../trident/functions/EvaluationFilter.java | 62 .../trident/functions/EvaluationFunction.java | 64 .../trident/functions/ForwardFunction.java | 30 ++ .../sql/runtime/trident/operations/CountBy.java | 53 +++ .../trident/operations/DivideForAverage.java| 45 +++ .../sql/runtime/trident/operations/MaxBy.java | 68 .../sql/runtime/trident/operations/MinBy.java | 68 .../sql/runtime/trident/operations/SumBy.java | 60 +++ .../test/org/apache/storm/sql/TestUtils.java| 74 pom.xml | 7 + 26 files changed, 1211 insertions(+), 371 deletions(-) -- http://git-wip-us.apache.org/repos/asf/storm/blob/28eefbef/external/sql/README.md -- diff --git a/external/sql/README.md b/external/sql/README.md index 6f68951..66b2185 100644 --- a/external/sql/README.md +++ b/external/sql/README.md @@ -19,6 +19,7 @@ The following features are supported in the current repository: * Streaming from and to external data sources * Filtering tuples * Projections +* Aggregations (Grouping) ## Specifying External Data Sources @@ -87,8 +88,7 @@ By now you should be able to see the `order_filtering` topology in the Storm UI. ## Current Limitations -Aggregation, windowing and joining tables are yet to be implemented. Specifying parallelism hints in the topology is not -yet supported. +Windowing and joining tables are yet to be implemented. Specifying parallelism hints in the topology is not yet supported. Supported aggregation functions are 'SUM', 'AVG', 'COUNT', 'MIN', 'MAX'. (Planned to address UDF - user defined functions.) Users also need to provide the dependency of the external data sources in the `extlib` directory. Otherwise the topology will fail to run because of `ClassNotFoundException`. @@ -114,4 +114,4 @@ under the License. ## Committer Sponsors * Sriharsha Chintalapani ([srihar...@apache.org](mailto:srihar...@apache.org)) - * P. Taylor Goetz ([ptgo...@apache.org](mailto:ptgo...@apache.org)) + * P. Taylor Goetz ([ptgo...@apache.org](mailto:ptgo...@apache.org)) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/storm/blob/28eefbef/external/sql/storm-sql-core/pom.xml -- diff --git a/external/sql/storm-sql-core/pom.xml b/external/sql/storm-sql-core/pom.xml index 8a9e313..d9a6098 100644 --
[1/3] storm git commit: STORM-1434 Support the GROUP BY clause in StormSQL
Repository: storm
Updated Branches:
refs/heads/1.x-branch a3090d313 -> 067c79cf9
http://git-wip-us.apache.org/repos/asf/storm/blob/0226dd4f/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
--
diff --git
a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
new file mode 100644
index 000..ced4201
--- /dev/null
+++
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/MinBy.java
@@ -0,0 +1,68 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.storm.sql.runtime.trident.operations;
+
+import clojure.lang.Numbers;
+import org.apache.storm.sql.runtime.trident.NumberConverter;
+import org.apache.storm.sql.runtime.trident.TridentUtils;
+import org.apache.storm.trident.operation.CombinerAggregator;
+import org.apache.storm.trident.tuple.TridentTuple;
+
+public class MinBy implements CombinerAggregator {
+
+private final String inputFieldName;
+private final Class targetClazz;
+
+public MinBy(String inputFieldName, Class targetClazz) {
+this.inputFieldName = inputFieldName;
+this.targetClazz = targetClazz;
+}
+
+@Override
+public Object init(TridentTuple tuple) {
+return TridentUtils.valueFromTuple(tuple, inputFieldName);
+}
+
+@Override
+public Object combine(Object val1, Object val2) {
+if (val1 == null) {
+return val2;
+}
+
+if (Number.class.isAssignableFrom(targetClazz)) {
+return NumberConverter.convert((Number) Numbers.min(val1, val2),
(Class) targetClazz);
+}
+
+if (!val1.getClass().equals(val2.getClass())) {
+throw new IllegalArgumentException("The type of values are
different! - class of val1: " +
+val1.getClass().getCanonicalName() + " and class of val2:
" +
+val2.getClass().getCanonicalName());
+} else if (!(val1 instanceof Comparable)) {
+throw new IllegalArgumentException("Value is not Comparable -
class of value: " +
+val1.getClass().getCanonicalName());
+}
+
+return ((Comparable)val1).compareTo(val2) > 0 ? val2 : val1;
+}
+
+@Override
+public Object zero() {
+return null;
+}
+}
http://git-wip-us.apache.org/repos/asf/storm/blob/0226dd4f/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
--
diff --git
a/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
new file mode 100644
index 000..77300c3
--- /dev/null
+++
b/external/sql/storm-sql-runtime/src/jvm/org/apache/storm/sql/runtime/trident/operations/SumBy.java
@@ -0,0 +1,60 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.storm.sql.runtime.trident.operations;
+
+import clojure.lang.Numbers;
+import org.apache.storm.sql.runtime.trident.NumberConverter;
+import org.apache.storm.sql.runtime.trident.TridentUtils;
+import org.apache.storm.trident.operation.CombinerAggregato
[2/3] storm git commit: STORM-1434 Support the GROUP BY clause in StormSQL
STORM-1434 Support the GROUP BY clause in StormSQL * Support GROUP BY for Trident * Implement basic functions for aggregation * Change the way of converting Calcite logical plan to Trident logical plan ** before: creating codes and compile them ** after: use Trident features, only creating code block if evaluation is needed *** Janino comes in to help evaluating code block in runtime * expand PostOrderRelNodeVisitor to be generalized version of TridentPostOrderRelNodeVisitor * Change the way to join results of aggregation functions via chaining ** Trident handles chained aggregator via applying each tuple to all aggregators, get rid of multiple reading for input tuples * Remove the empty check for tuple ** Crash fast if input fields for aggregation / function is not set rather than giving wrong result * add comment why we package empty topology and how sql topology works * Add test for scalar UDF with Trident Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/0226dd4f Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/0226dd4f Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/0226dd4f Branch: refs/heads/1.x-branch Commit: 0226dd4f985d6bb5266965a04fec0787763e2ac4 Parents: a3090d3 Author: Jungtaek Lim Authored: Thu Aug 18 16:32:46 2016 +0900 Committer: Jungtaek Lim Committed: Thu Aug 25 07:02:09 2016 +0900 -- external/sql/README.md | 6 +- external/sql/storm-sql-core/pom.xml | 5 + .../jvm/org/apache/storm/sql/StormSqlImpl.java | 19 +- .../apache/storm/sql/compiler/ExprCompiler.java | 16 +- .../sql/compiler/PostOrderRelNodeVisitor.java | 100 ++--- .../backends/standalone/RelNodeCompiler.java| 14 +- .../compiler/backends/trident/PlanCompiler.java | 222 +++- .../backends/trident/RelNodeCompiler.java | 116 -- .../trident/TridentLogicalPlanCompiler.java | 363 +++ .../storm/sql/compiler/TestCompilerUtils.java | 32 +- .../storm/sql/compiler/TestExprCompiler.java| 2 +- .../standalone/TestRelNodeCompiler.java | 7 +- .../backends/trident/TestPlanCompiler.java | 62 +++- external/sql/storm-sql-runtime/pom.xml | 5 + .../sql/runtime/trident/NumberConverter.java| 47 +++ .../storm/sql/runtime/trident/TridentUtils.java | 35 ++ .../trident/functions/EvaluationFilter.java | 62 .../trident/functions/EvaluationFunction.java | 64 .../trident/functions/ForwardFunction.java | 30 ++ .../sql/runtime/trident/operations/CountBy.java | 53 +++ .../trident/operations/DivideForAverage.java| 45 +++ .../sql/runtime/trident/operations/MaxBy.java | 68 .../sql/runtime/trident/operations/MinBy.java | 68 .../sql/runtime/trident/operations/SumBy.java | 60 +++ .../test/org/apache/storm/sql/TestUtils.java| 74 pom.xml | 7 + 26 files changed, 1211 insertions(+), 371 deletions(-) -- http://git-wip-us.apache.org/repos/asf/storm/blob/0226dd4f/external/sql/README.md -- diff --git a/external/sql/README.md b/external/sql/README.md index 2ac44a5..b22a79c 100644 --- a/external/sql/README.md +++ b/external/sql/README.md @@ -19,6 +19,7 @@ The following features are supported in the current repository: * Streaming from and to external data sources * Filtering tuples * Projections +* Aggregations (Grouping) ## Specifying External Data Sources @@ -79,8 +80,7 @@ By now you should be able to see the `order_filtering` topology in the Storm UI. ## Current Limitations -Aggregation, windowing and joining tables are yet to be implemented. Specifying parallelism hints in the topology is not -yet supported. +Windowing and joining tables are yet to be implemented. Specifying parallelism hints in the topology is not yet supported. Supported aggregation functions are 'SUM', 'AVG', 'COUNT', 'MIN', 'MAX'. (Planned to address UDF - user defined functions.) Users also need to provide the dependency of the external data sources in the `extlib` directory. Otherwise the topology will fail to run because of `ClassNotFoundException`. @@ -106,4 +106,4 @@ under the License. ## Committer Sponsors * Sriharsha Chintalapani ([srihar...@apache.org](mailto:srihar...@apache.org)) - * P. Taylor Goetz ([ptgo...@apache.org](mailto:ptgo...@apache.org)) + * P. Taylor Goetz ([ptgo...@apache.org](mailto:ptgo...@apache.org)) \ No newline at end of file http://git-wip-us.apache.org/repos/asf/storm/blob/0226dd4f/external/sql/storm-sql-core/pom.xml -- diff --git a/external/sql/storm-sql-core/pom.xml b/external/sql/storm-sql-core/pom.xml index d76a253..2e52be2 10064
[3/4] storm git commit: Merge branch 'STORM-1434'
Merge branch 'STORM-1434' Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/64fb1b1a Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/64fb1b1a Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/64fb1b1a Branch: refs/heads/master Commit: 64fb1b1a1c09f79dbb1ed919b786e20c0d4a358d Parents: 0b080fc 28eefbe Author: Jungtaek Lim Authored: Thu Aug 25 07:00:56 2016 +0900 Committer: Jungtaek Lim Committed: Thu Aug 25 07:00:56 2016 +0900 -- external/sql/README.md | 6 +- external/sql/storm-sql-core/pom.xml | 5 + .../jvm/org/apache/storm/sql/StormSqlImpl.java | 19 +- .../apache/storm/sql/compiler/ExprCompiler.java | 16 +- .../sql/compiler/PostOrderRelNodeVisitor.java | 100 ++--- .../backends/standalone/RelNodeCompiler.java| 14 +- .../compiler/backends/trident/PlanCompiler.java | 222 +++- .../backends/trident/RelNodeCompiler.java | 116 -- .../trident/TridentLogicalPlanCompiler.java | 363 +++ .../storm/sql/compiler/TestCompilerUtils.java | 32 +- .../storm/sql/compiler/TestExprCompiler.java| 2 +- .../standalone/TestRelNodeCompiler.java | 7 +- .../backends/trident/TestPlanCompiler.java | 62 +++- external/sql/storm-sql-runtime/pom.xml | 5 + .../sql/runtime/trident/NumberConverter.java| 47 +++ .../storm/sql/runtime/trident/TridentUtils.java | 35 ++ .../trident/functions/EvaluationFilter.java | 62 .../trident/functions/EvaluationFunction.java | 64 .../trident/functions/ForwardFunction.java | 30 ++ .../sql/runtime/trident/operations/CountBy.java | 53 +++ .../trident/operations/DivideForAverage.java| 45 +++ .../sql/runtime/trident/operations/MaxBy.java | 68 .../sql/runtime/trident/operations/MinBy.java | 68 .../sql/runtime/trident/operations/SumBy.java | 60 +++ .../test/org/apache/storm/sql/TestUtils.java| 74 pom.xml | 7 + 26 files changed, 1211 insertions(+), 371 deletions(-) -- http://git-wip-us.apache.org/repos/asf/storm/blob/64fb1b1a/external/sql/README.md -- http://git-wip-us.apache.org/repos/asf/storm/blob/64fb1b1a/pom.xml --
[4/4] storm git commit: add STORM-1434 to CHANGELOG
add STORM-1434 to CHANGELOG Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/989b0081 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/989b0081 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/989b0081 Branch: refs/heads/master Commit: 989b00811f631a7bfedb0f8ee6888efd4637e562 Parents: 64fb1b1 Author: Jungtaek Lim Authored: Thu Aug 25 07:01:21 2016 +0900 Committer: Jungtaek Lim Committed: Thu Aug 25 07:01:21 2016 +0900 -- CHANGELOG.md | 1 + 1 file changed, 1 insertion(+) -- http://git-wip-us.apache.org/repos/asf/storm/blob/989b0081/CHANGELOG.md -- diff --git a/CHANGELOG.md b/CHANGELOG.md index f6cbcd2..11968f0 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -144,6 +144,7 @@ * STORM-1769: Added a test to check local nimbus with notifier plugin ## 1.1.0 + * STORM-1434: Support the GROUP BY clause in StormSQL * STORM-2016: Topology submission improvement: support adding local jars and maven artifacts on submission * STORM-1994: Add table with per-topology & worker resource usage and components in (new) supervisor and topology pages * STORM-2023: Add calcite-core to dependency of storm-sql-runtime
svn commit: r14936 - /dev/storm/apache-storm-0.10.2-rc1/
Author: ptgoetz Date: Wed Aug 24 19:54:24 2016 New Revision: 14936 Log: stage 0.10.2 rc1 release Added: dev/storm/apache-storm-0.10.2-rc1/ dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz (with props) dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.asc dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.md5 dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.sha dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip (with props) dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.asc dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.md5 dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.sha dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.tar.gz (with props) dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.tar.gz.asc dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.tar.gz.md5 dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.tar.gz.sha dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.zip (with props) dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.zip.asc dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.zip.md5 dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2.zip.sha Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz == Binary file - no diff available. Propchange: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz -- svn:mime-type = application/octet-stream Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.asc == --- dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.asc (added) +++ dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.asc Wed Aug 24 19:54:24 2016 @@ -0,0 +1,11 @@ +-BEGIN PGP SIGNATURE- +Comment: GPGTools - https://gpgtools.org + +iQEcBAABCgAGBQJXvfl3AAoJEI3gOWLoC4/9iocH/Rly49qAEtzAHPR5DP8WExBj +UbbzGGbEIOm/tUH/UdjO7HHcobYhyzGG1gS4700BqP5lwVkQSIJlNHBxguoLPlYc +6wJd3gWKcLENwVROECKHWJQf718KsIT2O3xiK7l4nRvqpVsNI97CjTP8N0hKgUWe +0347UmLc553NIoazeAIrhyZ/NTOh+NVASm1tX5ja8tKeIab8n582SmQNseqLGCeE +cav1elIJ36i/FqXOdcfcfuTL+f4lbyWUBy2PBUeWcbEMt2wzgYRFDZmmn4TYj/PH +SL4rv32Q9er0Ezd+foFZmgUEW+vsq54DFezqTbgQ6kBpODXbWagMPi0A+Frle30= +=QauD +-END PGP SIGNATURE- Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.md5 == --- dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.md5 (added) +++ dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.md5 Wed Aug 24 19:54:24 2016 @@ -0,0 +1 @@ +apache-storm-0.10.2-src.tar.gz: 65 53 23 B3 A1 43 B4 D5 04 C8 AB 63 DB F7 A8 0C Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.sha == --- dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.sha (added) +++ dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.tar.gz.sha Wed Aug 24 19:54:24 2016 @@ -0,0 +1,4 @@ +apache-storm-0.10.2-src.tar.gz: FED5B662 449EA4B9 FD550CE5 5E60BDDA BDF28E87 +7EC99406 B2829463 6F1A1804 0F6A4F0C 1772E948 +AFAE00BF 0B3A8AB4 CBE2A3AC D15AF812 3B7E6F6E +3BB1B534 Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip == Binary file - no diff available. Propchange: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip -- svn:mime-type = application/octet-stream Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.asc == --- dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.asc (added) +++ dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.asc Wed Aug 24 19:54:24 2016 @@ -0,0 +1,11 @@ +-BEGIN PGP SIGNATURE- +Comment: GPGTools - https://gpgtools.org + +iQEcBAABCgAGBQJXvfl3AAoJEI3gOWLoC4/99xgH/1zIsiBNpD29Xi803ycSLhPO +LZplkpvGZgXVCL36yaweDn0jg9ukPt3Kjk92az0Ozs5svVhIDJRgQXdfQW9oRASZ +U4cYJZ5Qva2e1C9gZtckZkrxXh8VbzxQUwEVnQ3sQGhrm7RhosnbZM3T1H+5byZp +VBJckByCfV5oBU/4kGddPHXVgjJOKz4WC+fBb9nNpBqFS5rKs2A924/nYhgIH6vf +cNVG/rL89uHP48SP19PdG/kcT2PqvcJ8iRl9WegS6txh7zwFGrOAjcvwtlYdeU+6 +d09uTEh4Ylc0kAnbAgGHBfIbbfTgKU19ue2St2rU1hwbTJT0XbBT37Q28OJd1wc= +=79Zg +-END PGP SIGNATURE- Added: dev/storm/apache-storm-0.10.2-rc1/apache-storm-0.10.2-src.zip.md5 == ---
storm git commit: [maven-release-plugin] prepare for next development iteration
Repository: storm Updated Branches: refs/heads/0.10.x-branch 3c24dce8b -> 152147648 [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/15214764 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/15214764 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/15214764 Branch: refs/heads/0.10.x-branch Commit: 152147648e9d362d8ed4930fbb3364842821bacb Parents: 3c24dce Author: P. Taylor Goetz Authored: Wed Aug 24 15:08:01 2016 -0400 Committer: P. Taylor Goetz Committed: Wed Aug 24 15:08:01 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/15214764/examples/storm-starter/pom.xml -- diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml index 1dc232f..36dd602 100644 --- a/examples/storm-starter/pom.xml +++ b/examples/storm-starter/pom.xml @@ -20,7 +20,7 @@ storm org.apache.storm - 0.10.2 + 0.10.3-SNAPSHOT ../../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/15214764/external/flux/flux-core/pom.xml -- diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml index 1430f90..d5f970b 100644 --- a/external/flux/flux-core/pom.xml +++ b/external/flux/flux-core/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2 +0.10.3-SNAPSHOT ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/15214764/external/flux/flux-examples/pom.xml -- diff --git a/external/flux/flux-examples/pom.xml b/external/flux/flux-examples/pom.xml index 423a81b..3b29a87 100644 --- a/external/flux/flux-examples/pom.xml +++ b/external/flux/flux-examples/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2 +0.10.3-SNAPSHOT ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/15214764/external/flux/flux-wrappers/pom.xml -- diff --git a/external/flux/flux-wrappers/pom.xml b/external/flux/flux-wrappers/pom.xml index 8aaacc9..e1f414b 100644 --- a/external/flux/flux-wrappers/pom.xml +++ b/external/flux/flux-wrappers/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2 +0.10.3-SNAPSHOT ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/15214764/external/flux/pom.xml -- diff --git a/external/flux/pom.xml b/external/flux/pom.xml index caf6fe8..3632ca0 100644 --- a/external/flux/pom.xml +++ b/external/flux/pom.xml @@ -26,7 +26,7 @@ storm org.apache.storm -0.10.2 +0.10.3-SNAPSHOT ../../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/15214764/external/storm-eventhubs/pom.xml -- diff --git a/external/storm-eventhubs/pom.xml b/external/storm-eventhubs/pom.xml index 11df016..da8761b 100755 --- a/external/storm-eventhubs/pom.xml +++ b/external/storm-eventhubs/pom.xml @@ -21,7 +21,7 @@ storm or
storm git commit: [maven-release-plugin] prepare release v0.10.2
Repository: storm Updated Branches: refs/heads/0.10.x-branch 711174585 -> 3c24dce8b [maven-release-plugin] prepare release v0.10.2 Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/3c24dce8 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/3c24dce8 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/3c24dce8 Branch: refs/heads/0.10.x-branch Commit: 3c24dce8b35527b409cae68a1ebc0e25e5a0b03f Parents: 7111745 Author: P. Taylor Goetz Authored: Wed Aug 24 15:07:53 2016 -0400 Committer: P. Taylor Goetz Committed: Wed Aug 24 15:07:53 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/3c24dce8/examples/storm-starter/pom.xml -- diff --git a/examples/storm-starter/pom.xml b/examples/storm-starter/pom.xml index 978ac53..1dc232f 100644 --- a/examples/storm-starter/pom.xml +++ b/examples/storm-starter/pom.xml @@ -20,7 +20,7 @@ storm org.apache.storm - 0.10.2-SNAPSHOT + 0.10.2 ../../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/3c24dce8/external/flux/flux-core/pom.xml -- diff --git a/external/flux/flux-core/pom.xml b/external/flux/flux-core/pom.xml index 3427349..1430f90 100644 --- a/external/flux/flux-core/pom.xml +++ b/external/flux/flux-core/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2-SNAPSHOT +0.10.2 ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/3c24dce8/external/flux/flux-examples/pom.xml -- diff --git a/external/flux/flux-examples/pom.xml b/external/flux/flux-examples/pom.xml index b9ab3ad..423a81b 100644 --- a/external/flux/flux-examples/pom.xml +++ b/external/flux/flux-examples/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2-SNAPSHOT +0.10.2 ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/3c24dce8/external/flux/flux-wrappers/pom.xml -- diff --git a/external/flux/flux-wrappers/pom.xml b/external/flux/flux-wrappers/pom.xml index ba12309..8aaacc9 100644 --- a/external/flux/flux-wrappers/pom.xml +++ b/external/flux/flux-wrappers/pom.xml @@ -21,7 +21,7 @@ org.apache.storm flux -0.10.2-SNAPSHOT +0.10.2 ../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/3c24dce8/external/flux/pom.xml -- diff --git a/external/flux/pom.xml b/external/flux/pom.xml index 932791a..caf6fe8 100644 --- a/external/flux/pom.xml +++ b/external/flux/pom.xml @@ -26,7 +26,7 @@ storm org.apache.storm -0.10.2-SNAPSHOT +0.10.2 ../../pom.xml http://git-wip-us.apache.org/repos/asf/storm/blob/3c24dce8/external/storm-eventhubs/pom.xml -- diff --git a/external/storm-eventhubs/pom.xml b/external/storm-eventhubs/pom.xml index 5c5c1fe..11df016 100755 --- a/external/storm-eventhubs/pom.xml +++ b/external/storm-eventhubs/pom.xml @@ -21,7 +21,7 @@ storm org.apache.storm
[storm] Git Push Summary
Repository: storm Updated Tags: refs/tags/v0.10.2 [created] 318c5d2b7
