[FLINK-30623] Performance regression in checkpointSingleInput.UNALIGNED on 04.01.2023

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.17.0
• Component/s: Benchmarks, Runtime / Checkpointing
• Labels: pull-request-available
• Assignee: Rui Fan
• Reporter: Martijn Visser
• Created: 10/Jan/23 17:02
• Updated: 31/Jan/23 14:09
• Resolved: 31/Jan/23 14:09

Description

Performance regression
checkpointSingleInput.UNALIGNED median=338.1445195 recent_median=67.6453005
checkpointSingleInput.UNALIGNED_1 median=213.230041 recent_median=39.830277
deployAllTasks.STREAMING median=168.533106 recent_median=159.8534395
stateBackends.MEMORY median=3229.0248875 recent_median=2985.782919
tupleKeyBy median=4155.684199 recent_median=3987.5812305

http://codespeed.dak8s.net:8000/timeline/#/?exe=1&ben=checkpointSingleInput.UNALIGNED&extr=on&quarts=on&equid=off&env=2&revs=200

http://codespeed.dak8s.net:8000/timeline/#/?exe=1&ben=checkpointSingleInput.UNALIGNED_1&extr=on&quarts=on&equid=off&env=2&revs=200

http://codespeed.dak8s.net:8000/timeline/#/?exe=8&ben=deployAllTasks.STREAMING&extr=on&quarts=on&equid=off&env=2&revs=200

http://codespeed.dak8s.net:8000/timeline/#/?exe=6&ben=stateBackends.MEMORY&extr=on&quarts=on&equid=off&env=2&revs=200

http://codespeed.dak8s.net:8000/timeline/#/?exe=6&ben=tupleKeyBy&extr=on&quarts=on&equid=off&env=2&revs=200

Issue Links

• is related to: FLINK-30533 SourceOperator#emitNext() should push records to DataOutput in a while loop
• relates to: FLINK-30709 NetworkInput#emitNext() should push records to DataOutput in a while loop
• links to: GitHub Pull Request #21690