shangeyao opened a new pull request, #4475: URL: https://github.com/apache/streampark/pull/4475
## Summary - Introduce typed **Request** / **Response** DTOs for `FlinkApplicationController`, replacing direct `FlinkApplication` entity pass-through on HTTP boundaries - Add `FlinkApplicationAssembler` to convert between DTOs and domain entities, aligned with webapp-v2 types (`CreateParams`, `AppListRecord`, `DashboardResponse`, `CancelParam`) - Follow the existing `AlertConfigParams` pattern used in `AlertController` Closes #4474 ## Changes | Layer | Package | Description | |-------|---------|-------------| | Request | `core.request.flink.*` | Per-endpoint request objects (create, update, start, cancel, list query, etc.) | | Response | `core.response.flink.*` | `FlinkAppResponse`, `FlinkAppDashboardResponse` | | Assembler | `core.assembler.FlinkApplicationAssembler` | Entity ↔ DTO mapping | Endpoints still accept `application/x-www-form-urlencoded` payloads (no frontend change required). ## Test plan - [x] Add `FlinkApplicationAssemblerTest` covering create/start/response/dashboard mapping - [ ] `./mvnw test -pl streampark-console/streampark-console-service -Dtest=FlinkApplicationAssemblerTest` - [ ] Manual smoke test: Flink app list / create / start / cancel via console UI ## Follow-up Remaining controllers will be migrated in subsequent PRs under #4474. 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]
