Dagang Wei

I think it's okay to use `k8s.io` if that's the only option.

Thanks for the PRs! Let me know when it is ready for review.

The design choice of `flink run` was made because it is easy to integrate with the operator. I don't find `java org.apache.flink.container.entrypoint.StandaloneJobClusterEntryPoint` provides additional benefits. I'd like to know why...

Did you try creating a Uber jar with dependencies for your job?

Previously, I thought about job CRD even for job clusters, but that means users have to deal with 2 CRDs, but I want to keep things simple, that's why I...

With job CRD, how do you model Beam job?

The Flink docker-entrypoint.sh might try to edit flink-config.yaml with runtime values in some cases, when using the operator, we should avoid relying on these runtime values, instead declare them in...

I'm thinking about making /opt/flink/conf/flink-conf.yaml editable, one solution could be: mount the configmap to another location (say /tmp/flink-conf) first, then use an init container to copy it over to the...

Great, thanks!

I think it is okay to add a default init container to JM/TM.