[FLINK-23593] Performance regression on 15.07.2021

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Not A Problem
• Affects Version/s: 1.14.0
• Component/s: API / DataStream, Benchmarks
• Assignee: Unassigned
• Reporter: Piotr Nowojski
• Created: 03/Aug/21 06:14
• Updated: 11/Aug/21 11:19
• Resolved: 11/Aug/21 11:19

Description

http://codespeed.dak8s.net:8000/timeline/?ben=sortedMultiInput&env=2
http://codespeed.dak8s.net:8000/timeline/?ben=sortedTwoInput&env=2

pnowojski@piotr-mbp: [~/flink -  ((no branch, bisect started on pr/16589))] $ git ls f4afbf3e7de..eb8100f7afe
eb8100f7afe [4 weeks ago] (pn/bad, bad, refs/bisect/bad) [FLINK-22017][coordination] Allow BLOCKING result partition to be individually consumable [Thesharing]
d2005268b1e [4 weeks ago] (HEAD, pn/bisect-4, bisect-4) [FLINK-22017][coordination] Get the ConsumedPartitionGroup that IntermediateResultPartition and DefaultResultPartition belong to [Thesharing]
d8b1a6fd368 [3 weeks ago] [FLINK-23372][streaming-java] Disable AllVerticesInSameSlotSharingGroupByDefault in batch mode [Timo Walther]
4a78097d038 [3 weeks ago] (pn/bisect-3, bisect-3, refs/bisect/good-4a78097d0385749daceafd8326930c8cc5f26f1a) [FLINK-21928][clients][runtime] Introduce static method constructors of DuplicateJobSubmissionException for better readability. [David Moravek]
172b9e32215 [3 weeks ago] [FLINK-21928][clients] JobManager failover should succeed, when trying to resubmit already terminated job in application mode. [David Moravek]
f483008db86 [3 weeks ago] [FLINK-21928][core] Introduce org.apache.flink.util.concurrent.FutureUtils#handleException method, that allows future to recover from the specied exception. [David Moravek]
d7ac08c2ac0 [3 weeks ago] (pn/bisect-2, bisect-2, refs/bisect/good-d7ac08c2ac06b9ff31707f3b8f43c07817814d4f) [FLINK-22843][docs-zh] Document and code are inconsistent [ZhiJie Yang]
16c3ea427df [3 weeks ago] [hotfix] Split the final checkpoint related tests to a separate test class. [Yun Gao]
31b3d37a22c [7 weeks ago] [FLINK-21089][runtime] Skip the execution of new sources if finished on restore [Yun Gao]
20fe062e1b5 [3 weeks ago] [FLINK-21089][runtime] Skip execution for the legacy source task if finished on restore [Yun Gao]
874c627114b [3 weeks ago] [FLINK-21089][runtime] Skip the lifecycle method of operators if finished on restore [Yun Gao]
ceaf24b1d88 [3 weeks ago] (pn/bisect-1, bisect-1, refs/bisect/good-ceaf24b1d881c2345a43f305d40435519a09cec9) [hotfix] Fix isClosed() for operator wrapper and proxy operator close to the operator chain [Yun Gao]
41ea591a6db [3 weeks ago] [FLINK-22627][runtime] Remove unused slot request protocol [Yangze Guo]
489346b60f8 [3 months ago] [FLINK-22627][runtime] Remove PendingSlotRequest [Yangze Guo]
8ffb4d2af36 [3 months ago] [FLINK-22627][runtime] Remove TaskManagerSlot [Yangze Guo]
72073741588 [3 months ago] [FLINK-22627][runtime] Remove SlotManagerImpl and its related tests [Yangze Guo]
bdb3b7541b3 [3 months ago] [hotfix][yarn] Remove unused internal options in YarnConfigOptionsInternal [Yangze Guo]
a6a9b192eac [3 weeks ago] [FLINK-23201][streaming] Reset alignment only for the currently processed checkpoint [Anton Kalashnikov]
b35701a35c7 [3 weeks ago] [FLINK-23201][streaming] Calculate checkpoint alignment time only for last started checkpoint [Anton Kalashnikov]
3abec22c536 [3 weeks ago] [FLINK-23107][table-runtime] Separate implementation of deduplicate rank from other rank functions [Shuo Cheng]
1a195f5cc59 [3 weeks ago] [FLINK-16093][docs-zh] Translate "System Functions" page of "Functions" into Chinese (#16348) [ZhiJie Yang]

Issue Links

• is caused by: FLINK-23372 Disable AllVerticesInSameSlotSharingGroupByDefault in DataStream batch mode