I'm trying to get rid of test messages from my flume-dev folder so that I can reduce the noise to only important stuff - i.e messages posted by humans. Does anyone know how to filter these in gmail?
Ralph On Apr 11, 2012, at 5:30 PM, Arvind Prabhakar wrote: > > ----------------------------------------------------------- > This is an automatically generated e-mail. To reply, visit: > https://reviews.apache.org/r/4704/ > ----------------------------------------------------------- > > Review request for Flume. > > > Summary > ------- > > This change modifies the JDBC channel provider implementation so that it > invokes the size query only during configuration to initialize it's own > execution state. At runtime, the transaction instances keep track of how many > events get added and removed and the delta is then added to the size > maintained by the provider. Some notes about this implementation: > > * It is possible that between the commit and update of the size counter by > one transaction, another transaction may read stale size information. > * The size counter is only used to gate put operations and not take. This > ensures that stale or incorrect information does not inhibit the draining of > the channel. > > Also refactored the channel tests to be run with and without foreign keys > enabled. > > > This addresses bug FLUME-1113. > https://issues.apache.org/jira/browse/FLUME-1113 > > > Diffs > ----- > > > /trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcChannelProviderImpl.java > 1325037 > > /trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java > 1325037 > > /trunk/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionImpl.java > 1325037 > > /trunk/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/BaseJdbcChannelProviderTest.java > PRE-CREATION > > /trunk/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java > 1325037 > > /trunk/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProviderNoFK.java > PRE-CREATION > > Diff: https://reviews.apache.org/r/4704/diff > > > Testing > ------- > > Full build and tests. > > > Thanks, > > Arvind >
