Skip to content

Commit 5228259

Browse files
committed
cleanup to remove ES 5x related stuff
Signed-off-by: Jugal Chauhan <[email protected]>
1 parent c251bb9 commit 5228259

File tree

3 files changed

+12
-29
lines changed

3 files changed

+12
-29
lines changed

DocumentsFromSnapshotMigration/src/test/java/org/opensearch/migrations/bulkload/EndToEndTest.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -34,10 +34,10 @@ public class EndToEndTest extends SourceTestBase {
3434
@TempDir
3535
private File localDirectory;
3636

37-
private static Stream<Arguments> scenarios() {
38-
return SupportedClusters.supportedPairs(true).stream()
39-
.map(migrationPair -> Arguments.of(migrationPair.source(), migrationPair.target()));
40-
}
37+
private static Stream<Arguments> scenarios() {
38+
return SupportedClusters.supportedPairs(true).stream()
39+
.map(migrationPair -> Arguments.of(migrationPair.source(), migrationPair.target()));
40+
}
4141

4242
@ParameterizedTest(name = "Source {0} to Target {1}")
4343
@MethodSource(value = "scenarios")

RFS/src/main/java/org/opensearch/migrations/bulkload/version_es_6_8/ShardMetadataFactory_ES_6_8.java

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,6 @@ public ShardMetadata fromJsonNode(JsonNode root, String indexId, String indexNam
2626

2727
try {
2828
ObjectNode objectNodeRoot = (ObjectNode) root;
29-
System.out.println("====== START Smile Decoded JSON for indexId=" + indexId + ", shardId=" + shardId + " ======");
30-
System.out.println(objectMapper.writerWithDefaultPrettyPrinter().writeValueAsString(objectNodeRoot));
31-
System.out.println("====== END Smile JSON ======");
3229
ShardMetadataData_ES_6_8.DataRaw shardMetadataRaw = objectMapper.treeToValue(
3330
objectNodeRoot,
3431
ShardMetadataData_ES_6_8.DataRaw.class

RFS/src/testFixtures/java/org/opensearch/migrations/bulkload/framework/SearchClusterContainer.java

Lines changed: 8 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -74,23 +74,23 @@ public class SearchClusterContainer extends GenericContainer<SearchClusterContai
7474
Version.fromString("ES 6.4.3")
7575
);
7676
public static final ContainerVersion ES_V6_3 = new ElasticsearchOssVersion(
77-
"docker.elastic.co/elasticsearch/elasticsearch:6.3.2", // TODO: Doesn't resolve
77+
"docker.elastic.co/elasticsearch/elasticsearch:6.3.2",
7878
Version.fromString("ES 6.3")
7979
);
8080
public static final ContainerVersion ES_V6_2 = new ElasticsearchOssVersion(
81-
"elasticsearch-oss:6.2.4", // Matches your local image
82-
Version.fromString("ES 6.2.4") // Must match image tag for fallback lookup
81+
"elasticsearch-oss:6.2.4", // Matches local image
82+
Version.fromString("ES 6.2.4")
8383
);
8484
public static final ContainerVersion ES_V6_1 = new ElasticsearchOssVersion(
85-
"elasticsearch-oss:6.1.4", // Matches your local image
86-
Version.fromString("ES 6.1.4") // <-- not ES 6.1
85+
"elasticsearch-oss:6.1.4", // Matches local image
86+
Version.fromString("ES 6.1.4")
8787
);
8888
public static final ContainerVersion ES_V6_0 = new ElasticsearchOssVersion(
89-
"elasticsearch-oss:6.0.1", // Matches your local image
90-
Version.fromString("ES 6.0.1") // <-- not ES 6.0
89+
"elasticsearch-oss:6.0.1", // Matches local image
90+
Version.fromString("ES 6.0.1")
9191
);
9292

93-
public static final ContainerVersion ES_V5_6_16 = new Elasticsearch5Version(
93+
public static final ContainerVersion ES_V5_6_16 = new ElasticsearchVersion(
9494
"docker.elastic.co/elasticsearch/elasticsearch:5.6.16",
9595
Version.fromString("ES 5.6.16")
9696
);
@@ -133,14 +133,6 @@ private enum INITIALIZATION_FLAVOR {
133133
new ImmutableMap.Builder<String, String>().putAll(BASE.getEnvVariables())
134134
.put("bootstrap.system_call_filter", "false")
135135
.build()),
136-
ELASTICSEARCH_5(
137-
new ImmutableMap.Builder<String, String>().putAll(BASE.getEnvVariables())
138-
.put("xpack.security.enabled", "false")
139-
.put("xpack.watcher.enabled", "false")
140-
.put("xpack.monitoring.enabled", "false")
141-
.put("xpack.ml.enabled", "false")
142-
.put("bootstrap.system_call_filter", "false")
143-
.build()),
144136
ELASTICSEARCH_8(
145137
new ImmutableMap.Builder<String, String>().putAll(BASE.getEnvVariables())
146138
.put("xpack.security.enabled", "false")
@@ -327,12 +319,6 @@ public ElasticsearchVersion(String imageName, Version version) {
327319
}
328320
}
329321

330-
public static class Elasticsearch5Version extends ContainerVersion {
331-
public Elasticsearch5Version(String imageName, Version version) {
332-
super(imageName, version, INITIALIZATION_FLAVOR.ELASTICSEARCH_5, "elasticsearch");
333-
}
334-
}
335-
336322
public static class Elasticsearch8Version extends ContainerVersion {
337323
public Elasticsearch8Version(String imageName, Version version) {
338324
super(imageName, version, INITIALIZATION_FLAVOR.ELASTICSEARCH_8, "elasticsearch");

0 commit comments

Comments
 (0)