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 <[email protected]>
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 <[email protected]>
Tested-by: Jenkins <[email protected]>
Reviewed-by: Murtadha Hubail <[email protected]>
Reviewed-by: Ali Alsuliman <[email protected]>
---
.../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[] {}));
}
