shangeyao opened a new pull request, #4465: URL: https://github.com/apache/streampark/pull/4465
## Summary - Migrate `streampark-flink-kubernetes` from Scala to Java (#4451), replacing json4s with Jackson REST DTOs while preserving watcher/cache behavior and public API contracts. - Update console enum bridges (`FlinkAppStateEnum`, `FlinkK8sChangeEventListener`) for Java `FlinkJobState` / `FlinkK8sDeployMode`. - Remove redundant `JavaConverters` usage in packer K8s build pipelines after `PodTemplateTool` returns Java `Map`. ## Test plan - [x] `./mvnw test -pl streampark-flink/streampark-flink-kubernetes` (7 tests pass) - [x] `./mvnw install -pl streampark-console/streampark-console-service -am -DskipTests` (BUILD SUCCESS) - [ ] CI Backend build + Unit-Test Closes #4451 Made with [Cursor](https://cursor.com) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
