[FLUME-3060] Race condition in flume-taildir-source

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 1.7.0
• Fix Version/s: 1.7.0
• Component/s: Sinks+Sources
• Assignee: Unassigned
• Reporter: malin
• Created: 24/Feb/17 09:19
• Updated: 08/Oct/22 04:15

Description

flume-taildir-source stored the matched files in ReliableTaildirEventReader.tailFiles, and updated it in ReliableTaildirEventReader.updateTailFiles(), which will be invoked in the main thread(TaildirSource.process()). But at the same time, ReliableTaildirEventReader.tailFiles will be read in the idleFileChecker thread and PositionWriter thread, will there be any race condition?

Issue Links

• links to: GitHub Pull Request #369