private void reportRuntimeError()

in src/main/java/com/aliyun/odps/kafka/connect/MaxComputeSinkTask.java [424:434]

• 11 lines of code
• 3 McCabe index (conditional complexity)

  private void reportRuntimeError(SinkRecord record, IOException e) {
    if (runtimeErrorWriter != null) {
      LOGGER.info("Thread(" + Thread.currentThread().getId() + ") skip runtime error", e);
      runtimeErrorWriter.write(record);
    } else {
      if (!skipErrorRecords) {
        throw new RuntimeException(e);
      }
      LOGGER.warn("Runtime error when handling: {}, skip the record", record.toString());
    }
  }