Roman Khachatryan created FLINK-20453:
-----------------------------------------
Summary: Move checkpointing classes to a the appropriate package
Key: FLINK-20453
URL: https://issues.apache.org/jira/browse/FLINK-20453
Project: Flink
Issue Type: Improvement
Components: Runtime / Checkpointing
Environment: *
Reporter: Roman Khachatryan
Fix For: 1.13.0
The following classes handle with checkpointing in a subtask:
- AlignedController
- AlternatingController
- CheckpointBarrierBehaviourController
- CheckpointBarrierHandler
- CheckpointBarrierTracker
- SingleCheckpointBarrierHandler
- UnalignedController
They all reside in package org.apache.flink.streaming.runtime.io;
Other classes in this package include e.g. RecordWriterOutput,
PushingAsyncDataInput
A better place could be:
* org.apache.flink.streaming.runtime.tasks (existing)
* org.apache.flink.streaming.runtime.tasks.checkpointing (proposed)
* org.apache.flink.streaming.runtime.checkpointing (proposed)
Another class that could me moved is SubtaskCheckpointCoordinator(Impl).
This should be done after FLINK-19681 to avoid conflicts.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
