Summary
Parent epic: #4408
Stage 1 — Flink Core (2/4)
Migrate streampark-flink-core from Scala to Java with no behavior changes (Stages 1–2) unless explicitly in Stage 3 scope.
Module role
Flink core — job runtime context, environment initialization, and related base wrappers.
Dependencies
PRs within Stages 1–2 are sequential — do not start until the dependency issue is merged.
Constraints
Acceptance
References
Summary
Parent epic: #4408
Stage 1 — Flink Core (2/4)
Migrate
streampark-flink-corefrom Scala to Java with no behavior changes (Stages 1–2) unless explicitly in Stage 3 scope.Module role
Flink core — job runtime context, environment initialization, and related base wrappers.
Dependencies
streampark-commonmigration must merge first)Constraints
Acceptance
.scalaunderstreampark-flink-core(src/mainandsrc/test)References