ashulin commented on issue #2127: URL: https://github.com/apache/incubator-seatunnel/issues/2127#issuecomment-1175734279
> org.apache.seatunnel.api.source.SourceReader#snapshotState looks similar with org.apache.seatunnel.api.source.SourceSplitEnumerator#snapshotState , but return a different type(List<SplitT> and StateT), the comments is split checkpoint state. while actually it returns List<SplitT>, they are not same in my mind. Could we have a chance to unify the snapshot behavior? `SourceSplitEnumerator#snapshotState` and `SourceReader#snapshotState` are different. `SourceSplitEnumerator` assumes the role of coordinator, which may require information beyond the snapshot split. `SourceReader` is designed to only need splits to run, so the snapshot returns `List<SplitT>`. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
