You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Flavio Pompermaier (JIRA)" <ji...@apache.org> on 2016/08/25 14:40:21 UTC
[jira] [Created] (FLINK-4491) Handle index.number_of_shards in the
ES connector
Flavio Pompermaier created FLINK-4491:
-----------------------------------------
Summary: Handle index.number_of_shards in the ES connector
Key: FLINK-4491
URL: https://issues.apache.org/jira/browse/FLINK-4491
Project: Flink
Issue Type: Improvement
Components: Streaming Connectors
Affects Versions: 1.1.0
Reporter: Flavio Pompermaier
Priority: Minor
At the moment is not possible to configure the number of shards if an index does not already exists on the Elasticsearch cluster. It could be a great improvement to handle the index.number_of_shards (passed in the configuration object). E.g.:
{code:java}
Map<String, String> config = Maps.newHashMap();
config.put("bulk.flush.max.actions", "1");
config.put("cluster.name", "my-cluster-name");
config.put("index.number_of_shards", "1");
{code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)