Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
2.0-beta7
-
None
Description
FlumePeristentManager's WriterThread catches the exception thrown from the Flume RPCClient and then breaks out of the while loop causing the thread to stop. However, it does not mark the thread as shut down so subsequent events will be added to the Berkeley DB database and the key will be added to the internal queue. Eventually the queue will grow and cause an OutOfMemoryError.