[
https://issues.apache.org/jira/browse/FLINK-23382?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Piotr Nowojski reassigned FLINK-23382:
--------------------------------------
Assignee: Yingjie Cao
> Performance regression on 13.07.2021
> ------------------------------------
>
> Key: FLINK-23382
> URL: https://issues.apache.org/jira/browse/FLINK-23382
> Project: Flink
> Issue Type: Bug
> Components: Benchmarks, Runtime / Network
> Affects Versions: 1.14.0
> Reporter: Piotr Nowojski
> Assignee: Yingjie Cao
> Priority: Critical
> Fix For: 1.14.0
>
>
> It looks like there was a performance regression after merging FLINK-16641
> http://codespeed.dak8s.net:8000/timeline/?ben=readFileSplit&env=2
> http://codespeed.dak8s.net:8000/timeline/?ben=networkLatency1to1&env=2
> http://codespeed.dak8s.net:8000/timeline/?ben=networkSkewedThroughput&env=2
> (and a couple of other benchmarks)
> {code}
> $ git ls 4fddcb27c5..657df14677
> 657df14677a [2 days ago] [FLINK-23356][hbase] Do not use delegation token in
> case of keytab [Gabor Somogyi]
> 5aba6167343 [3 days ago] [FLINK-21088][runtime][checkpoint] Pass the finish
> on restore status to operator chain [Yun Gao]
> df99b49e3f4 [2 days ago] [FLINK-21088][runtime][checkpoint] Pass the finished
> on restore status to TaskStateManager [Yun Gao]
> 1251ab8566f [2 days ago] [FLINK-21088][runtime][checkpoint] Assign a finished
> snapshot to task if operators are all finished on restore [Yun Gao]
> 83c5e710673 [33 hours ago] [FLINK-23150][table-planner] Remove the old code
> split implementation [tsreaper]
> 2e374954b9b [2 days ago] [FLINK-23359][test] Fix the number of available
> slots in testResourceCanBeAllocatedForDifferentJobAfterFree [Yangze Guo]
> 2268baf211f [5 days ago] [FLINK-23235][connector] Fix SinkITCase instability
> [GuoWei Ma]
> 60d015cfc65 [6 days ago] [FLINK-16641][network] (Part#6) Enable to set
> network buffers per channel to 0 [kevin.cyj]
> 7d1bb5f5e0b [6 days ago] [FLINK-16641][network] (Part#5) Send empty buffers
> to the downstream tasks to release the allocated credits if the exclusive
> credit is 0 [kevin.cyj]
> 985382020b1 [6 days ago] [FLINK-16641][network] (Part#4) Release all
> allocated floating buffers of RemoteInputChannel on receiving any channel
> blocking event if the exclusive credit is 0 [kevin.cyj]
> 1bf36cbcbbf [6 days ago] [FLINK-16641][network] (Part#3) Support to announce
> the upstream backlog to the downstream tasks [kevin.cyj]
> 31e1cd174d6 [6 days ago] [FLINK-16641][network] (Part#2) Distinguish data
> buffer and event buffer for BoundedBlockingSubpartitionDirectTransferReader
> [kevin.cyj]
> 3a46604c068 [7 days ago] [FLINK-16641][network] (Part#1) Introduce a new
> network message BacklogAnnouncement which can bring the upstream buffer
> backlog to the downstream [kevin.cyj]
> 1746146ab9e [5 days ago] [hotfix] Fix typos in NettyShuffleUtils [kevin.cyj]
> 73fcb75352b [4 months ago] [hotfix] Simplify
> RemoteInputChannel#onSenderBacklog and call the existing method directly
> [kevin.cyj]
> dc80bb07fb9 [4 months ago] [hotfix] Remove outdated comments in
> UnionInputGate [kevin.cyj]
> 790576b544e [4 months ago] [hotfix] Remove redundant if condition in
> BufferManager [kevin.cyj]
> cf7d7258c5e [2 days ago] [hotfix][tests] Remove unnecessary sleep from
> RemoteAkkaRpcActorTest.failsRpcResultImmediatelyIfRemoteRpcServiceIsNotAvailable
> [Till Rohrmann]
> 4a3e6d6a769 [2 months ago] [FLINK-11103][runtime] Set a configurable uncaught
> exception handler for all entrypoints [Ashwin Kolhatkar]
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)