You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Rion Williams (Jira)" <ji...@apache.org> on 2021/10/09 19:26:00 UTC

[jira] [Updated] (FLINK-24493) Introduce DemultiplexingSink to Support Dynamic Sink Routing

     [ https://issues.apache.org/jira/browse/FLINK-24493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Rion Williams updated FLINK-24493:
----------------------------------
    Summary: Introduce DemultiplexingSink to Support Dynamic Sink Routing  (was: Introduce DemultiplexingSink)

> Introduce DemultiplexingSink to Support Dynamic Sink Routing
> ------------------------------------------------------------
>
>                 Key: FLINK-24493
>                 URL: https://issues.apache.org/jira/browse/FLINK-24493
>             Project: Flink
>          Issue Type: New Feature
>          Components: Connectors / Common
>            Reporter: Rion Williams
>            Priority: Major
>
> Recently, FLINK-23977 attempted to introduce an approach to supporting dynamic routing for the Elasticsearch sink, however during some discussion within [the pull request|https://github.com/apache/flink/pull/17061], the idea was introduced to create a more generic approach.
> The idea being that we could introduce a common DemultiplexingSink and related interface for handling routing to any number of existing sinks similar to the implementation mentioned in FLINK-23977 to the common connectors directory.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)