You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flume.apache.org by ar...@apache.org on 2012/02/13 05:03:37 UTC
svn commit: r1243410 - in /incubator/flume/branches/flume-728:
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/
flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/
flume-ng-channels/fl...
Author: arvind
Date: Mon Feb 13 04:03:36 2012
New Revision: 1243410
URL: http://svn.apache.org/viewvc?rev=1243410&view=rev
Log:
FLUME-964. Remove compiler warnings where possible.
(Brock Noland via Arvind Prabhakar)
Modified:
incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelException.java
incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java
incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java
incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java
incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java
incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestDefaultSourceFactory.java
incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestExecSource.java
incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestPollableSourceRunner.java
incubator/flume/branches/flume-728/flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroLegacy/TestLegacyAvroSource.java
incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/conf/properties/TestPropertiesFileConfigurationProvider.java
Modified: incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelException.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelException.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelException.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/JdbcChannelException.java Mon Feb 13 04:03:36 2012
@@ -21,6 +21,8 @@ import org.apache.flume.ChannelException
public class JdbcChannelException extends ChannelException {
+ private static final long serialVersionUID = -5566109526732929679L;
+
public JdbcChannelException(String message) {
super(message);
}
Modified: incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/DerbySchemaHandler.java Mon Feb 13 04:03:36 2012
@@ -31,7 +31,6 @@ import java.util.ArrayList;
import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
-import java.util.Map;
import java.util.Set;
import javax.sql.DataSource;
Modified: incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/JdbcTransactionFactory.java Mon Feb 13 04:03:36 2012
@@ -17,12 +17,8 @@
*/
package org.apache.flume.channel.jdbc.impl;
-import java.sql.SQLException;
-
import javax.sql.DataSource;
-import org.apache.flume.channel.jdbc.JdbcChannelException;
-
public class JdbcTransactionFactory extends ThreadLocal<JdbcTransactionImpl> {
private final DataSource dataSource;
Modified: incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/main/java/org/apache/flume/channel/jdbc/impl/PersistableEvent.java Mon Feb 13 04:03:36 2012
@@ -324,6 +324,7 @@ public class PersistableEvent implements
}
}
+ @SuppressWarnings("unused")
private static class HeaderPart {
private final String hBaseName;
private final String hBaseValue;
Modified: incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-channels/flume-jdbc-channel/src/test/java/org/apache/flume/channel/jdbc/TestJdbcChannelProvider.java Mon Feb 13 04:03:36 2012
@@ -25,7 +25,6 @@ import java.util.HashSet;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
-import java.util.Properties;
import java.util.Set;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MemoryChannel.java Mon Feb 13 04:03:36 2012
@@ -26,12 +26,10 @@ import java.util.concurrent.locks.Condit
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
-import org.apache.flume.Channel;
import org.apache.flume.ChannelException;
import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.Transaction;
-import org.apache.flume.conf.Configurable;
import com.google.common.base.Preconditions;
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/MultiplexingChannelSelector.java Mon Feb 13 04:03:36 2012
@@ -38,6 +38,7 @@ public class MultiplexingChannelSelector
"flume.selector.header";
public static final String CONFIG_PREFIX_MAPPING = "mapping";
+ @SuppressWarnings("unused")
private static final Logger LOG = LoggerFactory
.getLogger(MultiplexingChannelSelector.class);
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/channel/PseudoTxnMemoryChannel.java Mon Feb 13 04:03:36 2012
@@ -26,7 +26,6 @@ import org.apache.flume.ChannelException
import org.apache.flume.Context;
import org.apache.flume.Event;
import org.apache.flume.Transaction;
-import org.apache.flume.conf.Configurable;
import com.google.common.base.Preconditions;
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/client/avro/AvroCLIClient.java Mon Feb 13 04:03:36 2012
@@ -145,12 +145,12 @@ public class AvroCLIClient {
AvroFlumeEvent avroEvent = new AvroFlumeEvent();
- avroEvent.headers = new HashMap<CharSequence, CharSequence>();
- avroEvent.body = ByteBuffer.wrap(line.getBytes());
+ avroEvent.setHeaders(new HashMap<CharSequence, CharSequence>());
+ avroEvent.setBody(ByteBuffer.wrap(line.getBytes()));
eventBuffer.add(avroEvent);
- sentBytes += avroEvent.body.capacity();
+ sentBytes += avroEvent.getBody().capacity();
sent++;
long now = System.currentTimeMillis();
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/sink/AvroSink.java Mon Feb 13 04:03:36 2012
@@ -22,9 +22,9 @@ package org.apache.flume.sink;
import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
-import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
+import java.util.Map;
import java.util.Map.Entry;
import org.apache.avro.AvroRemoteException;
@@ -46,6 +46,7 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.google.common.base.Preconditions;
+import com.google.common.collect.Maps;
/**
* <p>
@@ -228,13 +229,13 @@ public class AvroSink extends AbstractSi
AvroFlumeEvent avroEvent = new AvroFlumeEvent();
- avroEvent.body = ByteBuffer.wrap(event.getBody());
- avroEvent.headers = new HashMap<CharSequence, CharSequence>();
+ avroEvent.setBody(ByteBuffer.wrap(event.getBody()));
+ Map<CharSequence, CharSequence> headers = Maps.newHashMap();
for (Entry<String, String> entry : event.getHeaders().entrySet()) {
- avroEvent.headers.put(entry.getKey(), entry.getValue());
+ headers.put(entry.getKey(), entry.getValue());
}
-
+ avroEvent.setHeaders(headers);
batch.add(avroEvent);
}
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/AvroSource.java Mon Feb 13 04:03:36 2012
@@ -38,7 +38,6 @@ import org.apache.flume.CounterGroup;
import org.apache.flume.Event;
import org.apache.flume.EventDrivenSource;
import org.apache.flume.Source;
-import org.apache.flume.Transaction;
import org.apache.flume.conf.Configurable;
import org.apache.flume.event.EventBuilder;
import org.apache.flume.source.avro.AvroFlumeEvent;
@@ -164,13 +163,13 @@ public class AvroSource extends Abstract
Map<String, String> headers = new HashMap<String, String>();
- for (Entry<CharSequence, CharSequence> entry : avroEvent.headers
+ for (Entry<CharSequence, CharSequence> entry : avroEvent.getHeaders()
.entrySet()) {
headers.put(entry.getKey().toString(), entry.getValue().toString());
}
- Event event = EventBuilder.withBody(avroEvent.body.array(), headers);
+ Event event = EventBuilder.withBody(avroEvent.getBody().array(), headers);
try {
getChannelProcessor().processEvent(event);
@@ -192,13 +191,13 @@ public class AvroSource extends Abstract
for (AvroFlumeEvent avroEvent : events) {
Map<String, String> headers = new HashMap<String, String>();
- for (Entry<CharSequence, CharSequence> entry : avroEvent.headers
+ for (Entry<CharSequence, CharSequence> entry : avroEvent.getHeaders()
.entrySet()) {
headers.put(entry.getKey().toString(), entry.getValue().toString());
}
- Event event = EventBuilder.withBody(avroEvent.body.array(), headers);
+ Event event = EventBuilder.withBody(avroEvent.getBody().array(), headers);
counterGroup.incrementAndGet("rpc.events");
batch.add(event);
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/source/ExecSource.java Mon Feb 13 04:03:36 2012
@@ -28,13 +28,10 @@ import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import org.apache.flume.Channel;
-import org.apache.flume.ChannelException;
import org.apache.flume.Context;
import org.apache.flume.CounterGroup;
-import org.apache.flume.Event;
import org.apache.flume.EventDrivenSource;
import org.apache.flume.Source;
-import org.apache.flume.Transaction;
import org.apache.flume.channel.ChannelProcessor;
import org.apache.flume.conf.Configurable;
import org.apache.flume.event.EventBuilder;
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestAvroSource.java Mon Feb 13 04:03:36 2012
@@ -145,8 +145,8 @@ public class TestAvroSource {
AvroFlumeEvent avroEvent = new AvroFlumeEvent();
- avroEvent.headers = new HashMap<CharSequence, CharSequence>();
- avroEvent.body = ByteBuffer.wrap("Hello avro".getBytes());
+ avroEvent.setHeaders(new HashMap<CharSequence, CharSequence>());
+ avroEvent.setBody(ByteBuffer.wrap("Hello avro".getBytes()));
Status status = client.append(avroEvent);
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestDefaultSourceFactory.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestDefaultSourceFactory.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestDefaultSourceFactory.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestDefaultSourceFactory.java Mon Feb 13 04:03:36 2012
@@ -21,10 +21,8 @@ package org.apache.flume.source;
import java.util.Map;
-import org.apache.flume.Channel;
import org.apache.flume.Source;
import org.apache.flume.SourceFactory;
-import org.apache.flume.lifecycle.LifecycleState;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestExecSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestExecSource.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestExecSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestExecSource.java Mon Feb 13 04:03:36 2012
@@ -74,7 +74,6 @@ public class TestExecSource {
transaction.begin();
Event event;
- int numEvents = 0;
FileOutputStream outputStream = new FileOutputStream(
"/tmp/flume-execsource." + Thread.currentThread().getId());
@@ -82,7 +81,6 @@ public class TestExecSource {
while ((event = channel.take()) != null) {
outputStream.write(event.getBody());
outputStream.write('\n');
- numEvents++;
}
outputStream.close();
Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestPollableSourceRunner.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestPollableSourceRunner.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestPollableSourceRunner.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestPollableSourceRunner.java Mon Feb 13 04:03:36 2012
@@ -19,7 +19,6 @@
package org.apache.flume.source;
-import java.util.List;
import java.util.concurrent.CountDownLatch;
import org.apache.flume.Channel;
Modified: incubator/flume/branches/flume-728/flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroLegacy/TestLegacyAvroSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroLegacy/TestLegacyAvroSource.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroLegacy/TestLegacyAvroSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-legacy-sources/flume-avro-source/src/test/java/org/apache/flume/source/avroLegacy/TestLegacyAvroSource.java Mon Feb 13 04:03:36 2012
@@ -53,6 +53,7 @@ import org.slf4j.LoggerFactory;
public class TestLegacyAvroSource {
+ @SuppressWarnings("unused")
private static final Logger logger = LoggerFactory
.getLogger(TestLegacyAvroSource.class);
Modified: incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/conf/properties/TestPropertiesFileConfigurationProvider.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/conf/properties/TestPropertiesFileConfigurationProvider.java?rev=1243410&r1=1243409&r2=1243410&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/conf/properties/TestPropertiesFileConfigurationProvider.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-node/src/test/java/org/apache/flume/conf/properties/TestPropertiesFileConfigurationProvider.java Mon Feb 13 04:03:36 2012
@@ -32,6 +32,7 @@ public class TestPropertiesFileConfigura
TestPropertiesFileConfigurationProvider.class.getClassLoader()
.getResource("flume-conf.properties").getFile());
+ @SuppressWarnings("unused")
private static final Logger LOGGER = LoggerFactory
.getLogger(TestPropertiesFileConfigurationProvider.class);