Skip to content

[Hudi-6318]The skip merge config for incremental-read ensures consistency in both stream and batch scenarios#8891

Open
zhuanshenbsj1 wants to merge 2 commits intoapache:masterfrom
zhuanshenbsj1:HUDI-6318
Open

[Hudi-6318]The skip merge config for incremental-read ensures consistency in both stream and batch scenarios#8891
zhuanshenbsj1 wants to merge 2 commits intoapache:masterfrom
zhuanshenbsj1:HUDI-6318

Conversation

@zhuanshenbsj1
Copy link
Contributor

@zhuanshenbsj1 zhuanshenbsj1 commented Jun 6, 2023

Change Logs

For example:

timeline: commit1, commit2, cluster1, commit3, commit4

I actually want to know what new data has been ingested upstream of commit2->commit4 through incremental reading in batch mode. If cluster1 is included, the old data belong to cluster1 will still be read once. If there are too many files, it will also have an invalid performance loss. So there should be an optional optimization option like stream mode

Impact

Describe any public API or user-facing feature change or any performance impact.

Risk level (write none, low medium or high below)

If medium or high, explain what verification was done to mitigate the risks.

Documentation Update

Describe any necessary documentation update if there is any new feature, config, or user-facing change

  • The config description must be updated if new configs are added or the default value of the configs are changed
  • Any new feature or user-facing change requires updating the Hudi website. Please create a Jira ticket, attach the
    ticket number here and follow the instruction to make
    changes to the website.

Contributor's checklist

  • Read through contributor's guide
  • Change Logs and Impact were stated clearly
  • Adequate tests were added if applicable
  • CI passed

.rowType(this.tableRowType)
.maxCompactionMemoryInBytes(maxCompactionMemoryInBytes)
.partitionPruner(partitionPruner)
.skipCompaction(conf.getBoolean(FlinkOptions.READ_STREAMING_SKIP_COMPACT))
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The read.streaming.skip_compaction and read.streaming.skip_clustering is the option of streaming read, not batch read.

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

The read.streaming.skip_compaction and read.streaming.skip_clustering is the option of streaming read, not batch read.

We can add a similar batch configuration.

@yihua yihua added the engine:flink Flink integration label Jun 15, 2023
@hudi-bot
Copy link
Collaborator

hudi-bot commented Jul 4, 2023

CI report:

Bot commands @hudi-bot supports the following commands:
  • @hudi-bot run azure re-run the last Azure build

@zhuanshenbsj1 zhuanshenbsj1 requested a review from SteNicholas July 5, 2023 09:42
@github-actions github-actions bot added the size:S PR with lines of changes in (10, 100] label Feb 26, 2024
@yihua yihua added the area:table-service Table services label Mar 26, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

area:table-service Table services engine:flink Flink integration size:S PR with lines of changes in (10, 100]

Projects

Status: 🆕 New

Development

Successfully merging this pull request may close these issues.

4 participants