[FLUME-2328] FileChannel Dual Checkpoint Backup Thread not released on Application stop

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.4.0
• Fix Version/s: 1.5.0
• Component/s: File Channel
• Assignee: Hari Shreedharan
• Reporter: Arun
• Created: 20/Feb/14 14:37
• Updated: 28/Feb/14 23:59
• Resolved: 28/Feb/14 23:12

Description

In my application wired the filechannel with dual checkpoint enabled. Even after calling application.stop() i can see checkpoint backup thread is still in waiting state.
"[channel=c1] - CheckpointBackUpThread" prio=6 tid=0x3a069400 nid=0x8a4 waiting on condition [0x3b17f000]
Since i am usign java service wrapper to run application and for stopping service i am waiting all user threads to be released, service is not stopping gracefully even after waiting for 5 mins.

in code i can see checkpointBackUpExecutor is started
if (shouldBackup) {
checkpointBackUpExecutor = Executors.newSingleThreadExecutor( new ThreadFactoryBuilder().setNameFormat( getName() + " - CheckpointBackUpThread").build());
} else

{ checkpointBackUpExecutor = null; }

....

there is no shutdown call for checkpointBackUpExecutor in anywhere in EventQueueBackingStoreFile