och5351 opened a new pull request, #4436: URL: https://github.com/apache/streampark/pull/4436
## What is the purpose of the change Implements [#4435](https://github.com/apache/streampark/issues/4435) — Phase 0.1 of the Scala removal plan ([#4408](https://github.com/apache/streampark/issues/4408)). Introduces a pure-Java `streampark-flink-core` module and defines `FlinkStreamingJob` as the Java abstract base class that replaces the deleted Scala `FlinkStreaming` trait. ## Brief change log - Add new Maven module `streampark-flink/streampark-flink-core` (no Scala version suffix, no Scala dependencies) - Define `FlinkStreamingJob` abstract class with lifecycle: `configure → ready → handle → execute → destroy` - Register the new module in `streampark-flink/pom.xml` - Add JUnit 5 tests verifying lifecycle order, class name default, and `ParameterTool` propagation ## Verifying this change ```bash mvn test -pl streampark-flink/streampark-flink-core ``` Tests run: 3, Failures: 0, Errors: 0 ## Does this pull request potentially affect one of the following parts? - [x] The public API - [ ] The web application - [ ] The build system ## Documentation - Relates to issue [#4435](https://github.com/apache/streampark/issues/4435) - Part of umbrella issue [#4408](https://github.com/apache/streampark/issues/4408) 🤖 Generated with [Claude Code](https://claude.com/claude-code) -- 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]
