[K8s] Migrate streampark-flink-kubernetes from Scala to Java - #4465
Open
shangeyao wants to merge 5 commits into
Open
[K8s] Migrate streampark-flink-kubernetes from Scala to Java#4465shangeyao wants to merge 5 commits into
shangeyao wants to merge 5 commits into
Conversation
…to Java Convert K8s integration module to Java with Jackson REST DTOs replacing json4s, preserve watcher/cache behavior, and update console enum bridges. Co-authored-by: Cursor <cursoragent@cursor.com>
Handle InterruptedException in watcher CompletableFuture joins, remove redundant Optional null checks, and replace backtracking-prone path regex. Co-authored-by: Cursor <cursoragent@cursor.com>
Address 32 Sonar CODE_SMELL findings: extract string constants (S1192), refactor nested try blocks (S1141), simplify complex methods (S3776/S135), use @Builder.Default static constants (S1170), and fix comment/path issues. Co-authored-by: Cursor <cursoragent@cursor.com>
Update KubernetesNativeSessionClient to use Java ClusterKey builder and Optional.orElseThrow after k8s module migration to Java. Co-authored-by: Cursor <cursoragent@cursor.com>
Use GHCR ryuk mirror with retry pre-pull for testcontainers images to avoid transient registry-1.docker.io timeouts in CI. Co-authored-by: Cursor <cursoragent@cursor.com>
|
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
1 participant
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Summary
streampark-flink-kubernetesfrom Scala to Java ([K8s] Migrate streampark-flink-kubernetes from Scala to Java #4451), replacing json4s with Jackson REST DTOs while preserving watcher/cache behavior and public API contracts.FlinkAppStateEnum,FlinkK8sChangeEventListener) for JavaFlinkJobState/FlinkK8sDeployMode.JavaConvertersusage in packer K8s build pipelines afterPodTemplateToolreturns JavaMap.Test plan
./mvnw test -pl streampark-flink/streampark-flink-kubernetes(7 tests pass)./mvnw install -pl streampark-console/streampark-console-service -am -DskipTests(BUILD SUCCESS)Closes #4451
Made with Cursor