[
https://issues.apache.org/jira/browse/RANGER-1776?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
peng.jianhua updated RANGER-1776:
---------------------------------
Description:
Ranger always show error , the reason is logJSON always return false :
{code}
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 {
.... ....
}
{code}
{code}
BufferedAuditProvider.java
@Override
public boolean logJSON(Collection<String> events) {
boolean ret = true;
for (String event : events) {
ret = logJSON(event);
if (!ret) {
break;
}
}
return false;
}
{code}
Here should return ret.
was:
Ranger always show error , the reason is logJSON always return false :
{code}
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 {
.... ....
}
{code}
{code}
BufferedAuditProvider.java
@Override
public boolean logJSON(Collection<String> events) {
boolean ret = true;
for (String event : events) {
ret = logJSON(event);
if (!ret) {
break;
}
}
return false;
}
{code}
> ranger-plugin-audit show log error.
> ------------------------------------
>
> Key: RANGER-1776
> URL: https://issues.apache.org/jira/browse/RANGER-1776
> Project: Ranger
> Issue Type: Bug
> Components: Ranger
> Affects Versions: master
> Reporter: peng.jianhua
> Assignee: peng.jianhua
>
> Ranger always show error , the reason is logJSON always return false :
> {code}
> 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 {
> .... ....
> }
> {code}
> {code}
> BufferedAuditProvider.java
> @Override
> public boolean logJSON(Collection<String> events) {
> boolean ret = true;
> for (String event : events) {
> ret = logJSON(event);
> if (!ret) {
> break;
> }
> }
> return false;
> }
> {code}
> Here should return ret.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
