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

[Amoro-3237] Generalize TaskRuntime to support more task types #3238

Merged
merged 13 commits into from
Oct 11, 2024

Conversation

majin1102
Copy link
Contributor

Why are the changes needed?

Close #3237.

Brief change log

How was this patch tested?

  • Add some test cases that check the changes thoroughly including negative and positive cases if possible

  • Add screenshots for manual tests if appropriate

  • Run test locally before making a pull request

Documentation

  • Does this pull request introduce a new feature? (yes / no)
  • If yes, how is the feature documented? (not applicable / docs / JavaDocs / not documented)

@github-actions github-actions bot added the module:ams-server Ams server module label Oct 8, 2024
@majin1102 majin1102 changed the title Generalize TaskRuntime to support more task types [Amoro-3237]Generalize TaskRuntime to support more task types Oct 8, 2024
@majin1102 majin1102 changed the title [Amoro-3237]Generalize TaskRuntime to support more task types [Amoro-3237] Generalize TaskRuntime to support more task types Oct 8, 2024
@majin1102 majin1102 requested review from zhoujinsong, zhongqishang and baiyangtx and removed request for zhoujinsong and zhongqishang October 9, 2024 03:29
public ExecutingStageTask(
long tableId, String partition, RewriteFilesInput input, Map<String, String> properties) {
super(tableId, input, properties);
this.partition = partition;
Copy link
Contributor

Choose a reason for hiding this comment

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

Persistence is required, otherwise information will be lost after recover.

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Persistence logic has not been modified.
Please check it in TaskRuntime.persistTaskRuntime()

Copy link
Contributor

@zhoujinsong zhoujinsong left a comment

Choose a reason for hiding this comment

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

@majin1102 Thanks for the work!
This is a good start to support more task types.
I left some small suggestions, PTAL.

Copy link
Contributor

@zhoujinsong zhoujinsong left a comment

Choose a reason for hiding this comment

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

LGTM.

@zhoujinsong zhoujinsong merged commit 8e23c89 into apache:master Oct 11, 2024
4 checks passed
@majin1102 majin1102 deleted the task-refactor branch October 11, 2024 11:40
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
module:ams-server Ams server module
Projects
None yet
Development

Successfully merging this pull request may close these issues.

[Subtask]: Generalize TaskRuntime to support more task types that can be delegated to the optimizer.
3 participants