pulsar-io/canal/src/main/java/org/apache/pulsar/io/canal/CanalAbstractSource.java [89:95]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if (!running) {
            return;
        }
        running = false;
        if (thread != null) {
            thread.interrupt();
            thread.join();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/flume/src/main/java/org/apache/pulsar/io/flume/source/AbstractSource.java [76:82]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        if (!running) {
            return;
        }
        running = false;
        if (thread != null) {
            thread.interrupt();
            thread.join();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -