commit 7f8041832f169a393f60ab2794158a79dff86de7
author Murtadha Hubail <mhubail@apache.org> Mon Oct 12 10:26:40 2020 +0300
committer Murtadha Hubail <mhubail@apache.org> Tue Oct 13 19:21:36 2020 +0000
tree 75430e6b0f4977c64257586e79c95bbd9c645c55
parent a10f414b9b2715132d036737348afb6f6c5d3a81

[NO ISSUE][MTD] Return Nodegroup nodes in a sorted ordered

- user model changes: no
- storage format changes: no
- interface changes: no

Details:

- Return nodegroups list of nodes in a sorted order. This
  ensures that datasets created on the same set of nodes
  will have the same location constraints order.
- Improve logging when an index is not found.

Change-Id: I9878aac19d64e57c473428f86e8858c06104712c
Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/8364
Integration-Tests: Jenkins <jenkins@fulliautomatix.ics.uci.edu>
Reviewed-by: Murtadha Hubail <mhubail@apache.org>
Reviewed-by: Dmitry Lychagin <dmitry.lychagin@couchbase.com>
Tested-by: Murtadha Hubail <mhubail@apache.org>
Tested-by: Jenkins <jenkins@fulliautomatix.ics.uci.edu>

asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java

diff --git a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java
index 8a7d5ec..1c4ec64 100644
--- a/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java
+++ b/asterixdb/asterix-metadata/src/main/java/org/apache/asterix/metadata/entities/NodeGroup.java
@@ -19,7 +19,11 @@
 
 package org.apache.asterix.metadata.entities;
 
+import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
+import java.util.Set;
+import java.util.TreeSet;
 
 import org.apache.asterix.metadata.MetadataCache;
 import org.apache.asterix.metadata.api.IMetadataEntity;
@@ -29,15 +33,19 @@
  */
 public class NodeGroup implements IMetadataEntity<NodeGroup> {
 
-    private static final long serialVersionUID = 1L;
+    private static final long serialVersionUID = 2L;
 
     // Enforced to be unique within an Asterix cluster.
     private final String groupName;
-    private final List<String> nodeNames;
+    private final Set<String> nodeNames;
 
     public NodeGroup(String groupName, List<String> nodeNames) {
         this.groupName = groupName;
-        this.nodeNames = nodeNames;
+        if (nodeNames != null) {
+            this.nodeNames = new TreeSet<>(nodeNames);
+        } else {
+            this.nodeNames = Collections.emptySet();
+        }
     }
 
     public String getNodeGroupName() {
@@ -45,7 +53,7 @@
     }
 
     public List<String> getNodeNames() {
-        return this.nodeNames;
+        return Collections.unmodifiableList(new ArrayList<>(nodeNames));
     }
 
     @Override

hyracks-fullstack/hyracks/hyracks-storage-am-common/src/main/java/org/apache/hyracks/storage/am/common/dataflow/IndexDataflowHelper.java

diff --git a/hyracks-fullstack/hyracks/hyracks-storage-am-common/src/main/java/org/apache/hyracks/storage/am/common/dataflow/IndexDataflowHelper.java b/hyracks-fullstack/hyracks/hyracks-storage-am-common/src/main/java/org/apache/hyracks/storage/am/common/dataflow/IndexDataflowHelper.java
index 520dbc0..16461de 100644
--- a/hyracks-fullstack/hyracks/hyracks-storage-am-common/src/main/java/org/apache/hyracks/storage/am/common/dataflow/IndexDataflowHelper.java
+++ b/hyracks-fullstack/hyracks/hyracks-storage-am-common/src/main/java/org/apache/hyracks/storage/am/common/dataflow/IndexDataflowHelper.java
@@ -73,6 +73,7 @@
         // Get local resource
         LocalResource lr = getResource();
         if (lr == null) {
+            LOGGER.error("index {} does not exist", resourceRef.getRelativePath());
             throw HyracksDataException.create(ErrorCode.INDEX_DOES_NOT_EXIST);
         }
         IResource resource = lr.getResource();