Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

#

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Jump to bottom

[Feature][Flink Stream] Use flink SDK replace the shell cli #11440

Closed
3 tasks done
shangeyao opened this issue Aug 12, 2022 · 4 comments
Closed
3 tasks done

[Feature][Flink Stream] Use flink SDK replace the shell cli #11440

shangeyao opened this issue Aug 12, 2022 · 4 comments
Assignees
@shangeyao
Labels
discussion discussion feature new feature
Milestone
3.3.0

Comments

@shangeyao
Copy link
Contributor

Search before asking

  • I had searched in the issues and found no similar feature requirement.

Description

I want to participate in it.
relate to #11352

Use case

No response

Related issues

No response

Are you willing to submit a PR?

  • Yes I am willing to submit a PR!

Code of Conduct
@shangeyao shangeyao added feature new feature Waiting for reply Waiting for reply labels Aug 12, 2022
@github-actions
Copy link

Thank you for your feedback, we have received your issue, Please wait patiently for a reply.

  • In order for us to understand your request as soon as possible, please provide detailed information、version or pictures.
  • If you haven't received a reply for a long time, you can join our slack and send your question to channel #troubleshooting

@ruanwenjun ruanwenjun added discussion discussion and removed Waiting for reply Waiting for reply labels Aug 12, 2022
@ruanwenjun
Copy link
Member

Could you please provide a detailed design?

@caishunfeng caishunfeng added this to the 3.1.0 milestone Aug 12, 2022
@caishunfeng caishunfeng mentioned this issue Aug 12, 2022
Closed
9 tasks
@shangeyao
Copy link
Contributor Author

1.Use flink-client to submit tasks instead of the current shell cli
2.Distinguish submission methods and parameters in three environments（Standalone Yarn K8S）
3.Use the job ID to cancel and save point

For details, please refer to the following doc:
https://nightlies.apache.org/flink/flink-docs-release-1.15/api/java/org/apache/flink/client/program/ClusterClient.html

@shangeyao
Copy link
Contributor Author

Expected flink SDK version：1.15.1

@shangeyao shangeyao mentioned this issue Sep 14, 2022
Closed
@caishunfeng caishunfeng modified the milestones: 3.1.0, 3.2.0 Sep 27, 2022
@zhongjiajie zhongjiajie modified the milestones: 3.2.0, 3.3.0 Aug 30, 2023
# for free to join this conversation on GitHub. Already have an account? # to comment
Assignees

@shangeyao shangeyao

Labels
discussion discussion feature new feature
Projects
None yet
Milestone
3.3.0
Development

Successfully merging a pull request may close this issue.

[Feature-11440][Flink Stream] Use flink SDK replace the shell cli shangeyao/dolphinscheduler
5 participants
@caishunfeng @zhongjiajie @SbloodyS @ruanwenjun @shangeyao