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.

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

[FLINK-21132][runtime] Don't end input on stop with savepoint #14815

Merged
merged 5 commits into from
Feb 3, 2021

Commits on Feb 2, 2021

  1. [FLINK-21132][runtime] Don't end input on stop with savepoint

    EndOfInput was used to handle any stopping of the job. When
    stopping with savepoint the input is not actually ended.
    This causes issues with some sinks (e.g. Iceberg).
    
    With this change, endInput is not call for stop-with-savepoint.
    
    To differentiate stop-with-savepoint from other cases
    only checkpoint (RPC/barriers) are considered and not network EOP.
    That's enough because EOP is only injected after the CP completion
    (i.e. when the downstream is also notified by sync savepoint by CP
    barriers).
    rkhachatryan committed Feb 2, 2021
    Configuration menu
    Copy the full SHA
    baa05e1 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    06e05bb View commit details
    Browse the repository at this point in the history
  3. Configuration menu
    Copy the full SHA
    bb89788 View commit details
    Browse the repository at this point in the history

Commits on Feb 3, 2021

  1. Configuration menu
    Copy the full SHA
    07d8465 View commit details
    Browse the repository at this point in the history
  2. Configuration menu
    Copy the full SHA
    0527a31 View commit details
    Browse the repository at this point in the history