Updated Branches:
  refs/heads/flume-1.3.0 7d8499ef3 -> c64975d60

FLUME-1555: StressSource outputs bad log messages that reference (Sequence 
generator)

(Ted Malaska via Brock Noland)


Project: http://git-wip-us.apache.org/repos/asf/flume/repo
Commit: http://git-wip-us.apache.org/repos/asf/flume/commit/c64975d6
Tree: http://git-wip-us.apache.org/repos/asf/flume/tree/c64975d6
Diff: http://git-wip-us.apache.org/repos/asf/flume/diff/c64975d6

Branch: refs/heads/flume-1.3.0
Commit: c64975d602aea69b4f27764a29144b0b899559a2
Parents: 7d8499e
Author: Brock Noland <[email protected]>
Authored: Mon Sep 10 13:09:46 2012 -0500
Committer: Brock Noland <[email protected]>
Committed: Mon Sep 10 13:14:31 2012 -0500

----------------------------------------------------------------------
 .../java/org/apache/flume/source/StressSource.java |    8 ++++----
 1 files changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flume/blob/c64975d6/flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
----------------------------------------------------------------------
diff --git 
a/flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java 
b/flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
index ba6f54a..b4a00f5 100644
--- a/flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
+++ b/flume-ng-core/src/main/java/org/apache/flume/source/StressSource.java
@@ -133,19 +133,19 @@ public class StressSource extends AbstractSource 
implements
 
   @Override
   public void start() {
-    logger.info("Sequence generator source starting");
+    logger.info("Stress source starting");
 
     super.start();
 
-    logger.debug("Sequence generator source started");
+    logger.debug("Stress source started");
   }
 
   @Override
   public void stop() {
-    logger.info("Sequence generator source stopping");
+    logger.info("Stress source stopping");
 
     super.stop();
 
-    logger.info("Sequence generator source stopped. Metrics:{}", counterGroup);
+    logger.info("Stress source stopped. Metrics:{}", counterGroup);
   }
 }

Reply via email to