Skip to content

[Scala Removal] Define Java user development API — FlinkStreamingJob lifecycle base class #4428

Description

@shangeyao

Parent Issue

Part of #4408 — Remove Scala from StreamPark.

Implementation Track

Delivered in PR #4418 on branch feature/remove-scala.

Scope

Design and implement FlinkStreamingJob abstract base class in org.apache.streampark.flink.core.java package. Preserve lifecycle execution order: maininitreadyhandleexecutedestroy. Use Java DataStream API exclusively (Flink 1.17–1.20).

Estimated Files

~1 new Java file; replaces FlinkStreaming.scala

Dependencies

Acceptance Criteria

  • FlinkStreamingJob compiles and lifecycle order matches Scala trait\n- [ ] handle() is abstract; ready(), destroy(), configure() have empty defaults\n- [ ] Migration note added to Javadoc

Sub-issue 0.1 of Scala removal epic (#4408).

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions