Flink: Backport PR #10526 to v1.18 and v1.20#11018
Conversation
|
@zhongqishang: |
|
|
||
| harness.processElement(of(dataFile1), ++timestamp); | ||
| long firstCheckpointId = 1; | ||
| harness.processElement(of(firstCheckpointId, dataFile1), ++timestamp); |
There was a problem hiding this comment.
@pvary When apply V1.20 patch, a misalignment occurred.
But I don't know what caused it, so I fixed it manually.
There was a problem hiding this comment.
I think this is related to @rodmeneses's last commit.
Could you please check @rodmeneses?
Thanks,
Peter
There was a problem hiding this comment.
e6f8ab9#diff-4f79d5342dad9de47d561297e1af60aac21a498f22144ad378dc762affdbfa27L142-L143
Yes, thanks for your reminder.
It should be the modification of TestIcebergFilesCommitter.java that caused the inconsistent line numbers.
|
I via the follow cmd to check the diff There is no difference between 1.19 and 1.20. |
|
Merged to main. Thanks for the backport @zhongqishang! |
* main: (208 commits) Docs: Fix Flink 1.20 support versions (apache#11065) Flink: Fix compile warning (apache#11072) Docs: Initial committer guidelines and requirements for merging (apache#10780) Core: Refactor ZOrderByteUtils (apache#10624) API: implement types timestamp_ns and timestamptz_ns (apache#9008) Build: Bump com.google.errorprone:error_prone_annotations (apache#11055) Build: Bump mkdocs-material from 9.5.33 to 9.5.34 (apache#11062) Flink: Backport PR apache#10526 to v1.18 and v1.20 (apache#11018) Kafka Connect: Disable publish tasks in runtime project (apache#11032) Flink: add unit tests for range distribution on bucket partition column (apache#11033) Spark 3.5: Use FileGenerationUtil in PlanningBenchmark (apache#11027) Core: Add benchmark for appending files (apache#11029) Build: Ignore benchmark output folders across all modules (apache#11030) Spec: Add RemovePartitionSpecsUpdate REST update type (apache#10846) Docs: bump latest version to 1.6.1 (apache#11036) OpenAPI, Build: Apply spotless to testFixtures source code (apache#11024) Core: Generate realistic bounds in benchmarks (apache#11022) Add REST Compatibility Kit (apache#10908) Flink: backport PR apache#10832 of inferring parallelism in FLIP-27 source (apache#11009) Docs: Add Druid docs url to sidebar (apache#10997) ...
(cherry picked from commit e8c6148)
Backport PR #10526