Gu Zhou created FLUME-2694:
------------------------------
Summary: when decodeErrorPolicy=IGNORE or REPLACE, malformedInput
occur,ResettableFileInputStream readChar also throw exception
Key: FLUME-2694
URL: https://issues.apache.org/jira/browse/FLUME-2694
Project: Flume
Issue Type: Bug
Reporter: Gu Zhou
when decodeErrorPolicy=IGNORE or REPLACE, malformedInput
occur,ResettableFileInputStream::readChar also throw exception, and spooldir
stoped.
snipt in ResettableFileInputStream.java:
public synchronized int readChar() throws IOException {
...
CoderResult res = decoder.decode(buf, charBuf, isEndOfInput);
if (res.isMalformed() || res.isUnmappable()) {
res.throwException();
}
...
}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)