[asterixdb] branch master updated: [NO ISSUE][CLUS] Order Cluster Partition Constraints Similar to Node Groups

[mhubail]

This is an automated email from the ASF dual-hosted git repository.

mhubail pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/asterixdb.git


The following commit(s) were added to refs/heads/master by this push:
     new a8bad1a  [NO ISSUE][CLUS] Order Cluster Partition Constraints Similar 
to Node Groups
a8bad1a is described below

commit a8bad1a13c64a94d8fa57e26609d991849e19d52
Author: Murtadha Hubail <mhub...@apache.org>
AuthorDate: Fri Nov 6 17:14:49 2020 +0300

    [NO ISSUE][CLUS] Order Cluster Partition Constraints Similar to Node Groups
    
    - user model changes: no
    - storage format changes: no
    - interface changes: no
    
    Details:
    
    - Order the list of nodes in the cluster partition constraints
      using the same ordering as nodegroups to allow data source
      functions attempting to access storage to be routed to the
      correct storage partition.
    
    Change-Id: Iba193bccb0c9c28f24e8d7136ce394abf780fa00
    Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/8783
    Integration-Tests: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Tested-by: Jenkins <jenk...@fulliautomatix.ics.uci.edu>
    Reviewed-by: Murtadha Hubail <mhub...@apache.org>
    Reviewed-by: Ali Alsuliman <ali.al.solai...@gmail.com>
---
 .../main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
 
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
index 7933cd2..2c05c53 100644
--- 
a/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
+++ 
b/asterixdb/asterix-runtime/src/main/java/org/apache/asterix/runtime/utils/ClusterStateManager.java
@@ -299,6 +299,8 @@ public class ClusterStateManager implements 
IClusterStateManager {
             }
         }
         clusterActiveLocations.removeAll(pendingRemoval);
+        // for operators attempting to access storage, order the nodes list 
similar to a nodegroup
+        Collections.sort(clusterActiveLocations);
         clusterPartitionConstraint =
                 new 
AlgebricksAbsolutePartitionConstraint(clusterActiveLocations.toArray(new 
String[] {}));
     }