public void flush()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkWriter.java [248:257]

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

  public void flush() {
    if (streamSession != null && streamPack != null) {
      try {
        flushStreamPackWithRetry(retryTimes);
      } catch (IOException e) {
        LOGGER.error("Failed to flush stream pack", e);
        throw new RuntimeException(e);
      }
    }
  }