[
https://issues.apache.org/jira/browse/AMBARI-25293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Krisztian Kasa updated AMBARI-25293:
------------------------------------
Description:
Every time when logfeeder sends a log entry to solr it updates the
corresponding checkpoint file. After a log file rolled over every subsequent
checkpoint file update fails with NPE
{code}
2019-06-04 00:00:13,611 [OutputSolr,audit_logs,worker=0] ERROR
org.apache.ambari.logfeeder.util.LogFeederUtil (LogFeederUtil.java:134) -
Caught exception checkIn. , input=input:source=file,
path=/var/log/hadoop/hdfs/hdfs-audit.log
java.lang.NullPointerException
at
org.apache.ambari.logfeeder.input.file.FileCheckInHelper.checkIn(FileCheckInHelper.java:45)
at
org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:147)
at
org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:49)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.addToSolr(OutputSolr.java:472)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.sendToSolr(OutputSolr.java:380)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.run(OutputSolr.java:340)
{code}
There is no entry in the map returned by inputFile.getCheckPointFiles() with
the new file key
https://github.com/apache/ambari/blob/fd3024cc2d7e8493446ccf42e81ed52497379cce/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/input/file/FileCheckInHelper.java#L43
was:
Every time when logfeeder sends a log entry to solr it updates the
corresponding checkpoint file. After a log file rolled over every subsequent
checkpoint file update fails with NPE
{code}
Caught exception checkIn. , input=input:source=file,
path=/var/log/oozie/oozie.log
java.lang.NullPointerException
at
org.apache.ambari.logfeeder.input.file.FileCheckInHelper.checkIn(FileCheckInHelper.java:45)
at org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:147)
at org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:49)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.addToSolr(OutputSolr.java:472)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.sendToSolr(OutputSolr.java:380)
at
org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.run(OutputSolr.java:340)
{code}
There is no entry in the map returned by inputFile.getCheckPointFiles() with
the new file key
https://github.com/apache/ambari/blob/fd3024cc2d7e8493446ccf42e81ed52497379cce/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/input/file/FileCheckInHelper.java#L43
> Logsearch: logfeeder throws NPE when updating checkpoint
> --------------------------------------------------------
>
> Key: AMBARI-25293
> URL: https://issues.apache.org/jira/browse/AMBARI-25293
> Project: Ambari
> Issue Type: Bug
> Components: logsearch
> Affects Versions: 2.7.3
> Reporter: Krisztian Kasa
> Assignee: Krisztian Kasa
> Priority: Major
> Fix For: 2.7.4
>
>
> Every time when logfeeder sends a log entry to solr it updates the
> corresponding checkpoint file. After a log file rolled over every subsequent
> checkpoint file update fails with NPE
> {code}
> 2019-06-04 00:00:13,611 [OutputSolr,audit_logs,worker=0] ERROR
> org.apache.ambari.logfeeder.util.LogFeederUtil (LogFeederUtil.java:134) -
> Caught exception checkIn. , input=input:source=file,
> path=/var/log/hadoop/hdfs/hdfs-audit.log
> java.lang.NullPointerException
> at
> org.apache.ambari.logfeeder.input.file.FileCheckInHelper.checkIn(FileCheckInHelper.java:45)
> at
> org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:147)
> at
> org.apache.ambari.logfeeder.input.InputFile.checkIn(InputFile.java:49)
> at
> org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.addToSolr(OutputSolr.java:472)
> at
> org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.sendToSolr(OutputSolr.java:380)
> at
> org.apache.ambari.logfeeder.output.OutputSolr$SolrWorkerThread.run(OutputSolr.java:340)
> {code}
> There is no entry in the map returned by inputFile.getCheckPointFiles() with
> the new file key
> https://github.com/apache/ambari/blob/fd3024cc2d7e8493446ccf42e81ed52497379cce/ambari-logsearch/ambari-logsearch-logfeeder/src/main/java/org/apache/ambari/logfeeder/input/file/FileCheckInHelper.java#L43
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
