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

[Feature] JobState component in launcher module #25

Merged

Conversation

Davidhua1996
Copy link
Collaborator

What is the purpose of the change

Adjust the architecture of job launcher module and append the interface of job state. close #23

Brief change log

  • Append JobStateManager into JobLauncherManager interface.
  • Add JobStateFetchers to fetch the checkpoint or savepoint information of Flink job in different ways.

Documentation

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

Copy link
Collaborator

@wushengyeyouya wushengyeyouya left a comment

Choose a reason for hiding this comment

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

LGTM.

@wushengyeyouya wushengyeyouya merged commit ba9a890 into WeBankFinTech:dev-0.2.0 Jun 16, 2022
@Davidhua1996 Davidhua1996 deleted the dev-0.2.0-jobstate-interface branch June 17, 2022 03:09
yangwenzea pushed a commit to WeDataSphere/Streamis that referenced this pull request Sep 15, 2023
…ate-interface

[Feature] JobState component in launcher module
Alexkun pushed a commit to WeDataSphere/Streamis that referenced this pull request Jun 5, 2024
…ate-interface

[Feature] JobState component in launcher module
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants