Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

[FLINK-15467][task] Wait for invokable cancellation when stopping Task #12714

Closed
wants to merge 4 commits into from
Closed

[FLINK-15467][task] Wait for invokable cancellation when stopping Task #12714

wants to merge 4 commits into from

Commits on Jun 23, 2020

  1. [hotfix][task] Extract SourceStreamTask.LegacySourceFunctionRunner in… 

    …terface to facilitate testing
    @rkhachatryan
    rkhachatryan committed Jun 23, 2020
    Copy the full SHA
    7d6f3bf View commit details
    Browse the repository at this point in the history

  2. [FLINK-15467][task] Return future from StreamTask cancelTask/finishTask

    @rkhachatryan
    rkhachatryan committed Jun 23, 2020
    Copy the full SHA
    86452a6 View commit details
    Browse the repository at this point in the history

  3. [FLINK-15467][task] Return completion future from AbstractInvokable c… 

    …ancel
    @rkhachatryan
    rkhachatryan committed Jun 23, 2020
    Copy the full SHA
    6d3fe44 View commit details
    Browse the repository at this point in the history

  4. [FLINK-15467][task] Wait in Task.cancelInvokable for completion 

    Task.invokableCancelFuture is added instead of just joining the source thread in cancelTask.
This is because cancelTask can be called from TaskCanceller thread,
while resources are freed by Task.executingThread or upon it's death.
    @rkhachatryan
    rkhachatryan committed Jun 23, 2020
    Copy the full SHA
    0d85f9e View commit details
    Browse the repository at this point in the history