Flume
  1. Flume
  2. FLUME-2305

BucketWriter#close must cancel idleFuture

    Details

    • Type: Bug Bug
    • Status: Resolved
    • Priority: Major Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: v1.5.0
    • Component/s: None
    • Labels:
      None

      Description

      We use a ScheduledExecutorService to close the files after a time period. If the task has been submitted, the service does not cancel that task by default. In the ScheduledThreadPoolExecutor class: this field "executeExistingDelayedTasksAfterShutdown" is set to true, by default - which causes the task to be executed even if the executor was shutdown.

      If we don't cancel it, the agent does not die till idleTimeout even though every other component is stopped.

      1. FLUME-2305.patch
        0.8 kB
        Hari Shreedharan

        Issue Links

          Activity

          No work has yet been logged on this issue.

            People

            • Assignee:
              Hari Shreedharan
              Reporter:
              Hari Shreedharan
            • Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved:

                Development