You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Zichen Liu (Jira)" <ji...@apache.org> on 2022/05/06 16:18:00 UTC

[jira] [Updated] (FLINK-27537) Remove requirement for Async Sink's RequestEntryT to be serializable

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

Zichen Liu updated FLINK-27537:
-------------------------------
    Description: 
Currently, in AsyncSinkBase and it's dependent classes, e.g. the sink writer, element converter etc., the RequestEntryT generic type is required to be serializable.

However, this requirement no longer holds and there is nothing that actually requires this.

Proposed approach:
 * Remove the extends serializable from the generic type RequestEntryT

  was:
Currently, in `AsyncSinkBase` and it's dependent classes, e.g. the sink writer, element converter etc., the `RequestEntryT` generic type is required to be `serializable`.

However, this requirement no longer holds and there is nothing that actually requires this.

Proposed approach:

* Remove the `extends serializable` from the generic type `RequestEntryT`


> Remove requirement for Async Sink's RequestEntryT to be serializable
> --------------------------------------------------------------------
>
>                 Key: FLINK-27537
>                 URL: https://issues.apache.org/jira/browse/FLINK-27537
>             Project: Flink
>          Issue Type: Improvement
>          Components: Connectors / Common
>    Affects Versions: 1.15.0
>            Reporter: Zichen Liu
>            Priority: Major
>
> Currently, in AsyncSinkBase and it's dependent classes, e.g. the sink writer, element converter etc., the RequestEntryT generic type is required to be serializable.
> However, this requirement no longer holds and there is nothing that actually requires this.
> Proposed approach:
>  * Remove the extends serializable from the generic type RequestEntryT



--
This message was sent by Atlassian Jira
(v8.20.7#820007)