shangeyao opened a new pull request, #4461: URL: https://github.com/apache/streampark/pull/4461
## Summary - Complete **#4447**: migrate all `streampark-flink-shims` sources (base + Flink 1.12–1.20 + shims-test) from Scala to Java with no remaining `.scala` under `src/main` or `src/test`. - Builds on **#4445** (`streampark-common` Java migration) and related JDK 11 / CI fixes already on this branch. - Preserve existing behavior: SQL parse/execute/validate, environment initializers, version-specific `TableContext` / `StreamTableContext`, cluster/k8s client wrappers, and Scala-bridge Flink APIs used by `sqlclient` / console submit paths. ## Migration phases (this PR) | Phase | Scope | |-------|--------| | Phase 1 | shims-base leaf APIs (`FlinkConfiguration`, traits, utils, config types) | | Phase 2 | SQL runtime (`SqlCommandParser`, `FlinkSqlExecutor`, `FlinkSqlValidator`, initializers) | | Phase 3 | `FlinkTableTrait` / `FlinkStreamTableTrait`, per-version contexts/clients/`TableExt`, JUnit 5 shims-test | ## Acceptance (#4447) - [x] No `.scala` under `streampark-flink-shims` (`src/main` + `src/test`) - [x] All shims modules compile (1.12–1.20) - [x] `streampark-flink-shims-test` passes (11 tests) ## Test plan - [x] `mvn -f streampark-flink/streampark-flink-shims/pom.xml clean compile` - [x] `mvn -f streampark-flink/streampark-flink-shims/pom.xml test -DskipITs` - [ ] CI Backend / Unit-Test / Sonar (on merge) - [ ] Smoke: Console Flink SQL submit path (manual, post-merge) Closes #4447 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]
