Indeed, we've tried with the parameter *index.number_of_shards* but it didn't work so I fear that this parameter is not handled by the current implementation..am I wrong?
On Mon, Jul 18, 2016 at 11:37 AM, Ufuk Celebi <u...@apache.org> wrote: > 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 >
