Skip to content

Commit 7e2ee43

Browse files
nkvolldadoonet
authored andcommitted
Update to elasticsearch 0.90.4
Breaking changes in to EsExecutors was introduced in elasticsearch 0.90.4 Closes #35.
1 parent 1a7d263 commit 7e2ee43

File tree

3 files changed

+3
-3
lines changed

3 files changed

+3
-3
lines changed

README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@ In order to install the plugin, simply run: `bin/plugin -install elasticsearch/e
1515
<tbody>
1616
<tr>
1717
<td>1.15.0-SNAPSHOT (master)</td>
18-
<td>0.90.3 -> master</td>
18+
<td>0.90.4 -> master</td>
1919
</tr>
2020
<tr>
2121
<td>1.14.0</td>

pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@
3131
</parent>
3232

3333
<properties>
34-
<elasticsearch.version>0.90.3</elasticsearch.version>
34+
<elasticsearch.version>0.90.4</elasticsearch.version>
3535
</properties>
3636

3737
<repositories>

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,7 @@ public S3Gateway(Settings settings, ThreadPool threadPool, ClusterService cluste
9090
ByteSizeValue chunkSize = componentSettings.getAsBytesSize("chunk_size", new ByteSizeValue(100, ByteSizeUnit.MB));
9191

9292
int concurrentStreams = componentSettings.getAsInt("concurrent_streams", 5);
93-
this.concurrentStreamPool = EsExecutors.newScalingExecutorService(1, concurrentStreams, 5, TimeUnit.SECONDS, EsExecutors.daemonThreadFactory(settings, "[s3_stream]"));
93+
this.concurrentStreamPool = EsExecutors.newScaling(1, concurrentStreams, 5, TimeUnit.SECONDS, EsExecutors.daemonThreadFactory(settings, "[s3_stream]"));
9494

9595
logger.debug("using bucket [{}], region [{}], chunk_size [{}], concurrent_streams [{}]", bucket, region, chunkSize, concurrentStreams);
9696

0 commit comments

Comments
 (0)