honeymoose/OpenSearch
1
0
Fork 0
mirror of https://github.com/honeymoose/OpenSearch.git synced 2025-02-17 02:14:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

[ML] Add debug logging of notification messages to upgrade test (#62342)

Browse Source 
For #61908
This commit is contained in:
David Kyle 2020-09-15 08:24:13 +01:00 committed by GitHub
parent 3536f7f7c2
commit c50899dd8f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
x-pack/qa/rolling-upgrade/src/test/java/org/elasticsearch/upgrades/MlMappingsUpgradeIT.java
View File

@ -14,6 +14,7 @@ import org.elasticsearch.client.ml.job.config.Detector;
import org.elasticsearch.client.ml.job.config.Job;
import org.elasticsearch.common.Strings;
import org.elasticsearch.common.unit.TimeValue;
import org.elasticsearch.common.xcontent.support.XContentMapValues;
import org.elasticsearch.xpack.test.rest.XPackRestTestConstants;
import org.elasticsearch.xpack.test.rest.XPackRestTestHelper;
@ -21,6 +22,7 @@ import java.io.IOException;
import java.util.Collection;
import java.util.Collections;
import java.util.HashSet;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.stream.Collectors;
@ -227,10 +229,23 @@ public class MlMappingsUpgradeIT extends AbstractUpgradeTestCase {
assertLegacyTemplateMatchesIndexMappings(".ml-meta", ".ml-meta", true, Collections.emptySet());
assertLegacyTemplateMatchesIndexMappings(".ml-stats", ".ml-stats-000001", true, statsIndexException);
assertLegacyTemplateMatchesIndexMappings(".ml-state", ".ml-state-000001");
// AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/61908")
// assertLegacyTemplateMatchesIndexMappings(".ml-notifications-000001", ".ml-notifications-000001");
// AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/61908")
logNotications(); // debugging for #61908
assertLegacyTemplateMatchesIndexMappings(".ml-notifications-000001", ".ml-notifications-000001");
assertLegacyTemplateMatchesIndexMappings(".ml-inference-000003", ".ml-inference-000003", true, Collections.emptySet());
// .ml-annotations-6 does not use a template
// .ml-anomalies-shared uses a template but will have dynamically updated mappings as new jobs are opened
}
@SuppressWarnings("unchecked")
private void logNotications() throws IOException {
Request searchNotifications = new Request("GET", ".ml-notifications-000001/_search");
searchNotifications.addParameter("sort", "timestamp:asc");
Map<String, Object> searchResponse = entityAsMap(client().performRequest(searchNotifications));
List<Map<String, Object>> hits = (List<Map<String, Object>>) XContentMapValues.extractValue("hits.hits", searchResponse);
List<Map<String, Object>> sources =
hits.stream().map(hit -> (Map<String, Object>) hit.get("_source")).collect(Collectors.toList());
logger.info("ml notification messages: {}", sources);
}
}