pulsar-io/hdfs2/src/main/java/org/apache/pulsar/io/hdfs2/sink/HdfsSyncThread.java [66:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void ackRecords() throws IOException, InterruptedException {

        if (CollectionUtils.isEmpty(unackedRecords)) {
           return;
        }

        synchronized (stream) {
          stream.hsync();
        }

        while (!unackedRecords.isEmpty()) {
          unackedRecords.take().ack();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



pulsar-io/hdfs3/src/main/java/org/apache/pulsar/io/hdfs3/sink/HdfsSyncThread.java [66:79]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    private void ackRecords() throws IOException, InterruptedException {

        if (CollectionUtils.isEmpty(unackedRecords)) {
           return;
        }

        synchronized (stream) {
          stream.hsync();
        }

        while (!unackedRecords.isEmpty()) {
          unackedRecords.take().ack();
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -