[jira] [Created] (FLINK-4491) Handle index.number_of_shards in the ES connector

[Shang Yuanchun (Jira)]

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)