[
https://issues.apache.org/jira/browse/FLINK-17019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17019:
Fix Version/s: (was: 1.11.0)
1.12.0
> Implement FIFO Physical Slot Assignment in Sl
[
https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17017:
Fix Version/s: (was: 1.11.0)
1.12.0
> Implement Bulk Slot Allocation
>
[
https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17016:
Fix Version/s: (was: 1.11.0)
1.12.0
> Use PipelinedRegionSchedulingStrategy in Defa
[
https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17018:
Fix Version/s: (was: 1.11.0)
1.12.0
> DefaultExecutionSlotAllocator allocates slots
[
https://issues.apache.org/jira/browse/FLINK-17542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17542:
Fix Version/s: (was: 1.11.0)
1.12.0
> Unify slot request timeout handling for strea
[
https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17330:
Fix Version/s: (was: 1.11.0)
1.12.0
> Avoid scheduling deadlocks caused by cyclic i
[
https://issues.apache.org/jira/browse/FLINK-15626?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15626:
Fix Version/s: (was: 1.11.0)
1.12.0
> Remove legacy scheduler
> ---
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15031:
Fix Version/s: (was: 1.11.0)
1.12.0
> Calculate required shuffle memory before allo
[
https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-13056:
Fix Version/s: (was: 1.11.0)
> Optimize region failover performance on calculating vertices to restart
[
https://issues.apache.org/jira/browse/FLINK-17760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17760:
Fix Version/s: 1.12.0
> Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore
> -
[
https://issues.apache.org/jira/browse/FLINK-17760?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17760:
Affects Version/s: 1.11.0
> Rework tests to not rely on legacy scheduling logics in ExecutionGraph anymore
[
https://issues.apache.org/jira/browse/FLINK-14606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14606:
Fix Version/s: (was: 1.11.0)
> Simplify params of Execution#processFail
>
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15178:
Fix Version/s: (was: 1.11.0)
> TaskExecutor crashes due to mmap allocation failure for BLOCKING shuffl
[
https://issues.apache.org/jira/browse/FLINK-14510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14510:
Fix Version/s: (was: 1.11.0)
1.12.0
> Remove the lazy vertex attaching mechanism fr
[
https://issues.apache.org/jira/browse/FLINK-14236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14236:
Fix Version/s: (was: 1.11.0)
> Make LazyFromSourcesSchedulingStrategy do lazy scheduling based on part
[
https://issues.apache.org/jira/browse/FLINK-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14233:
Fix Version/s: (was: 1.11.0)
> All task state changes should be notified to SchedulingStrategy (Schedu
[
https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-15813.
---
Resolution: Fixed
done via
master
b425c05d57ace5cf27591dbd6798b6131211f6c1
release-1.1
6fa0c92567a9d8163
Zhu Zhu created FLINK-17821:
---
Summary:
Kafka010TableITCase>KafkaTableTestBase.testKafkaSourceSink failed on AZP
Key: FLINK-17821
URL: https://issues.apache.org/jira/browse/FLINK-17821
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-17821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17111779#comment-17111779
]
Zhu Zhu commented on FLINK-17821:
-
[~wanglijie95] yes, it's the same root cause.
Thanks
[
https://issues.apache.org/jira/browse/FLINK-17821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17821.
---
Resolution: Duplicate
> Kafka010TableITCase>KafkaTableTestBase.testKafkaSourceSink failed on AZP
> -
[
https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17018:
---
Assignee: Zhu Zhu
> DefaultExecutionSlotAllocator allocates slots in bulks ignoring slot sharing
>
[
https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17645:
Affects Version/s: 1.12.0
> REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the
> rep
[
https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17645:
Fix Version/s: 1.12.0
> REAPER_THREAD.start() in SafetyNetCloseableRegistry failed, causing the
> repeate
[
https://issues.apache.org/jira/browse/FLINK-17645?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17645.
---
Resolution: Fixed
Fixed via
master
9f3a71183ea4b14a396ecf66e4377da07b06a689
release-1.1
d40826d23c8993f462
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17814:
---
Assignee: CaoZhen
> Translate native kubernetes document to Chinese
> -
[
https://issues.apache.org/jira/browse/FLINK-17814?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17112774#comment-17112774
]
Zhu Zhu commented on FLINK-17814:
-
I have assigned the ticket to you [~caozhen1937].
>
[
https://issues.apache.org/jira/browse/FLINK-17019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17019:
---
Assignee: Zhu Zhu
> Implement FIFO Physical Slot Assignment in SlotPoolImpl
> -
[
https://issues.apache.org/jira/browse/FLINK-17016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17016:
---
Assignee: Zhu Zhu
> Use PipelinedRegionSchedulingStrategy in DefaultScheduler (for Blink Planner)
>
[
https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-17726:
---
Assignee: Nicholas Jiang
> Scheduler should take care of tasks directly canceled by TaskManager
> -
[
https://issues.apache.org/jira/browse/FLINK-17726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17113820#comment-17113820
]
Zhu Zhu commented on FLINK-17726:
-
I have assigned the ticket to you. [~nicholasjiang]
B
[
https://issues.apache.org/jira/browse/FLINK-17542?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17542.
---
Resolution: Abandoned
Superseded by FLINK-17018.
> Unify slot request timeout handling for streaming and ba
[
https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu closed FLINK-17017.
---
Resolution: Abandoned
Superseded by FLINK-17018.
> Implement Bulk Slot Allocation
> ---
[
https://issues.apache.org/jira/browse/FLINK-17018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17018:
Summary: Allocates slots in bulks on pipelined region scheduling (was:
DefaultExecutionSlotAllocator allo
[
https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17017:
Summary: Implements bulk allocation for physical slots (was: Implement
Bulk Slot Allocation)
> Implement
[
https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reopened FLINK-17017:
-
Reopened for 'bulk slot allocation' part of FLINK-17018.
> Implements bulk allocation for physical slots
>
[
https://issues.apache.org/jira/browse/FLINK-17017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-17017:
Description:
SlotProvider should support bulk slot allocation so that we can check to see if
the resource
[
https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17117512#comment-17117512
]
Zhu Zhu commented on FLINK-17923:
-
We([~yunta]) just find that we can also have option #
[
https://issues.apache.org/jira/browse/FLINK-15037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988444#comment-16988444
]
Zhu Zhu commented on FLINK-15037:
-
Thanks for the feedback [~ykt836]. This task is not f
[
https://issues.apache.org/jira/browse/FLINK-15037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988444#comment-16988444
]
Zhu Zhu edited comment on FLINK-15037 at 12/5/19 4:09 AM:
--
Than
[
https://issues.apache.org/jira/browse/FLINK-14566?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988458#comment-16988458
]
Zhu Zhu commented on FLINK-14566:
-
Thanks for confirming the design and helping with the
[
https://issues.apache.org/jira/browse/FLINK-14701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14701:
Priority: Minor (was: Major)
> Slot leaks if SharedSlotOversubscribedException happens
>
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988603#comment-16988603
]
Zhu Zhu commented on FLINK-15031:
-
Thanks [~trohrmann] for the feedbacks. I can work on
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16988603#comment-16988603
]
Zhu Zhu edited comment on FLINK-15031 at 12/5/19 9:03 AM:
--
Than
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15031:
Summary: Calculate required shuffle memory before allocating slots if
resources are specified (was: Calcu
[
https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-13056:
Fix Version/s: (was: 1.10.0)
1.11.0
> Optimize region failover performance on calcu
[
https://issues.apache.org/jira/browse/FLINK-13056?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16991173#comment-16991173
]
Zhu Zhu commented on FLINK-13056:
-
postpone this improvement to 1.11.
> Optimize region
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15031:
Fix Version/s: (was: 1.10.0)
1.11.0
> Calculate required shuffle memory before allo
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16991514#comment-16991514
]
Zhu Zhu commented on FLINK-15031:
-
Postpone to 1.11 since several re-requisites to use t
[
https://issues.apache.org/jira/browse/FLINK-14162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14162:
Fix Version/s: (was: 1.10.0)
1.11.0
> Unify SchedulerOperations#allocateSlotsAndDep
[
https://issues.apache.org/jira/browse/FLINK-14233?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14233:
Fix Version/s: (was: 1.10.0)
1.11.0
> All task state changes should be notified to
[
https://issues.apache.org/jira/browse/FLINK-14606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14606:
Fix Version/s: (was: 1.10.0)
1.11.0
> Simplify params of Execution#processFail
> --
[
https://issues.apache.org/jira/browse/FLINK-14234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14234:
Fix Version/s: (was: 1.10.0)
1.11.0
> All partition consumable events should be not
[
https://issues.apache.org/jira/browse/FLINK-14236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-14236:
Fix Version/s: (was: 1.10.0)
1.11.0
> Make LazyFromSourcesSchedulingStrategy do laz
[
https://issues.apache.org/jira/browse/FLINK-15031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15031:
Parent: (was: FLINK-14058)
Issue Type: Task (was: Sub-task)
> Calculate required shuffle memo
Zhu Zhu created FLINK-15169:
---
Summary: Errors happen in the scheduling of DefaultScheduler is
not shown in WebUI
Key: FLINK-15169
URL: https://issues.apache.org/jira/browse/FLINK-15169
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15169:
Description:
WebUI relies on {{ExecutionGraph#failureInfo}} and {{Execution#failureCause}}
to generate er
[
https://issues.apache.org/jira/browse/FLINK-14058?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992444#comment-16992444
]
Zhu Zhu commented on FLINK-14058:
-
Yes we can close it. We may need some time for the re
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992455#comment-16992455
]
Zhu Zhu commented on FLINK-15169:
-
1. Execution#processFail is only invoked on task fail
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992455#comment-16992455
]
Zhu Zhu edited comment on FLINK-15169 at 12/10/19 11:27 AM:
Zhu Zhu created FLINK-15178:
---
Summary: Task crash due to mmap allocation failure for BLOCKING
shuffle
Key: FLINK-15178
URL: https://issues.apache.org/jira/browse/FLINK-15178
Project: Flink
Issue T
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15178:
Summary: TaskExecutor crashes due to mmap allocation failure for BLOCKING
shuffle (was: Task crash due to
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15178:
Description:
I met this issue when running testing batch(DataSet) job with 1000 parallelism.
Some TMs cras
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992602#comment-16992602
]
Zhu Zhu edited comment on FLINK-15169 at 12/10/19 2:29 PM:
---
If
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992602#comment-16992602
]
Zhu Zhu commented on FLINK-15169:
-
If we can have an interface {{ExecutionVertexOperatio
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16992602#comment-16992602
]
Zhu Zhu edited comment on FLINK-15169 at 12/10/19 2:30 PM:
---
If
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993300#comment-16993300
]
Zhu Zhu commented on FLINK-15178:
-
[~pnowojski] I tried -XX:-UseCompressedOops but the i
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993300#comment-16993300
]
Zhu Zhu edited comment on FLINK-15178 at 12/11/19 8:31 AM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993323#comment-16993323
]
Zhu Zhu commented on FLINK-15178:
-
Thanks for the explanation [~pnowojski].
Yes the iss
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993477#comment-16993477
]
Zhu Zhu commented on FLINK-15178:
-
Yes, my result is from the master {{Rev:1710207, Date
[
https://issues.apache.org/jira/browse/FLINK-15178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16993477#comment-16993477
]
Zhu Zhu edited comment on FLINK-15178 at 12/11/19 12:37 PM:
[
https://issues.apache.org/jira/browse/FLINK-15013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994287#comment-16994287
]
Zhu Zhu commented on FLINK-15013:
-
[~trohrmann] yes that's what I mean. And location pre
[
https://issues.apache.org/jira/browse/FLINK-15169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15169:
Summary: Errors happen in the scheduling of DefaultScheduler are not shown
in WebUI (was: Errors happen i
Zhu Zhu created FLINK-15224:
---
Summary: Resource requirements are not respected when fulfilling a
slot request with unresolvedRootSlots from a SlotSharingManager
Key: FLINK-15224
URL: https://issues.apache.org/jira/brows
[
https://issues.apache.org/jira/browse/FLINK-15224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15224:
Description:
In {{SchedulerImpl#allocateMultiTaskSlot}}, if a slot request cannot be
fulfilled immediatel
[
https://issues.apache.org/jira/browse/FLINK-15224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15224:
Description:
In {{SchedulerImpl#allocateMultiTaskSlot}}, if a slot request cannot be
fulfilled immediatel
[
https://issues.apache.org/jira/browse/FLINK-15224?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15224:
Description:
In {{SchedulerImpl#allocateMultiTaskSlot}}, if a slot request cannot be
fulfilled immediatel
[
https://issues.apache.org/jira/browse/FLINK-15013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994787#comment-16994787
]
Zhu Zhu commented on FLINK-15013:
-
Yes, it is ok to not respect input preferences if fal
[
https://issues.apache.org/jira/browse/FLINK-15224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16995723#comment-16995723
]
Zhu Zhu commented on FLINK-15224:
-
The managed memory weight is not in ResourceProfile i
[
https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16997171#comment-16997171
]
Zhu Zhu commented on FLINK-15249:
-
Hi [~nppoly], did you measure the region building per
[
https://issues.apache.org/jira/browse/FLINK-15249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16998122#comment-16998122
]
Zhu Zhu commented on FLINK-15249:
-
Thanks for the reply [~nppoly]. According to the resu
[
https://issues.apache.org/jira/browse/FLINK-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-15320:
---
Assignee: Zhu Zhu
> JobManager crashes in the standalone model when cancelling job which subtask'
[
https://issues.apache.org/jira/browse/FLINK-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999815#comment-16999815
]
Zhu Zhu commented on FLINK-15320:
-
To summarize, this issue happens when an external job
Zhu Zhu created FLINK-15325:
---
Summary: Input location preference which affects task distribution
may make certain job performance worse
Key: FLINK-15325
URL: https://issues.apache.org/jira/browse/FLINK-15325
[
https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15325:
Environment: (was: When running TPC-DS jobs in a session cluster, we
observed that sometimes tasks are
[
https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15325:
Description:
When running TPC-DS jobs in a session cluster, we observed that sometimes tasks
are not even
[
https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15325:
Description:
When running TPC-DS jobs in a session cluster, we observed that sometimes tasks
are not even
[
https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999895#comment-16999895
]
Zhu Zhu commented on FLINK-15325:
-
[~trohrmann] do you think we should have such a confi
[
https://issues.apache.org/jira/browse/FLINK-15320?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16999898#comment-16999898
]
Zhu Zhu commented on FLINK-15320:
-
Thanks [~trohrmann]. And also thanks [~lining] for re
[
https://issues.apache.org/jira/browse/FLINK-15325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-15325:
Issue Type: Improvement (was: Bug)
> Input location preference which affects task distribution may make c
[
https://issues.apache.org/jira/browse/FLINK-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038956#comment-17038956
]
Zhu Zhu commented on FLINK-16139:
-
cc [~gjy]
> Co-location constraints are not reset on
Zhu Zhu created FLINK-16139:
---
Summary: Co-location constraints are not reset on task recovery in
DefaultScheduler
Key: FLINK-16139
URL: https://issues.apache.org/jira/browse/FLINK-16139
Project: Flink
Zhu Zhu created FLINK-16180:
---
Summary: Replacing vertexExecution in ScheduledUnit with
executionVertexID
Key: FLINK-16180
URL: https://issues.apache.org/jira/browse/FLINK-16180
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16180:
Parent: FLINK-15626
Issue Type: Sub-task (was: Improvement)
> Replacing vertexExecution in Schedu
[
https://issues.apache.org/jira/browse/FLINK-16145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040582#comment-17040582
]
Zhu Zhu commented on FLINK-16145:
-
Thanks for reporting this issue [~liuyufei]!
This is
[
https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16180:
Description:
{{ScheduledUnit#vertexExecution}} is nullable but {{ProgrammedSlotProvider}}
requires it to
[
https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17040713#comment-17040713
]
Zhu Zhu commented on FLINK-16180:
-
cc [~gjy] [~trohrmann]
> Replacing vertexExecution i
[
https://issues.apache.org/jira/browse/FLINK-16180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu updated FLINK-16180:
Description:
{{ScheduledUnit#vertexExecution}} is nullable but {{ProgrammedSlotProvider}}
requires it to
[
https://issues.apache.org/jira/browse/FLINK-16139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu resolved FLINK-16139.
-
Resolution: Fixed
Fixed via:
master: 8c01397018f20865094dec8c37cf44279651a279
release-1.10: fd3e6e7dcaee
[
https://issues.apache.org/jira/browse/FLINK-15813?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhu Zhu reassigned FLINK-15813:
---
Assignee: Zhu Zhu
> Set default value of jobmanager.execution.failover-strategy to region
> ---
[
https://issues.apache.org/jira/browse/FLINK-16017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17044298#comment-17044298
]
Zhu Zhu commented on FLINK-16017:
-
Yes region creation is now invoked twice, one from
R
801 - 900 of 2297 matches
Mail list logo
