Skip to content

feat: Migrating Flink-emr-eks to V2#929

Closed
bbgu1 wants to merge 4 commits intoawslabs:v2from
bbgu1:v2
Closed

feat: Migrating Flink-emr-eks to V2#929
bbgu1 wants to merge 4 commits intoawslabs:v2from
bbgu1:v2

Conversation

@bbgu1
Copy link
Copy Markdown
Contributor

@bbgu1 bbgu1 commented Jan 5, 2026

What does this PR do?

Migrating Flink-on-EMR-on-EKS pattern to V2

🛑 Please open an issue first to discuss any significant work and flesh out details/direction. When we triage the issues, we will add labels to the issue like "Enhancement", "Bug" which should indicate to you that this issue can be worked on and we are looking forward to your PR. We would hate for your time to be wasted.
Consult the CONTRIBUTING guide for submitting pull-requests.

Motivation

More

  • Yes, I have tested the PR using my local account setup (Provide any test evidence report under Additional Notes)
  • Mandatory for new blueprints. Yes, I have added a example to support my blueprint PR
  • Mandatory for new blueprints. Yes, I have updated the website/docs or website/blog section for this feature
  • Yes, I ran pre-commit run -a with this PR. Link for installing pre-commit locally

For Moderators

  • E2E Test successfully complete before merge?

Additional Notes

The same EMR-on-EKS infrastructure can be used for emr-eks-spark as well.

@nabuskey
Copy link
Copy Markdown
Collaborator

@bbgu1 Thanks for the PR! Will you please rebase your PR so that we can merge your changes to EMR on EKS datastack?

@bbgu1
Copy link
Copy Markdown
Contributor Author

bbgu1 commented Jan 13, 2026

@bbgu1 Thanks for the PR! Will you please rebase your PR so that we can merge your changes to EMR on EKS datastack?

resolved the conflict - ready for merge now

# IRSA for flink pods for "flink-team-a"
#---------------------------------------------------------------
module "flink_irsa_jobs" {
source = "aws-ia/eks-blueprints-addon/aws"
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

We need to move away from eks-blueprints-addon and IRSA (where possible). Something like this: https://github.com/awslabs/data-on-eks/blob/v2/infra/terraform/datahub.tf

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

Move these resources to https://github.com/awslabs/data-on-eks/blob/v2/infra/terraform/emr-on-eks-flink.tf and a conditon of enable_emr_on_eks_flink=true

@@ -0,0 +1,171 @@
resource "kubernetes_namespace_v1" "flink_team_a" {
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

See if we can reuse the existing teams created for EMR Spark. We can use the same users instead of creating a new one for flink. https://github.com/awslabs/data-on-eks/blob/804202e2d7c13095c3fbdc42ea45db93d459b2fe/infra/terraform/emr-on-eks-spark.tf#L7C1-L76C2

#---------------------------------------------------------------
# S3 bucket for Flink related data,logs and checkpoint
#---------------------------------------------------------------
module "flink_s3_bucket" {
Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

EMR on EKS stack is creating s3 bucket which we can reuse for Flink as well

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

Move these resources to https://github.com/awslabs/data-on-eks/blob/v2/infra/terraform/emr-on-eks-flink.tf and a condition of enable_emr_on_eks_flink=true

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

rebase from v2

Copy link
Copy Markdown
Collaborator

Choose a reason for hiding this comment

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

rebase from v2

@vara-bonthu vara-bonthu deleted the branch awslabs:v2 February 3, 2026 22:48
@vara-bonthu vara-bonthu closed this Feb 3, 2026
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.

3 participants