tcsdn

FLUME-3207:Fix some typos in TestReliableSpoolingFileEventReader

2

There is a mistake in `testConsumeFileOldestWithLexicographicalComparision` ```java public void testConsumeFileOldestWithLexicographicalComparision() throws IOException, InterruptedException { ReliableEventReader reader = new ReliableSpoolingFileEventReader.Builder().spoolDirectory(WORK_DIR) .consumeOrder(ConsumeOrder.OLDEST) .build(); File file1 = new File(WORK_DIR, "new-file1"); File file2 =...

FLUME-3205:Remove unnecessary 'synchronized' in ResettableFileInputStream

4

I found no concurrent access to ResettableFileInputStream object in flume code. Remove 'synchronized' will improve performance of SpoolDirectorySource. Tested with a file of 200MB，with 'synchronized' it took 9 seconds to...