-----------------------------------------------------------
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/4704/
-----------------------------------------------------------
(Updated 2012-04-12 01:13:25.731663)
Review request for Flume.
Changes
-------
During manual testing, I realized that the avro source was not logging channel
exception. Added a log message to facilitate testing and also removed some
empty lines. No logic changes in this diff update.
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 (updated)
-----
/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
/trunk/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
1325037
Diff: https://reviews.apache.org/r/4704/diff
Testing
-------
Full build and tests.
Thanks,
Arvind
