B. Todd Burruss created FLUME-2290: -------------------------------------- Summary: AbstractRpcSink does not properly shutdown the cxnResetExecutor executor and its tasks Key: FLUME-2290 URL: https://issues.apache.org/jira/browse/FLUME-2290 Project: Flume Issue Type: Bug Affects Versions: v1.4.0 Environment: Linux java version "1.6.0_38" Java(TM) SE Runtime Environment (build 1.6.0_38-b05) Java HotSpot(TM) 64-Bit Server VM (build 20.13-b02, mixed mode)
Reporter: B. Todd Burruss in the AbstactRpcSink.stop() method, cxnResetExecutor.shutdown() is called, but this will not terminate scheduled tasks. you must explicitly cancel the task. however, i believe you guys tried to handle this because of the call to cxnResetExecutor.awaitTermination(), but mishandled the return code. if "false" is returned you want to call cxnResetExecutor.shutdownNow(), not if true is returned. my recommendation is to capture the ScheduledFuture returned and cancel the task explicitly after calling cxnResetExecutor.shutdown(). then if awaitTermination still doesn't work, call cxnResetExecutor.shutdownNow() -- This message was sent by Atlassian JIRA (v6.1.5#6160)