Xingcan Cui created FLINK-37308:
-----------------------------------
Summary: HybridSourceReader doesn't support pauseOrResumeSplits
Key: FLINK-37308
URL: https://issues.apache.org/jira/browse/FLINK-37308
Project: Flink
Issue Type: Bug
Components: Connectors / Common
Affects Versions: 1.20.1
Reporter: Xingcan Cui
Currently, the {{HybridSourceReader}} doesn't implement the
{{pauseOrResumeSplits()}} method and it prevents hybrid sources from
functioning correctly with watermark alignment. I'm not quite sure if we can
simply add the following implementation for it.
{code:java}
@Override
public void pauseOrResumeSplits(
Collection<String> splitsToPause,
Collection<String> splitsToResume) {
currentReader.pauseOrResumeSplits(splitsToPause, splitsToResume);
} {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
