flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arv...@apache.org
Subject 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...
Date Mon, 13 Feb 2012 04:03:37 GMT
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);
 



Mime
View raw message