Path Lines of Code apis/flinkcluster/v1beta1/flinkcluster_default.go 131 apis/flinkcluster/v1beta1/flinkcluster_types.go 354 apis/flinkcluster/v1beta1/flinkcluster_types_util.go 125 apis/flinkcluster/v1beta1/flinkcluster_validate.go 488 apis/flinkcluster/v1beta1/flinkcluster_webhook.go 35 apis/flinkcluster/v1beta1/groupversion_info.go 10 apis/flinkcluster/v1beta1/zz_generated.deepcopy.go 1002 config/certmanager/certificate.yaml 21 config/certmanager/kustomization.yaml 4 config/certmanager/kustomizeconfig.yaml 14 config/crd/bases/flinkoperator.k8s.io_flinkclusters.yaml 9445 config/crd/kustomization.yaml 8 config/crd/kustomizeconfig.yaml 16 config/crd/patches/cainjection_in_flinkclusters.yaml 6 config/crd/patches/crd_protection.yaml 6 config/crd/patches/webhook_in_flinkclusters.yaml 15 config/default-sharded/kustomization.yaml 46 config/default-sharded/manager_auth_proxy_patch.yaml 26 config/default-sharded/manager_config_patch.yaml 14 config/default-sharded/manager_webhook_patch.yaml 23 config/default-sharded/mutation_webhook_namespace_selector_patch.yaml 12 config/default-sharded/validation_webhook_namespace_selector_patch.yaml 12 config/default-sharded/webhookcainjection_patch.yaml 13 config/default/kustomization.yaml 46 config/default/manager_auth_proxy_patch.yaml 26 config/default/manager_config_patch.yaml 14 config/default/manager_webhook_patch.yaml 23 config/default/mutation_webhook_namespace_selector_patch.yaml 12 config/default/validation_webhook_namespace_selector_patch.yaml 12 config/default/webhookcainjection_patch.yaml 13 config/manager-sharded/kustomization.yaml 11 config/manager-sharded/manager.yaml 55 config/manager-sharded/service.yaml 13 config/manager/kustomization.yaml 10 config/manager/manager.yaml 49 config/prometheus/kustomization.yaml 2 config/prometheus/monitor.yaml 18 config/rbac/auth_proxy_client_clusterrole.yaml 9 config/rbac/auth_proxy_role.yaml 17 config/rbac/auth_proxy_role_binding.yaml 12 config/rbac/auth_proxy_service.yaml 18 config/rbac/flinkcluster_editor_role.yaml 23 config/rbac/flinkcluster_viewer_role.yaml 19 config/rbac/kustomization.yaml 10 config/rbac/leader_election_role.yaml 36 config/rbac/leader_election_role_binding.yaml 12 config/rbac/role.yaml 229 config/rbac/role_binding.yaml 12 config/rbac/service_account.yaml 5 config/webhook/kustomization.yaml 5 config/webhook/kustomizeconfig.yaml 21 config/webhook/manifests.yaml 52 config/webhook/service.yaml 11 controllers/flinkcluster/flinkcluster_controller.go 198 controllers/flinkcluster/flinkcluster_converter.go 1194 controllers/flinkcluster/flinkcluster_observer.go 646 controllers/flinkcluster/flinkcluster_reconciler.go 764 controllers/flinkcluster/flinkcluster_submit_job_script.go 134 controllers/flinkcluster/flinkcluster_updater.go 959 controllers/flinkcluster/flinkcluster_util.go 473 controllers/flinkcluster/sharder.go 64 helm-chart/flink-job-cluster/Chart.yaml 10 helm-chart/flink-job-cluster/templates/_helpers.tpl 30 helm-chart/flink-job-cluster/templates/flinkjobcluster.yaml 93 helm-chart/flink-job-cluster/templates/podmonitor.yaml 18 helm-chart/flink-job-cluster/values.yaml 59 helm-chart/flink-operator/Chart.yaml 8 helm-chart/flink-operator/templates/_helpers.tpl 52 helm-chart/flink-operator/templates/flink-cluster-crd.yaml 8534 helm-chart/flink-operator/templates/flink-operator.yaml 101 helm-chart/flink-operator/templates/rbac.yaml 336 helm-chart/flink-operator/templates/serviceaccount.yaml 13 helm-chart/flink-operator/templates/webhook.yaml 77 helm-chart/flink-operator/values.yaml 30 images/flink/hadoop/core-site.xml 24 internal/batchscheduler/factory.go 38 internal/batchscheduler/types/types.go 16 internal/batchscheduler/volcano/volcano.go 222 internal/controllers/history/controller_history.go 252 internal/flink/client.go 223 internal/model/model.go 21 internal/util/diff.go 19 internal/util/kube.go 69 internal/util/strings.go 5 internal/util/time.go 32 main.go 87