UNSUBSCRIBE On Tue, Dec 30, 2025 at 10:24 AM Matt Cuento (Jira) <[email protected]> wrote:
> Matt Cuento created FLINK-38849: > ----------------------------------- > > Summary: HybridSourceReader does not respect > pauseOrResumeSplits implementations > Key: FLINK-38849 > URL: https://issues.apache.org/jira/browse/FLINK-38849 > Project: Flink > Issue Type: Bug > Components: Connectors / HybridSource > Affects Versions: 2.1.1, 2.2.0, 2.0.1 > Reporter: Matt Cuento > > > `HybridSourceReader` implements the `SourceReader` interface which > contains a default implementation of `pauseOrResumeSplits` for use in > watermark alignment which throws `UnsupportedOperationException`. > > The `HybridSourceReader` should be extended to call the current source's > implementation of `pauseOrResumeSplits` to support watermark alignment. > > > > -- > This message was sent by Atlassian Jira > (v8.20.10#820010) >
