Repository: storm Updated Branches: refs/heads/master 8ba90e9fa -> 559053dec
Quick Fix: fix storm-cassandra to not exceed current max violation count Project: http://git-wip-us.apache.org/repos/asf/storm/repo Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/2dd79db3 Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/2dd79db3 Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/2dd79db3 Branch: refs/heads/master Commit: 2dd79db30a360d1f899c54c18873a41a74dfd5a4 Parents: 8ba90e9 Author: Jungtaek Lim <kabh...@gmail.com> Authored: Thu Jul 13 00:53:53 2017 +0900 Committer: Jungtaek Lim <kabh...@gmail.com> Committed: Thu Jul 13 00:53:53 2017 +0900 ---------------------------------------------------------------------- .../org/apache/storm/cassandra/AbstractExecutionResultHandler.java | 1 + .../java/org/apache/storm/cassandra/BaseExecutionResultHandler.java | 1 + .../src/main/java/org/apache/storm/cassandra/CassandraContext.java | 1 + .../java/org/apache/storm/cassandra/DynamicStatementBuilder.java | 1 + .../java/org/apache/storm/cassandra/ExecutionResultHandler.java | 1 + .../main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java | 1 + 6 files changed, 6 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java index cf68c4f..6510565 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/AbstractExecutionResultHandler.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import org.apache.storm.task.OutputCollector; http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java index 18f9ebf..59b6343 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/BaseExecutionResultHandler.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import org.apache.storm.task.OutputCollector; http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java index 9e06a53..e862755 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/CassandraContext.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import com.datastax.driver.core.Cluster; http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java index 4a98632..2bd7107 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/DynamicStatementBuilder.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import com.datastax.driver.core.BatchStatement; http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java index ac3c76e..6113efb 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/ExecutionResultHandler.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import org.apache.storm.task.OutputCollector; http://git-wip-us.apache.org/repos/asf/storm/blob/2dd79db3/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java ---------------------------------------------------------------------- diff --git a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java index 5d67796..9fbed68 100644 --- a/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java +++ b/external/storm-cassandra/src/main/java/org/apache/storm/cassandra/Murmur3StreamGrouping.java @@ -16,6 +16,7 @@ * specific language governing permissions and limitations * under the License. */ + package org.apache.storm.cassandra; import org.apache.storm.generated.GlobalStreamId;
