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

[Umbrella][Feature] Flink Kubernetes Module V2 #2879

Open
10 of 11 tasks
Al-assad opened this issue Jul 22, 2023 · 5 comments
Open
10 of 11 tasks

[Umbrella][Feature] Flink Kubernetes Module V2 #2879

Al-assad opened this issue Jul 22, 2023 · 5 comments
Assignees
Labels
Milestone

Comments

@Al-assad
Copy link
Member

Al-assad commented Jul 22, 2023

Code of Conduct

Search before asking

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

Describe the proposal

Due to many issues with the current version of StreamPark Flink on Kubernetes in terms of submitting and tracking tasks, we hope to refactor the entire module based on the Flink Kubernetes Operator to better address the following problems:

  • Inaccurate and confusing tracking of Flink on Kubernetes status;
  • Unstable and lengthy Flink K8s Application Job submission process;
  • Scattered Event Watcher thread pool code;

Resources

Task list

Dependency relationship of subtasks

#2880#2881#2882, #2883, #2884, #2885#2887

Are you willing to submit PR?

  • Yes I am willing to submit a PR!
@Al-assad
Copy link
Member Author

@ChengJie1053 @caicancai
Hey Bros, If you're totally stoked about tasks #2883 to #2887, they're all yours for the taking! Just claim 'em right here! 😆

@caicancai
Copy link
Member

@Al-assad i pick #2883 and #2884

@caicancai
Copy link
Member

caicancai commented Aug 12, 2023

@ChengJie1053 @caicancai Hey Bros, If you're totally stoked about tasks #2883 to #2887, they're all yours for the taking! Just claim 'em right here! 😆

@Al-assad It should be #2882 to #2887,I guessed at the beginning that I wanted to pick #2882, #2883. Now I guess I can pick #2882 to #2884

@Al-assad
Copy link
Member Author

@ChengJie1053 @caicancai Hey Bros, If you're totally stoked about tasks #2883 to #2887, they're all yours for the taking! Just claim 'em right here! 😆

@Al-assad It should be #2882 to #2887,I guessed at the beginning that I wanted to pick #2882, #2883. Now I guess I can pick #2882 to #2884

Sure, Looking forward to your PRs 😆

@ChengJie1053
Copy link
Member

@Al-assad i pick #2885 to #2887

Al-assad added a commit to Al-assad/incubator-streampark that referenced this issue Sep 13, 2023
Al-assad added a commit to Al-assad/incubator-streampark that referenced this issue Sep 13, 2023
Al-assad added a commit to Al-assad/incubator-streampark that referenced this issue Sep 13, 2023
wolfboys pushed a commit that referenced this issue Sep 14, 2023
wolfboys pushed a commit that referenced this issue Sep 22, 2023
…function reference (#3164)

* [feat][flink-k8s-v2] Migrate the creation process of the flink deploy ingress to the Flink kubernetes operator (#2879)

* Fix the error type conversion of streampark.flink-k8s.enable-v2.

* Fix the issue of Scala calling Mybatis LambdaWrapper with Java function reference parameters.

* Resolve conflict

* Format code
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

4 participants