Skip to content

Commit ecc4577

Browse files
committed
cloud-aws 2.1.0 doesn't support elasticsearch 1.1.1
Closes #74. (cherry picked from commit a9a76e2)
1 parent 68a8e78 commit ecc4577

File tree

4 files changed

+8
-6
lines changed

4 files changed

+8
-6
lines changed

pom.xml

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -32,8 +32,8 @@
3232
</parent>
3333

3434
<properties>
35-
<elasticsearch.version>1.0.0</elasticsearch.version>
36-
<lucene.version>4.6.1</lucene.version>
35+
<elasticsearch.version>1.1.1</elasticsearch.version>
36+
<lucene.version>4.7.1</lucene.version>
3737
<tests.output>onerror</tests.output>
3838
<tests.jvms>1</tests.jvms>
3939
<tests.shuffle>true</tests.shuffle>

src/main/java/org/elasticsearch/discovery/ec2/Ec2Discovery.java

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,7 @@
2727
import org.elasticsearch.common.collect.ImmutableList;
2828
import org.elasticsearch.common.inject.Inject;
2929
import org.elasticsearch.common.settings.Settings;
30+
import org.elasticsearch.discovery.DiscoverySettings;
3031
import org.elasticsearch.discovery.zen.ZenDiscovery;
3132
import org.elasticsearch.discovery.zen.ping.ZenPing;
3233
import org.elasticsearch.discovery.zen.ping.ZenPingService;
@@ -43,8 +44,9 @@ public class Ec2Discovery extends ZenDiscovery {
4344
@Inject
4445
public Ec2Discovery(Settings settings, ClusterName clusterName, ThreadPool threadPool, TransportService transportService,
4546
ClusterService clusterService, NodeSettingsService nodeSettingsService, ZenPingService pingService,
46-
DiscoveryNodeService discoveryNodeService, AwsEc2Service ec2Service) {
47-
super(settings, clusterName, threadPool, transportService, clusterService, nodeSettingsService, discoveryNodeService, pingService, Version.CURRENT);
47+
DiscoveryNodeService discoveryNodeService, AwsEc2Service ec2Service, DiscoverySettings discoverySettings) {
48+
super(settings, clusterName, threadPool, transportService, clusterService, nodeSettingsService,
49+
discoveryNodeService, pingService, Version.CURRENT, discoverySettings);
4850
if (settings.getAsBoolean("cloud.enabled", true)) {
4951
ImmutableList<? extends ZenPing> zenPings = pingService.zenPings();
5052
UnicastZenPing unicastZenPing = null;

src/main/java/org/elasticsearch/gateway/s3/S3Gateway.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ public class S3Gateway extends BlobStoreGateway {
4949
@Inject
5050
public S3Gateway(Settings settings, ThreadPool threadPool, ClusterService clusterService,
5151
ClusterName clusterName, AwsS3Service s3Service) throws IOException {
52-
super(settings, threadPool, clusterService);
52+
super(settings, threadPool, clusterService, clusterName);
5353

5454
String bucket = componentSettings.get("bucket");
5555
if (bucket == null) {

src/test/java/org/elasticsearch/repositories/s3/S3SnapshotRestoreTest.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -142,7 +142,7 @@ public void testSimpleWorkflow() {
142142

143143
// Test restore after index deletion
144144
logger.info("--> delete indices");
145-
wipeIndices("test-idx-1", "test-idx-2");
145+
cluster().wipeIndices("test-idx-1", "test-idx-2");
146146
logger.info("--> restore one index after deletion");
147147
restoreSnapshotResponse = client.admin().cluster().prepareRestoreSnapshot("test-repo", "test-snap").setWaitForCompletion(true).setIndices("test-idx-*", "-test-idx-2").execute().actionGet();
148148
assertThat(restoreSnapshotResponse.getRestoreInfo().totalShards(), greaterThan(0));

0 commit comments

Comments
 (0)