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)