@Override
    public void stop() {
        LOG.debug("stopping StreamFetchTask for split: {}", split);
        if (streamSplitReadTask != null) {
            ((StreamSplitChangeEventSourceContext) streamSplitReadTask.context).finished();
        }
        stopped = true;
    }
A {@link FetchTask} implementation for Postgres to read streaming changes.
inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/source/fetch/PostgresStreamFetchTask.java