shangeyao opened a new pull request, #4419:
URL: https://github.com/apache/streampark/pull/4419
## Summary
- **Drop Flink 1.12–1.16 shims** and remove legacy modules, assembly deps,
and UI hints for unsupported versions.
- **Baseline Flink 1.x at 1.17+** — retain shims for 1.17, 1.18, 1.19, and
1.20.
- **Add Flink 2.0 / 2.1 / 2.2 support** via new Java
`streampark-flink-shims-base-v2` and thin version-specific shims modules (no
`_2.12` artifact suffix).
- Update `FlinkVersion`, `FlinkShimsProxy`, `EnvInitializer`, and console
packaging for the new supported version matrix: **1.17–1.20, 2.0–2.2**.
**Depends on:** #4418 (Remove Scala), which depends on #4417 (JDK 11
baseline).
## Supported Flink versions after this PR
| 1.x | 2.x |
|-----|-----|
| 1.17, 1.18, 1.19, 1.20 | 2.0.2, 2.1.2, 2.2.1 |
## Test plan
- [x] JDK 11 compile (shims + console-service):
```bash
export JAVA_HOME=$(/usr/libexec/java_home -v 11)
./mvnw clean compile -Pfast \
-pl
streampark-flink/streampark-flink-shims,streampark-console/streampark-console-service
-am -DskipTests
```
- [ ] Register Flink 1.17+ and 2.x homes in Console and verify version
detection
- [ ] Submit test Flink SQL / streaming app on 1.20 and 2.x
- [ ] Verify shims jars are copied to dist `lib/` and loaded by
`FlinkShimsProxy`
---
**AI Disclosure**
- Model: Claude Opus (Composer)
- Platform/Tool: Cursor
- Human Oversight: partially reviewed
- Prompt Summary: Single PR for Flink version baseline (drop 1.12–1.16,
1.17+ baseline, 2.0/2.1/2.2 support) on dedicated branch separate from Remove
Scala PR
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]
