Skip to content

[Flink] Migrate streampark-flink-sqlclient from Scala to Java #4448

Description

@shangeyao

Summary

Parent epic: #4408
Stage 1 — Flink Core (4/4)

Migrate streampark-flink-sqlclient from Scala to Java with no behavior changes (Stages 1–2) unless explicitly in Stage 3 scope.

Module role

Flink SQL job entry — SqlClient CLI (org.apache.streampark.flink.cli.SqlClient), SQL parse & execute path.

Dependencies

PRs within Stages 1–2 are sequential — do not start until the dependency issue is merged.

Constraints

Acceptance

  • No .scala under streampark-flink-sqlclient (src/main and src/test)
  • Module builds and tests pass
  • Downstream modules compile (where applicable)

References

Notes

Do not change SqlClient FQCN or external submission behavior.

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