Auto assign uuid in the controller when missing.
Project: http://git-wip-us.apache.org/repos/asf/incubator-blur/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-blur/commit/33eeef09 Tree: http://git-wip-us.apache.org/repos/asf/incubator-blur/tree/33eeef09 Diff: http://git-wip-us.apache.org/repos/asf/incubator-blur/diff/33eeef09 Branch: refs/heads/master Commit: 33eeef09e6c11dcc65a3ca078ca8baf4a2722d60 Parents: 94cb92b Author: Aaron McCurry <[email protected]> Authored: Thu Aug 29 23:40:49 2013 -0400 Committer: Aaron McCurry <[email protected]> Committed: Thu Aug 29 23:40:49 2013 -0400 ---------------------------------------------------------------------- .../main/java/org/apache/blur/thrift/BlurControllerServer.java | 4 ++++ 1 file changed, 4 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-blur/blob/33eeef09/blur-core/src/main/java/org/apache/blur/thrift/BlurControllerServer.java ---------------------------------------------------------------------- diff --git a/blur-core/src/main/java/org/apache/blur/thrift/BlurControllerServer.java b/blur-core/src/main/java/org/apache/blur/thrift/BlurControllerServer.java index 0602367..1376898 100644 --- a/blur-core/src/main/java/org/apache/blur/thrift/BlurControllerServer.java +++ b/blur-core/src/main/java/org/apache/blur/thrift/BlurControllerServer.java @@ -24,6 +24,7 @@ import java.util.HashMap; import java.util.HashSet; import java.util.List; import java.util.Map; +import java.util.UUID; import java.util.Map.Entry; import java.util.Set; import java.util.TreeSet; @@ -310,6 +311,9 @@ public class BlurControllerServer extends TableAdmin implements Iface { _queryChecker.checkQuery(blurQuery); checkSelectorFetchSize(blurQuery.getSelector()); int shardCount = _clusterStatus.getShardCount(true, cluster, table); + if (blurQuery.getUuid() == null) { + blurQuery.setUuid(UUID.randomUUID().toString()); + } OUTER: for (int retries = 0; retries < _maxDefaultRetries; retries++) { try {
