flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From esam...@apache.org
Subject svn commit: r1159012 - /incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java
Date Thu, 18 Aug 2011 03:26:06 GMT
Author: esammer
Date: Thu Aug 18 03:26:06 2011
New Revision: 1159012

URL: http://svn.apache.org/viewvc?rev=1159012&view=rev
Log:
- Allow a LogicalNode in an error state to be stopped (to clean up remaining resources like
thread pools).

Modified:
    incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java

Modified: incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java
URL: http://svn.apache.org/viewvc/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java?rev=1159012&r1=1159011&r2=1159012&view=diff
==============================================================================
--- incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java
(original)
+++ incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java
Thu Aug 18 03:26:06 2011
@@ -134,9 +134,6 @@ public class LogicalNode implements Life
   public void stop(Context context) throws LifecycleException,
       InterruptedException {
 
-    Preconditions.checkState(LifecycleState.START.equals(lifecycleState),
-        "It is illegal to stop something that isn't running");
-
     logger.info("Stopping logical node:{}", this);
 
     if (driver.getLifecycleState().equals(LifecycleState.START)) {



Mime
View raw message