Repository: flume Updated Branches: refs/heads/trunk 1ca0765aa -> c554ba3d9
FLUME-2514. Speed up TestFileChannelRestart tests TestFileChannelRestart tests are really slow. For example, testToggleCheckpointCompressionFromFalseToTrue and testToggleCheckpointCompressionFromTrueToFalse take ~4 minutes each. Some of them could be made faster by using channels with lower capacity. Reviewed by Bessenyei Balázs Donát (Santiago M. Mola via Mike Percy) Project: http://git-wip-us.apache.org/repos/asf/flume/repo Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/c554ba3d Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c554ba3d Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c554ba3d Branch: refs/heads/trunk Commit: c554ba3d9b8234b37ba0b5dde3657034d11acb0b Parents: 1ca0765 Author: Santiago M. Mola <[email protected]> Authored: Wed Jul 20 11:36:57 2016 -0700 Committer: Mike Percy <[email protected]> Committed: Wed Jul 20 11:38:53 2016 -0700 ---------------------------------------------------------------------- .../java/org/apache/flume/channel/file/TestFileChannelRestart.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flume/blob/c554ba3d/flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java ---------------------------------------------------------------------- diff --git a/flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java b/flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java index d21f140..80c3013 100644 --- a/flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java +++ b/flume-ng-channels/flume-file-channel/src/test/java/org/apache/flume/channel/file/TestFileChannelRestart.java @@ -881,6 +881,8 @@ public class TestFileChannelRestart extends TestFileChannelBase { overrides.put(FileChannelConfiguration.USE_DUAL_CHECKPOINTS, "true"); overrides.put(FileChannelConfiguration.MAX_FILE_SIZE, "1000"); + overrides.put(FileChannelConfiguration.TRANSACTION_CAPACITY, "1000"); + overrides.put(FileChannelConfiguration.CAPACITY, "1000"); overrides.put(FileChannelConfiguration.COMPRESS_BACKUP_CHECKPOINT, String.valueOf(originalCheckpointCompressed)); channel = createFileChannel(overrides);
