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-18990][task] Read channel state sequentially #13351

Merged
merged 8 commits into from
Oct 9, 2020
Merged

[FLINK-18990][task] Read channel state sequentially #13351

merged 8 commits into from
Oct 9, 2020

Commits on Oct 8, 2020

  1. [hotfix][tests] Report FailureReason in StreamTask tests

    @rkhachatryan
    rkhachatryan committed Oct 8, 2020
    Configuration menu
    Copy the full SHA
    a740234 View commit details
    Browse the repository at this point in the history

  2. [hotfix][tests] Return empty array of gates instead of null

    @rkhachatryan
    rkhachatryan committed Oct 8, 2020
    Configuration menu
    Copy the full SHA
    cc26964 View commit details
    Browse the repository at this point in the history

  3. [FLINK-19385] Request partitions for each inputGate independently

    @rkhachatryan
    rkhachatryan committed Oct 8, 2020
    Configuration menu
    Copy the full SHA
    e574b03 View commit details
    Browse the repository at this point in the history

  4. [task][refactor] Introduce InputChannel.setup 

    This removes casts to RemoteInputChannel and RecoveredInputChannel
    @rkhachatryan
    rkhachatryan committed Oct 8, 2020
    Configuration menu
    Copy the full SHA
    e4946c0 View commit details
    Browse the repository at this point in the history

  5. [FLINK-18989][task] Read channel state sequentially 

    Non-sequential state reader and the associated code will be removed in
subsequent commits.
    @rkhachatryan
    rkhachatryan committed Oct 8, 2020
    Configuration menu
    Copy the full SHA
    eee860a View commit details
    Browse the repository at this point in the history

Commits on Oct 9, 2020

  1. [FLINK-18989][task] Read channel state unconditionally 

    Motivation: reduce the required test coverage (tests will be removed in
a later commit).
    @rkhachatryan
    rkhachatryan committed Oct 9, 2020
    Configuration menu
    Copy the full SHA
    5dd1085 View commit details
    Browse the repository at this point in the history

  2. [FLINK-18989][task] Allow conversion of RecoveredInputChannel only af… 

    …ter state was fully consumed

Motivation:
1. Guarantee state is not lost
2. Reduce the required test coverage (tests will be removed in the next
commit)
    @rkhachatryan
    rkhachatryan committed Oct 9, 2020
    Configuration menu
    Copy the full SHA
    7cc1374 View commit details
    Browse the repository at this point in the history

  3. [FLINK-18989][task] Remove non-sequental ChannelStateReader and the r… 

    …elated code

- ChannelStateReader and supporting classes
- methods for channel state recovery in inputChannels, subpartitions, etc.
- tests for reading channel state non-sequentially
    @rkhachatryan
    rkhachatryan committed Oct 9, 2020
    Configuration menu
    Copy the full SHA
    c0b8f40 View commit details
    Browse the repository at this point in the history