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/18 05:26:06 UTC
svn commit: r1159012 -
/incubator/flume/branches/flume-728/flume-ng-core/src/main/java/org/apache/flume/LogicalNode.java
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)) {