pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java [48:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void run() {
       while (keepRunning) {
         try {
            Thread.sleep(syncInterval);
            ackRecords();
         } catch (InterruptedException e) {
            return;
         } catch (IOException e) {
            e.printStackTrace();
         }
       }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSyncThread.java [48:59]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void run() {
       while (keepRunning) {
         try {
            Thread.sleep(syncInterval);
            ackRecords();
         } catch (InterruptedException e) {
            return;
         } catch (IOException e) {
            e.printStackTrace();
         }
       }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -