From 5d87ef13b6d0b5c03dd3fc983b43c12d1ba3d7c9 Mon Sep 17 00:00:00 2001 From: Amit Galitzky Date: Wed, 22 Jun 2022 22:25:25 +0000 Subject: [PATCH 1/3] 2.1 version bump and gradle 7.4.2 bump Signed-off-by: Amit Galitzky --- build.gradle | 4 ++-- gradle/wrapper/gradle-wrapper.properties | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/build.gradle b/build.gradle index 613a6beec..9bb9522aa 100644 --- a/build.gradle +++ b/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 diff --git a/gradle/wrapper/gradle-wrapper.properties b/gradle/wrapper/gradle-wrapper.properties index 2e6e5897b..aa991fcea 100644 --- a/gradle/wrapper/gradle-wrapper.properties +++ b/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 From 2cf67e67afe2c41e646a219c802026bc00e0b9ad Mon Sep 17 00:00:00 2001 From: Amit Galitzky Date: Thu, 23 Jun 2022 14:54:04 +0000 Subject: [PATCH 2/3] changed clustermanager method naming and add lucene snapshot dependency Signed-off-by: Amit Galitzky --- build.gradle | 1 + .../ad/cluster/ClusterManagerEventListener.java | 4 ++-- .../opensearch/ad/indices/AnomalyDetectionIndices.java | 4 ++-- .../ad/cluster/ClusterManagerEventListenerTests.java | 8 ++++---- 4 files changed, 9 insertions(+), 8 deletions(-) diff --git a/build.gradle b/build.gradle index 9bb9522aa..abbaad643 100644 --- a/build.gradle +++ b/build.gradle @@ -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' diff --git a/src/main/java/org/opensearch/ad/cluster/ClusterManagerEventListener.java b/src/main/java/org/opensearch/ad/cluster/ClusterManagerEventListener.java index 505cbf888..353a7ad14 100644 --- a/src/main/java/org/opensearch/ad/cluster/ClusterManagerEventListener.java +++ b/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; diff --git a/src/main/java/org/opensearch/ad/indices/AnomalyDetectionIndices.java b/src/main/java/org/opensearch/ad/indices/AnomalyDetectionIndices.java index 266a5ece4..2320e1c2c 100644 --- a/src/main/java/org/opensearch/ad/indices/AnomalyDetectionIndices.java +++ b/src/main/java/org/opensearch/ad/indices/AnomalyDetectionIndices.java @@ -677,7 +677,7 @@ public void initCheckpointIndex(ActionListener 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(); } diff --git a/src/test/java/org/opensearch/ad/cluster/ClusterManagerEventListenerTests.java b/src/test/java/org/opensearch/ad/cluster/ClusterManagerEventListenerTests.java index 39146c90b..eccf67de8 100644 --- a/src/test/java/org/opensearch/ad/cluster/ClusterManagerEventListenerTests.java +++ b/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())); } From 9d6ea85be8897ad8e178ac7d57ca355b29b2bfc3 Mon Sep 17 00:00:00 2001 From: Amit Galitzky Date: Thu, 23 Jun 2022 16:10:02 +0000 Subject: [PATCH 3/3] changed fromMediaTypeOrFormat to fromMediaType Signed-off-by: Amit Galitzky --- src/test/java/org/opensearch/ad/ODFERestTestCase.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/test/java/org/opensearch/ad/ODFERestTestCase.java b/src/test/java/org/opensearch/ad/ODFERestTestCase.java index 8d729688e..6de204584 100644 --- a/src/test/java/org/opensearch/ad/ODFERestTestCase.java +++ b/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()