[FLINK-23495] [Connectors / Google Cloud PubSub] Make checkpoint optional for preview/staging mode #16596
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
What is the purpose of the change
This PR add a new option for PubSub source called :
withoutCheckpoint
, to disable checkpoint verification.This is useful for testing, and especially when using Ververica platform-> Sql editor (they disable checkpointing for preview cluster)
Brief change log
(for example:)
PubSubSource
called :checkpointDisabled
, to disable checkpoint verification.true
.true
, the methodhasNoCheckpointingEnabled
will not raise error anymore.Verifying this change
This change is a trivial rework / code cleanup without any test coverage.
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 changed class annotated with
@Public(Evolving)
: noThe serializers: (yes / no / don't know) don't know
The runtime per-record code paths (performance sensitive): don't know
Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: yes (checkpointing)
The S3 file system connector: no
Does this pull request introduce a new feature? yes, kind of,
If yes, how is the feature documented? not documented (can you help me where should I document it)