flink icon indicating copy to clipboard operation
flink copied to clipboard

[FLINK-34549][API] Introduce config, context and processingTimerService for DataStream API V2

Open reswqa opened this issue 1 year ago • 3 comments

What is the purpose of the change

Implementation of FLIP-410. This PR will Introduce config, context and processingTimerService for DataStream API V2.

Brief change log

  • Introduce ProcessConfigurable to configurate the processing of stream
  • Introduce RuntimeContext
  • Support process timer service

Verifying this change

Can be verified by unit tests.

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

reswqa avatar Mar 20 '24 12:03 reswqa

CI report:

  • e59422deeaaa67b1a00895d3466c778f107860ff Azure: SUCCESS
Bot commands The @flinkbot bot supports the following commands:
  • @flinkbot run azure re-run the last Azure build

flinkbot avatar Mar 20 '24 12:03 flinkbot

I have rebased this on master.

reswqa avatar Apr 09 '24 12:04 reswqa

@flinkbot run azure

reswqa avatar Apr 18 '24 01:04 reswqa

Thanks @Sxnan for the review! I have updated this PR according to your comments, PTAL again.

reswqa avatar May 22 '24 01:05 reswqa

@reswqa Thanks for the update! LGTM.

Sxnan avatar May 22 '24 03:05 Sxnan