Skip to content

Commit fdc7d11

Browse files
committed
Upgrading ES to 5.0.0-rc1
1 parent 786301f commit fdc7d11

File tree

4 files changed

+9
-5
lines changed

4 files changed

+9
-5
lines changed

build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,7 +22,7 @@ allprojects {
2222
// Hive depends on JDO ec2 missing from Maven Central
2323
maven { url "http://www.datanucleus.org/downloads/maven2" }
2424
maven { url "http://oss.sonatype.org/content/groups/public/" }
25-
maven { url "https://staging.elastic.co/5.0.0-beta1-5eb5cbdb/maven" }
25+
maven { url "https://staging.elastic.co/5.0.0-rc1-9db751df/maven" }
2626
}
2727

2828
apply plugin: "java"

gradle.properties

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -35,8 +35,8 @@ hamcrestVersion = 1.3
3535
# Hive 0.11 finally updated antlr to 3.4 so there are no more conflicts with Pig
3636
antlrVersion = 3.4
3737
thriftVersion = 0.5.0
38-
esVersion = 5.0.0-beta1
39-
esVersionStable = 5.0.0-beta1
38+
esVersion = 5.0.0-rc1
39+
esVersionStable = 5.0.0-rc1
4040

4141
luceneVersion = 6.0.0
4242
groovyVersion = 2.4.4

mr/src/main/java/org/elasticsearch/hadoop/rest/RestRepository.java

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -419,7 +419,11 @@ public void delete() {
419419
}
420420
else {
421421
// try first a blind delete by query (since the plugin might be installed)
422-
client.delete(resourceW.indexAndType() + "/_query?q=*");
422+
try {
423+
client.delete(resourceW.indexAndType() + "/_query?q=*");
424+
} catch (EsHadoopInvalidRequest ehir) {
425+
log.info("Skipping delete by query as the plugin is not installed...");
426+
}
423427

424428
// in ES 2.0 and higher this means scrolling and deleting the docs by hand...
425429
// do a scroll-scan without source

mr/src/main/java/org/elasticsearch/hadoop/rest/SearchRequestBuilder.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -192,7 +192,7 @@ private String assemble() {
192192
}
193193
if (local) {
194194
if (pref.length() > 0) {
195-
pref.append(";");
195+
pref.append("|");
196196
}
197197
pref.append("_local");
198198
}

0 commit comments

Comments
 (0)