apache / apache/streampark

[Feature] [Flink] Define FlinkStreamingJob Java lifecycle base class

Open
#4,435 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Java
Stars
4.3k
Forks
1.1k
Avg merge
13h 35m
Merged PRs (30d)
2

Description

### Search before asking

- [x] I had searched in the [feature](https://github.com/apache/streampark/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement.

### Description

> https://github.com/apache/streampark/issues/4408

### Usage Scenario

_No response_

### Related issues

_No response_

### Are you willing to submit a PR?

- [x] Yes I am willing to submit a PR!

### Code of Conduct

- [x] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)

Contributor guide

No contributing guide indexed for this repository

Research direction

Start by reading the related issue #4408 and the requested FlinkStreamingJob Java lifecycle base class described here. Determine the intended lifecycle responsibilities and acceptance criteria from that issue before locating the relevant Flink job entry points. The work is done when the base class behavior and scope are clearly defined and implemented consistently with those requirements.

Written by the indexing model from the issue text.

Assessment

Tech stack
java
Domain
stream-processing
Issue type
Feature
Difficulty
5/5
Estimated time
Over a week
Activity status
Quiet
Clarity
Needs clarification
Newbie friendliness
25/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.