You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flume.apache.org by es...@apache.org on 2011/08/29 18:55:38 UTC

svn commit: r1162901 - /incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java

Author: esammer
Date: Mon Aug 29 16:55:38 2011
New Revision: 1162901

URL: http://svn.apache.org/viewvc?rev=1162901&view=rev
Log:
- Updated SequenceGeneratorSource tests to pass proper configuration info.

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java?rev=1162901&r1=1162900&r2=1162901&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java (original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/test/java/org/apache/flume/source/TestSequenceGeneratorSource.java Mon Aug 29 16:55:38 2011
@@ -4,6 +4,7 @@ import org.apache.flume.Context;
 import org.apache.flume.Event;
 import org.apache.flume.EventDeliveryException;
 import org.apache.flume.EventSource;
+import org.apache.flume.conf.Configurables;
 import org.apache.flume.lifecycle.LifecycleException;
 import org.junit.Assert;
 import org.junit.Before;
@@ -24,6 +25,10 @@ public class TestSequenceGeneratorSource
 
     Context context = new Context();
 
+    context.put("logicalNode.name", "test");
+
+    Configurables.configure(source, context);
+
     source.open(context);
 
     for (long i = 0; i < 100; i++) {