Uploaded image for project: 'Flume'
  1. Flume
  2. FLUME-2328

FileChannel Dual Checkpoint Backup Thread not released on Application stop

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 1.4.0
    • Fix Version/s: 1.5.0
    • Component/s: File Channel
    • Labels:
      None

      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

        Attachments

        1. FLUME-2328.patch
          1 kB
          Hari Shreedharan

          Activity

            People

            • Assignee:
              hshreedharan Hari Shreedharan
              Reporter:
              arajput Arun
            • Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: