apache / apache/rocketmq-flink
[BUG] If the optional param 'startup.offset.timestamp' is not set, a NullPointerException will be thrown.
- Dominant language
- Java
- Stars
- 174
- Forks
- 104
- PR merge metrics
- No merged PRs in 30d
Description
Contributor guide
No contributing guide indexed for this repository
Research direction
Start by reproducing the NullPointerException with startup.offset.timestamp omitted, then trace how that optional parameter is read in the RocketMQ-Flink source or sink. Confirm the intended behavior for a missing value from the existing configuration flow; done means the job no longer throws the exception when the option is unset.
Written by the indexing model from the issue text.
Assessment
- Tech stack
- java
- Domain
- stream-processing
- Issue type
- Bug
- Difficulty
- 3/5
- Estimated time
- 1-2 days
- Activity status
- Stale
- Clarity
- Needs clarification
- Newbie friendliness
- 25/100