Poorvankbhatia opened a new pull request, #950:
URL: https://github.com/apache/flink-kubernetes-operator/pull/950
## What is the purpose of the change
This pull request migrates the ImpulseSource to use Flink's new Source API,
replacing the older SourceFunction.
## Brief change log
- Replaced the old ImpulseSource (which implemented SourceFunction<Long>)
with a new implementation using Flink's modern Source API.
- Implemented createReader, createEnumerator, and serialization methods in
the new source.
- Updated LoadSimulationPipeline to use env.fromSource(...) instead of
env.addSource(...).
- Ensured that the new implementation preserves the same functionality as
the old one.
## Verifying this change
This change is already covered by existing tests, such as:
- Existing load simulation tests that verify the source is producing
expected records.
- The Flink job runs with the updated ImpulseSource without functional
changes.
- The change was manually verified by running a Flink job with the new
ImpulseSource.
## Does this pull request potentially affect one of the following parts:
- Dependencies (does it add or upgrade a dependency): no
- The public API, i.e., is any changes to the `CustomResourceDescriptors`:
no
- Core observer or reconciler logic that is regularly executed: no
## Documentation
- Does this pull request introduce a new feature? no
- If yes, how is the feature documented? (not applicable)
--
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]
