[ https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15673355#comment-15673355 ]
ASF GitHub Bot commented on FLINK-4491: --------------------------------------- Github user fpompermaier commented on the issue: https://github.com/apache/flink/pull/2790 Any other feedback on this?could it be merged? > 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 > Labels: elasticsearch, streaming > > 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)