2.1 version bump and Gradle bump

build.gradle

@@ -17,9 +17,9 @@ buildscript {
     ext {
         opensearch_group = "org.opensearch"
         isSnapshot = "true" == System.getProperty("build.snapshot", "true")
-        opensearch_version = System.getProperty("opensearch.version", "2.0.0-SNAPSHOT")
+        opensearch_version = System.getProperty("opensearch.version", "2.1.0-SNAPSHOT")
         buildVersionQualifier = System.getProperty("build.version_qualifier", "")
-        // 2.0.0-SNAPSHOT -> 2.0.0.0-SNAPSHOT
+        // 2.1.0-SNAPSHOT -> 2.1.0.0-SNAPSHOT
         version_tokens = opensearch_version.tokenize('-')
         opensearch_build = version_tokens[0] + '.0'
         plugin_no_snapshot = opensearch_build
@@ -80,6 +80,7 @@ repositories {
     maven { url "https://aws.oss.sonatype.org/content/repositories/snapshots" }
     mavenCentral()
     maven { url "https://plugins.gradle.org/m2/" }
+    maven { url "https://d1nvenhzbhpy0q.cloudfront.net/snapshots/lucene/" }
 }
 
 apply plugin: 'java'

gradle/wrapper/gradle-wrapper.properties

@@ -1,5 +1,5 @@
 distributionBase=GRADLE_USER_HOME
 distributionPath=wrapper/dists
-distributionUrl=https\://services.gradle.org/distributions/gradle-7.3.3-bin.zip
+distributionUrl=https\://services.gradle.org/distributions/gradle-7.4.2-bin.zip
 zipStoreBase=GRADLE_USER_HOME
 zipStorePath=wrapper/dists

src/main/java/org/opensearch/ad/cluster/ClusterManagerEventListener.java

@@ -57,7 +57,7 @@ public ClusterManagerEventListener(
     }
 
     @Override
-    public void onMaster() {
+    public void onClusterManager() {
         if (hourlyCron == null) {
             hourlyCron = threadPool.scheduleWithFixedDelay(new HourlyCron(client, nodeFilter), TimeValue.timeValueHours(1), executorName());
             clusterService.addLifecycleListener(new LifecycleListener() {
@@ -88,7 +88,7 @@ public void beforeStop() {
     }
 
     @Override
-    public void offMaster() {
+    public void offClusterManager() {
         cancel(hourlyCron);
         cancel(checkpointIndexRetentionCron);
         hourlyCron = null;

src/main/java/org/opensearch/ad/indices/AnomalyDetectionIndices.java

@@ -677,7 +677,7 @@ public void initCheckpointIndex(ActionListener<CreateIndexResponse> actionListen
     }
 
     @Override
-    public void onMaster() {
+    public void onClusterManager() {
         try {
             // try to rollover immediately as we might be restarting the cluster
             rolloverAndDeleteHistoryIndex();
@@ -692,7 +692,7 @@ public void onMaster() {
     }
 
     @Override
-    public void offMaster() {
+    public void offClusterManager() {
         if (scheduledRollover != null) {
             scheduledRollover.cancel();
         }

src/test/java/org/opensearch/ad/ODFERestTestCase.java

@@ -139,7 +139,7 @@ protected RestClient buildClient(Settings settings, HttpHost[] hosts) throws IOE
     @After
     protected void wipeAllODFEIndices() throws IOException {
         Response response = adminClient().performRequest(new Request("GET", "/_cat/indices?format=json&expand_wildcards=all"));
-        XContentType xContentType = XContentType.fromMediaTypeOrFormat(response.getEntity().getContentType().getValue());
+        XContentType xContentType = XContentType.fromMediaType(response.getEntity().getContentType().getValue());
         try (
             XContentParser parser = xContentType
                 .xContent()

src/test/java/org/opensearch/ad/cluster/ClusterManagerEventListenerTests.java

@@ -71,12 +71,12 @@ public void setUp() throws Exception {
     }
 
     public void testOnOffMaster() {
-        clusterManagerService.onMaster();
+        clusterManagerService.onClusterManager();
         assertThat(hourlyCancellable, is(notNullValue()));
         assertThat(checkpointIndexRetentionCancellable, is(notNullValue()));
         assertTrue(!clusterManagerService.getHourlyCron().isCancelled());
         assertTrue(!clusterManagerService.getCheckpointIndexRetentionCron().isCancelled());
-        clusterManagerService.offMaster();
+        clusterManagerService.offClusterManager();
         assertThat(clusterManagerService.getCheckpointIndexRetentionCron(), is(nullValue()));
         assertThat(clusterManagerService.getHourlyCron(), is(nullValue()));
     }
@@ -100,10 +100,10 @@ public void testBeforeStop() {
             return null;
         }).when(clusterService).addLifecycleListener(any());
 
-        clusterManagerService.onMaster();
+        clusterManagerService.onClusterManager();
         assertThat(clusterManagerService.getCheckpointIndexRetentionCron(), is(nullValue()));
         assertThat(clusterManagerService.getHourlyCron(), is(nullValue()));
-        clusterManagerService.offMaster();
+        clusterManagerService.offClusterManager();
         assertThat(clusterManagerService.getCheckpointIndexRetentionCron(), is(nullValue()));
         assertThat(clusterManagerService.getHourlyCron(), is(nullValue()));
     }