public synchronized void rollback()

in src/main/java/com/microsoft/azure/kusto/kafka/connect/sink/FileWriter.java [218:225]

• 8 lines of code
• 4 McCabe index (conditional complexity)

    public synchronized void rollback() throws IOException {
        if (countingStream != null) {
            countingStream.close();
            if (currentFile != null && currentFile.file != null) {
                dumpFile();
            }
        }
    }