Summary
Parent epic: #4408
Stage 1 — Flink Core (3/4)
Migrate streampark-flink-shims from Scala to Java with no behavior changes (Stages 1–2) unless explicitly in Stage 3 scope.
Module role
Flink multi-version adapter — shims hide API differences across Flink 1.17–1.20 (~62 .scala files across base + version modules).
Dependencies
PRs within Stages 1–2 are sequential — do not start until the dependency issue is merged.
Constraints
Acceptance
References
Notes
High sensitivity: preserve FlinkShimsProxy / classloader semantics when touching shims-related code.
Summary
Parent epic: #4408
Stage 1 — Flink Core (3/4)
Migrate
streampark-flink-shimsfrom Scala to Java with no behavior changes (Stages 1–2) unless explicitly in Stage 3 scope.Module role
Flink multi-version adapter — shims hide API differences across Flink 1.17–1.20 (~62
.scalafiles across base + version modules).Dependencies
streampark-flink-coremigration must merge first)Constraints
Acceptance
.scalaunderstreampark-flink-shims(src/mainandsrc/test)References
Notes
High sensitivity: preserve
FlinkShimsProxy/ classloader semantics when touching shims-related code.