Skip to content

Conversation

@wary
Copy link
Contributor

@wary wary commented Sep 30, 2025

What changes were proposed in this pull request

  1. Fix ingress configure bugs for flink application and flink cluster, support status refresh via ingress url
  2. Fix getFlinkConfig bugs in class FlinkEnv
      public Properties getFlinkConfig() {
         Properties flinkConfig = new Properties();
         flinkConfig.putAll(convertFlinkYamlAsMap());
         return flinkConfig;
     }```
  3. Supports Flink cluster state refresh and task submission in K8S environment
  4. Fix Flink Cluster Service Account Configuration not taking effect bugs

Brief change log

Verifying this change

This change is a trivial rework / code cleanup without any test coverage.

(or)

This change is already covered by existing tests, such as (please describe tests).

(or)

This change added tests and can be verified as follows:

Does this pull request potentially affect one of the following parts

  • Dependencies (does it add or upgrade a dependency): (yes / no)

@sonarqubecloud
Copy link

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant