[ 
https://issues.apache.org/jira/browse/FLINK-37445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17933883#comment-17933883
 ] 

Poorvank Bhatia commented on FLINK-37445:
-----------------------------------------

Yes yes. The handling of bounded sources, integration with the input formats, 
and converting them into executable transformations where this is used along 
with affects state compatibility needs a migration plan.

I've created a ticket to track this, and I'll be publishing a document soon 
outlining the necessary changes. Will be attaching the doc to the description 
and starting a DISCUSS thread, if that works for the community. :)

 

> Migrate InputFormatSourceFunction to the Source V2 API
> ------------------------------------------------------
>
>                 Key: FLINK-37445
>                 URL: https://issues.apache.org/jira/browse/FLINK-37445
>             Project: Flink
>          Issue Type: Technical Debt
>            Reporter: Poorvank Bhatia
>            Priority: Major
>
> InputFormatSourceFunction: 
> [https://github.com/apache/flink/blob/master/flink-runtime/src/main/java/org/apache/flink/streaming/api/functions/source/legacy/InputFormatSourceFunction.java]
>  needs to be moved to the new Source V2 API.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to