I've never used the Elasticsearch sink, but the docs say: "Note how a Map of Strings is used to configure the Sink. The configuration keys are documented in the Elasticsearch documentationhere. Especially important is the cluster.name parameter that must correspond to the name of your cluster."
The config keys for index creation are found here: https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-create-index.html Does this help? If not, maybe @Aljoscha can chime in here. – Ufuk On Mon, Jul 18, 2016 at 11:23 AM, Flavio Pompermaier <pomperma...@okkam.it> wrote: > Hi to all, > > we tried to use the streaming ES connector of Flink 1.1-SNAPSHOT and we > wanted to set the number of shards when creating a new index. Is that > possible at the moment? > > Best, > Flavio
