[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 8:19 AM:
---
Hi [~gdegrove],
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu commented on FLINK-25649:
-
Hi Gil, just to confirm the scenario,
1. are all the jobs unbounded
[
https://issues.apache.org/jira/browse/FLINK-25649?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17476945#comment-17476945
]
Zhu Zhu edited comment on FLINK-25649 at 1/17/22, 3:59 AM:
---
Hi [~gdegrove],
[
https://issues.apache.org/jira/browse/FLINK-25034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25034.
---
Fix Version/s: 1.15.0
Resolution: Done
master/release-1.15:
856652435b2b65933c0b09e780a6229c62a854e4
[
https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24892:
Fix Version/s: 1.15.0
> FLIP-187: Adaptive Batch Scheduler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-25032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25032.
---
Fix Version/s: 1.15.0
Resolution: Done
master/1.15:
d2bfe404e199f98115df419232399bcc11b59e5a
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-18295.
---
Fix Version/s: 1.15.0
Resolution: Fixed
master/1.15:
15255565ad1ec6261db4e1c9211fe9b85ca77ac3
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-18295:
---
Assignee: Zhu Zhu
> Remove the hack logics of result consumers
>
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Description:
Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}.
That's why the
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Description:
Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}.
That's why the
[
https://issues.apache.org/jira/browse/FLINK-25011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25011.
---
Fix Version/s: 1.15.0
Resolution: Fixed
master:
afb29d92c4e76ec6a453459c3d8a08304efec549
>
[
https://issues.apache.org/jira/browse/FLINK-25225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25225:
Description: To automatically and continuously verify the
AdatpiveBatchScheduler, we should add a new e2e
[
https://issues.apache.org/jira/browse/FLINK-25225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25225:
Summary: Add e2e TPCDS tests to run against the AdaptiveBatchScheduler
(was: Add e2e TPCDS tests to run
[
https://issues.apache.org/jira/browse/FLINK-25225?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-25225:
Description: To automatically and continuously verify the
AdaptiveBatchScheduler, we should add a new e2e
Zhu Zhu created FLINK-25226:
---
Summary: Add documentation about the AdaptiveBatchScheduler
Key: FLINK-25226
URL: https://issues.apache.org/jira/browse/FLINK-25226
Project: Flink
Issue Type:
Zhu Zhu created FLINK-25225:
---
Summary: Add e2e TPCDS tests to run against the
AdatpiveBatchScheduler
Key: FLINK-25225
URL: https://issues.apache.org/jira/browse/FLINK-25225
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-19142.
---
Resolution: Fixed
> Local recovery can be broken if slot hijacking happened during a full restart
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17456104#comment-17456104
]
Zhu Zhu commented on FLINK-19142:
-
1.14:
63cf221ca2d963aa1394fb0244a8702b9e8c3835
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17455181#comment-17455181
]
Zhu Zhu commented on FLINK-19142:
-
I think it's time to do the backport. I'm now doing it.
I have also
[ https://issues.apache.org/jira/browse/FLINK-19142 ]
Zhu Zhu deleted comment on FLINK-19142:
-
was (Author: flink-jira-bot):
This issue was marked "stale-assigned" and has not received an update in 7
days. It is now automatically unassigned. If
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Labels: pull-request-available (was: pull-request-available stale-assigned)
> Local recovery can be
[ https://issues.apache.org/jira/browse/FLINK-19142 ]
Zhu Zhu deleted comment on FLINK-19142:
-
was (Author: flink-jira-bot):
I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I help
the community manage its development. I see
[
https://issues.apache.org/jira/browse/FLINK-25031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-25031.
---
Fix Version/s: 1.15.0
Resolution: Fixed
Done via caf72abd10628187af1440e0e8113384e1343eb9
> Job
[
https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-24980.
---
Fix Version/s: 1.15.0
Resolution: Fixed
Done via 3761bbf68c183cf4728353948acea0a2ac40f2a7
> Collect
[
https://issues.apache.org/jira/browse/FLINK-25045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25045:
---
Assignee: Lijie Wang
> Introduce AdaptiveBatchScheduler
>
>
>
[
https://issues.apache.org/jira/browse/FLINK-25033?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25033:
---
Assignee: Lijie Wang
> Let some scheduler components updatable
>
[
https://issues.apache.org/jira/browse/FLINK-25032?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25032:
---
Assignee: Lijie Wang
> Allow to create execution vertices and execution edges lazily
>
[
https://issues.apache.org/jira/browse/FLINK-25035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25035:
---
Assignee: Lijie Wang
> Shuffle Service Supports Consuming Subpartition Range
>
[
https://issues.apache.org/jira/browse/FLINK-25034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25034:
---
Assignee: Lijie Wang
> Support flexible number of subpartitions in IntermediateResultPartition
>
[
https://issues.apache.org/jira/browse/FLINK-25036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25036:
---
Assignee: Lijie Wang
> Introduce stage-wised scheduling strategy
>
[
https://issues.apache.org/jira/browse/FLINK-25011?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25011:
---
Assignee: Lijie Wang
> Introduce VertexParallelismDecider
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-25031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-25031:
---
Assignee: Lijie Wang
> Job finishes iff all job vertices finish
>
[
https://issues.apache.org/jira/browse/FLINK-24892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-24892:
---
Assignee: Lijie Wang
> FLIP-187: Adaptive Batch Scheduler
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-24980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-24980:
---
Assignee: Lijie Wang
> Collect sizes of finished BLOCKING result partitions
>
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24793:
Fix Version/s: (was: 1.14.1)
> DefaultSchedulerLocalRecoveryITCase fails on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-24793.
---
Resolution: Fixed
Fixed via 130db3830a9dc9173b2afd8f22e577c9711812bc
> DefaultSchedulerLocalRecoveryITCase
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24793:
Affects Version/s: (was: 1.14.1)
> DefaultSchedulerLocalRecoveryITCase fails on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17440224#comment-17440224
]
Zhu Zhu commented on FLINK-24793:
-
This IT case fails when it is testing using AdaptiveScheduler. The
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-24793:
---
Assignee: Zhu Zhu
> DefaultSchedulerLocalRecoveryITCase fails on AZP
>
[
https://issues.apache.org/jira/browse/FLINK-24793?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439669#comment-17439669
]
Zhu Zhu commented on FLINK-24793:
-
Thanks for the notification! [~trohrmann]
I will look into it.
>
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Description:
Currently an {{IntermediateDataSet}} can have multiple consumer {{JobEdge}}s.
That's why
[
https://issues.apache.org/jira/browse/FLINK-24316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-24316.
---
Resolution: Duplicate
> Refactor IntermediateDataSet to have only one consumer
>
[
https://issues.apache.org/jira/browse/FLINK-24316?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24316:
Fix Version/s: (was: 1.15.0)
> Refactor IntermediateDataSet to have only one consumer
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17438675#comment-17438675
]
Zhu Zhu edited comment on FLINK-19142 at 11/5/21, 9:25 AM:
---
Fixed in
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-19142:
-
> Local recovery can be broken if slot hijacking happened during a full restart
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Fix Version/s: 1.14.1
> Local recovery can be broken if slot hijacking happened during a full restart
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17439118#comment-17439118
]
Zhu Zhu commented on FLINK-19142:
-
I would keep this ticket open for now and keep watching it.
If there
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-19142.
---
Resolution: Fixed
Done via
4618b6a6e0584fc9054505035bb6a3b4e951c937
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Fix Version/s: (was: 1.14.1)
> Local recovery can be broken if slot hijacking happened during a full
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Fix Version/s: 1.14.1
> Local recovery can be broken if slot hijacking happened during a full restart
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Summary: Local recovery can be broken if slot hijacking happened during a
full restart (was: Local
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Issue Type: Bug (was: Improvement)
> Local recovery can be broken if slot hijacking happened during
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Description:
The ticket originates from [this PR
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Summary: Local recovery can be broken if slot hijacking happened during
restarting (was: Investigate
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Comment: was deleted
(was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Comment: was deleted
(was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Comment: was deleted
(was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Comment: was deleted
(was: This issue was marked "stale-assigned" 7 days ago and has not received an
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-24375.
---
Resolution: Done
Done via 5947647a3390bf7804ca927976dda909fb6db295
> The name of flush thread in
[
https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420270#comment-17420270
]
Zhu Zhu commented on FLINK-24293:
-
I think "yarn.provided.lib.dirs" can be used for user jars. If a user
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24375:
Fix Version/s: 1.15.0
> The name of flush thread in RecordWriter should contain subtask index
>
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420235#comment-17420235
]
Zhu Zhu commented on FLINK-24375:
-
Thanks for reporting this! [~wanglijie95]
I think it's good to have
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24375:
Priority: Major (was: Minor)
> The name of flush thread in RecordWriter should contain subtask index
>
[
https://issues.apache.org/jira/browse/FLINK-24375?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-24375:
---
Assignee: Lijie Wang
> The name of flush thread in RecordWriter should contain subtask index
>
[
https://issues.apache.org/jira/browse/FLINK-24293?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420222#comment-17420222
]
Zhu Zhu commented on FLINK-24293:
-
Hi [~huntercc],
I agree that it's not ideal to download a jar to one
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420218#comment-17420218
]
Zhu Zhu edited comment on FLINK-23826 at 9/26/21, 6:56 AM:
---
Here is the
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420218#comment-17420218
]
Zhu Zhu edited comment on FLINK-23826 at 9/26/21, 6:48 AM:
---
Here is the
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-23826.
---
Resolution: Done
> Verify optimized scheduler performance for large-scale jobs
>
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17420218#comment-17420218
]
Zhu Zhu commented on FLINK-23826:
-
Here is the benchmark results of release-1.14 v.s. release-1.12.
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23826:
Description:
This ticket is used to verify the result of FLINK-21110.
It should check if large scale
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23826:
Priority: Major (was: Critical)
> Verify optimized scheduler performance for large-scale jobs
>
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17414833#comment-17414833
]
Zhu Zhu commented on FLINK-23826:
-
Here's the testing result:
||JM/Scheduler Initializing||Task
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23826:
Description:
This ticket is used to verify the result of FLINK-21110.
It should check if large scale
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23826:
Description:
This ticket is used to verify the result of FLINK-21110.
It should check if large scale
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-23826:
---
Assignee: Zhu Zhu (was: Zhilong Hong)
> Verify optimized scheduler performance for large-scale
[
https://issues.apache.org/jira/browse/FLINK-23826?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23826:
Priority: Critical (was: Blocker)
> Verify optimized scheduler performance for large-scale jobs
>
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Labels: pull-request-available (was: auto-unassigned
pull-request-available)
> Investigate slot
[
https://issues.apache.org/jira/browse/FLINK-19142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-19142:
Fix Version/s: (was: 1.14.0)
1.15.0
> Investigate slot hijacking from preceding
[
https://issues.apache.org/jira/browse/FLINK-21110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-21110:
Release Note: The performance of scheduler has been improved to reduce the
time on execution graph
[
https://issues.apache.org/jira/browse/FLINK-23833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-23833.
---
Resolution: Fixed
Fixed via:
master:
8d3ec4a2fb1c9e07ee386dced15e1f64f359c6a2
[
https://issues.apache.org/jira/browse/FLINK-23833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-23833:
Fix Version/s: 1.15.0
> Cache of ShuffleDescriptors should be individually cleaned up
>
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406577#comment-17406577
]
Zhu Zhu edited comment on FLINK-24005 at 8/30/21, 6:20 AM:
---
Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17406577#comment-17406577
]
Zhu Zhu commented on FLINK-24005:
-
Thanks for the explanation! [~trohrmann] [~chesnay]
I now understand
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405565#comment-17405565
]
Zhu Zhu commented on FLINK-24005:
-
That's also my question that why we need to decrease requirements
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405203#comment-17405203
]
Zhu Zhu commented on FLINK-24005:
-
Would it work if we do not decrease resource requirements if a TM
[
https://issues.apache.org/jira/browse/FLINK-24005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-24005:
Attachment: decrease_resource_requirements.log
> Resource requirements declaration may be incorrect if
Zhu Zhu created FLINK-24005:
---
Summary: Resource requirements declaration may be incorrect if
JobMaster disconnects with a TaskManager with available slots in the SlotPool
Key: FLINK-24005
URL:
[
https://issues.apache.org/jira/browse/FLINK-23172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-23172.
---
Resolution: Fixed
release-1.13: 1fb2c19fbd24c0037b436b3f261db63fc4056df5
> Links to Task Failure Recovery
[
https://issues.apache.org/jira/browse/FLINK-23889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402974#comment-17402974
]
Zhu Zhu edited comment on FLINK-23889 at 8/23/21, 6:40 AM:
---
Regarding why the
[
https://issues.apache.org/jira/browse/FLINK-23889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402974#comment-17402974
]
Zhu Zhu commented on FLINK-23889:
-
Regarding why the empty resource declaration is sent twice, I think
[
https://issues.apache.org/jira/browse/FLINK-23889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17402962#comment-17402962
]
Zhu Zhu commented on FLINK-23889:
-
Looks to me that "Clearing resource requirements ..." is printed each
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Comment: was deleted
(was: This issue was marked "stale-assigned" and has not received an update in
7
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Comment: was deleted
(was: This issue was labeled "stale-major" 7 ago and has not received any
updates
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Comment: was deleted
(was: This issue is assigned but has not received an update in 7 days so it has
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Comment: was deleted
(was: I am the [Flink Jira Bot|https://github.com/apache/flink-jira-bot/] and I
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Priority: Major (was: Minor)
> Remove the hack logics of result consumers
>
[
https://issues.apache.org/jira/browse/FLINK-18295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-18295:
Labels: (was: auto-deprioritized-major auto-unassigned)
> Remove the hack logics of result consumers
>
[
https://issues.apache.org/jira/browse/FLINK-23879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17401986#comment-17401986
]
Zhu Zhu commented on FLINK-23879:
-
cc [~arvid] [~dwysakowicz]
> Benchmark are not compiling
>
[
https://issues.apache.org/jira/browse/FLINK-23806?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-23806.
---
Resolution: Fixed
Fixed via
master/release-1.14: f543e9a97e2d2dda340d4d1d54467ffe060666cb
release-1.13:
[
https://issues.apache.org/jira/browse/FLINK-23833?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-23833:
---
Assignee: Zhilong Hong
> Cache of ShuffleDescriptors should be individually cleaned up
>
701 - 800 of 2407 matches
Mail list logo
