[ https://issues.apache.org/jira/browse/FLINK-4491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15686995#comment-15686995 ]
ASF GitHub Bot commented on FLINK-4491: --------------------------------------- Github user fhueske commented on the issue: https://github.com/apache/flink/pull/2790 Thanks for the pull request @ddolzan and sorry for the delayed review. To be honest, I am not sure if we should include the `ElasticSearchHelper` in Flink. I see that might be helpful for some users, but it does not contain any Flink related code and is in principle a light-weight Elasticsearch client. > 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)