flink icon indicating copy to clipboard operation
flink copied to clipboard

[FLINK-32695] [Tests] Migrated SimpleStringGenerator to Source V2 Implementation

Open Poorvankbhatia opened this issue 4 months ago • 4 comments

What is the purpose of the change

This PR migrates CheckpointedStreamingProgram from the deprecated legacy SourceFunction API to the modern FLIP-27 Source API.

Brief change log

  • Removed SimpleStringGenerator class that implemented the deprecated SourceFunction interface
  • Configured a new SimpleStringGenerator based on FLIP-27 Source API. (Must be implemented inside the user JAR as user code, & Cannot depend on external source implementations)
  • Updated imports to use FLIP-27 Source API classes

Verifying this change

Existing tests already cover this change, ClassLoaderITCase.

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): no
  • The serializers: no
  • The runtime per-record code paths (performance sensitive): no
  • Anything that affects deployment or recovery: JobManager (and its components), Checkpointing, Kubernetes/Yarn, ZooKeeper: no
  • The S3 file system connector: no

Documentation

  • Does this pull request introduce a new feature? no
  • If yes, how is the feature documented? no

Poorvankbhatia avatar Jul 24 '25 03:07 Poorvankbhatia

@afedulov PTAL Thanks.

Poorvankbhatia avatar Jul 24 '25 03:07 Poorvankbhatia

CI report:

  • 6d210dfdbab9c8213e19ea55589506a643a19e15 Azure: SUCCESS
  • ff8c1e126a3f00487d72b83dc545b80c376dff86 UNKNOWN
  • 0a5a1c88b3007041a53d5cc7fc2baaa64d2bbdf8 UNKNOWN
Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

flinkbot avatar Jul 24 '25 03:07 flinkbot

@fapaul Rebased with master. PTAL

Poorvankbhatia avatar Aug 22 '25 08:08 Poorvankbhatia

@fapaul Rebased with master. PTAL.

Poorvankbhatia avatar Sep 15 '25 05:09 Poorvankbhatia