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: Fix duplicate data with upsert writer in case of aborted checkpoints #10526

Merged
merged 8 commits into from
Aug 26, 2024
Merged

Flink: Fix duplicate data with upsert writer in case of aborted checkpoints #10526

merged 8 commits into from
Aug 26, 2024

Commits on Aug 24, 2024

  1. Flink: Fix duplicate data in Flink's upsert writer for format V2 

    # Conflicts:
#	flink/v1.19/flink/src/main/java/org/apache/iceberg/flink/sink/FlinkSink.java
#	flink/v1.19/flink/src/test/java/org/apache/iceberg/flink/sink/TestIcebergStreamWriter.java
    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    1f95701 View commit details
    Browse the repository at this point in the history

  2. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    25ae701 View commit details
    Browse the repository at this point in the history

  3. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    f50ba4b View commit details
    Browse the repository at this point in the history

  4. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    f1cbf5f View commit details
    Browse the repository at this point in the history

  5. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    5999740 View commit details
    Browse the repository at this point in the history

  6. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    4758461 View commit details
    Browse the repository at this point in the history

  7. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    80a68b5 View commit details
    Browse the repository at this point in the history

  8. fix comments

    @zhongqishang
    zhongqishang committed Aug 24, 2024
    Configuration menu
    Copy the full SHA
    6b004f5 View commit details
    Browse the repository at this point in the history