Description
Ranger always show error , the reason is logJSON always return false :
AuditFileSpool.java ret = consumerProvider.logJSON(lines); if (!ret) { // Need to log error after fixed interval logError("Error sending logs to consumer. provider=" + queueProvider.getName() + ", consumer=" + consumerProvider.getName()); } else { .... .... }
BufferedAuditProvider.java @Override public boolean logJSON(Collection<String> events) { boolean ret = true; for (String event : events) { ret = logJSON(event); if (!ret) { break; } } return false; }
Here should return ret.
Attachments
Attachments
Issue Links
- links to