[
https://issues.apache.org/jira/browse/FLINK-23975?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski updated FLINK-23975:
-----------------------------------
Affects Version/s: 1.14.0
1.13.2
> High checkpoint time for unaligned checkpoint when throthling in source
> -----------------------------------------------------------------------
>
> Key: FLINK-23975
> URL: https://issues.apache.org/jira/browse/FLINK-23975
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.14.0, 1.13.2
> Reporter: Anton Kalashnikov
> Priority: Major
>
> According to a brief test, if we add a delay in the source before
> emitting(outside of the checkpoint lock synchronization) it leads to
> increasing unaligned checkpoint time(in my case from 1sec to 15sec).
> Approximate logic for throttling in source:
>
>
> {noformat}
> @Override
> public void run(SourceContext<Type> sourceContext) throws Exception {
> while (running) {
> LockSupport.parkNanos(sleepNanos);
> synchronized (sourceContext.getCheckpointLock()) {
> sourceContext.collect(new
> Type(ThreadLocalRandom.current().nextLong(), time, payload));
> }
> }
> }
> {noformat}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
