shangeyao commented on issue #4421: URL: https://github.com/apache/streampark/issues/4421#issuecomment-5174194823
## Progress Update (2026-08-04) **Overall:** Implementation on PR [#4419](https://github.com/apache/streampark/pull/4419) (`feature/flink-1.17-plus`) is **feature-complete and under review**. Latest commit: `75f034548`. ### Goals checklist | Goal | Status | Notes | |------|--------|-------| | Drop Flink **1.12–1.16** shims | ✅ | Removed from `streampark-flink-shims/pom.xml` and console assembly; legacy E2E cases disabled in CI workflow | | Retain **1.17–1.20** shims (Java) | ✅ | All four modules compile and package into dist | | Add Flink **2.x** support | ✅ | `shims-base-v2` + **2.0 / 2.1 / 2.2 / 2.3** thin modules (2.3 added beyond original proposal) | | Update `FlinkVersion`, `FlinkShimsProxy`, `EnvInitializer`, console, frontend | ✅ | 2.x `flink-dist-2.x.jar` detection, classloader routing, dist packaging, UI hints aligned | | Document supported versions & upgrade path | ⏳ | Release notes / upgrade guide still pending | ### Verification (local, branch `feature/flink-1.17-plus`) | Check | Result | |-------|--------| | `./mvnw clean install -Pshaded,webapp,dist -DskipTests` | ✅ | | `./mvnw clean test` (full unit suite) | ✅ | | checkstyle + spotless + apache-rat + `check-LICENSE.sh` | ✅ | | SonarCloud (PR #4419) | ✅ | | E2E (13 CI cases, M1 `-Dm1_chip=true`) | ✅ all passed locally | ### Shims layout (as built) ``` shims-base + shims-base-v2 ├── flink-1.17 … flink-1.20 └── flink-2.0 … flink-2.3 (JDK 11+ profile) ``` Default `streampark.flink.shims.version` → **1.17**. ### Remaining before close 1. **PR #4419 merge** — currently blocked on reviewer approval; fork CI E2E may need maintainer workflow approval. 2. **Docs** — supported-version matrix and 1.12–1.16 → 1.17+ upgrade guide for 3.0 release notes. 3. **Follow-up (optional)** — dedicated Flink 2.x E2E case; cleanup of orphaned legacy shims directories / E2E docker assets if still present on disk. Ref: #4419 · depends on #4408 / #4471 (post-Scala Java baseline ✅ merged) -- 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]
