Skip to content

Conversation

@wary
Copy link
Contributor

@wary wary commented Sep 30, 2025

What changes were proposed in this pull request

  1. add from image resource for Flink k8s Application: submit flink application with existed image
    image

  2. Fix the issue where the Flink task status was incorrectly determined to be cancelled, add watchController.canceling.invalidate(trackId) in method doWatching

def doWatching(trackId: TrackId): Unit = {
  if (trackId.isLegal) {
    watchController.trackIds.set(trackId)
    watchController.canceling.invalidate(trackId)
  }
}

def unWatching(trackId: TrackId): Unit = {
  watchController.canceling.set(trackId)
}

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)

@wary wary changed the title Add from image Resouce Type For K Add from image Resouce Type for k8s flink application Sep 30, 2025
@wary wary changed the title Add from image Resouce Type for k8s flink application [Future]Add from image Resouce Type for k8s flink application Sep 30, 2025
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