shangeyao opened a new pull request, #4507: URL: https://github.com/apache/streampark/pull/4507
## Summary Fixes REMOTE Session JobGraph submission for Flink 1.20 SQL jobs and uploaded JAR applications (Closes #4506). - **SQL**: normalize storage/decoding with `DeflaterUtils.toPlainText` / `compressForStorage`; harden `checkChange`; sync remote cluster `versionId` on update. - **Uploaded JAR**: skip `distHome` for upload resources; resolve shaded jar fallback; add Flink runtime classpath + parent-first classloading for JobGraph build on Flink 1.20 (`flink-dist`). - **Client/packer**: read main class from JSON `appConf`; fix `ShadedBuildResponse` JSON mapping; SQL fat-jar snakeyaml handling; propagate build pipeline errors; Flink 2.x shims-base upload in `EnvInitializer`. ## Test plan - [x] Flink 1.20.5 REMOTE Session: SQL app build + start → RUNNING via JobGraph (no REST fallback) - [x] Flink 1.20.5 REMOTE Session: uploaded JAR (Flink 1.20-compatible examples jar) build + start → RUNNING via JobGraph - [x] Flink 2.x REMOTE Session: SQL + JAR regression verified in local e2e - [ ] CI **Note:** uploaded JARs must match the target Flink version (e.g. Flink 2.x example jars are incompatible with Flink 1.20). 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]
