[
https://issues.apache.org/jira/browse/FLINK-23977?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-23977:
-----------------------------------
Labels: elasticsearch pull-request-available (was: elasticsearch)
> Add Support for Dynamic Elastic Cluster/Index Routing
> -----------------------------------------------------
>
> Key: FLINK-23977
> URL: https://issues.apache.org/jira/browse/FLINK-23977
> Project: Flink
> Issue Type: Improvement
> Components: Connectors / ElasticSearch
> Reporter: Rion Williams
> Assignee: Rion Williams
> Priority: Major
> Labels: elasticsearch, pull-request-available
>
> Currently only index-level dynamic routing is supported within the
> Elasticsearch connector, which can be problematic if information such as the
> host of the cluster (e.g. HttpHosts) is not known until run-time.
> The idea behind this ticket would be to implement a wrapper that would allow
> Elasticsearch sink instances to be created at run time and stored within an
> in-memory cache (i.e. HashMap) using a key-value association where the key
> represents a deterministically unique "route" and the value is the sink to
> which all items with a given key are written.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
