[
https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-18767:
-
Affects Version/s: (was: 1.8.3)
> Streaming job stuck when disabling operator chaining
> ---
[
https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17169904#comment-17169904
]
Zhijiang commented on FLINK-18767:
--
After confirming with [~NicoK] offline, it had some
[
https://issues.apache.org/jira/browse/FLINK-18767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-18767.
Resolution: Not A Problem
> Streaming job stuck when disabling operator chaining
> ---
[
https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-18821:
Assignee: Roman Kishchenko
> Netty client retry mechanism may cause
> PartitionRequestClientFact
[
https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-18821:
Assignee: Roman Khachatryan (was: Roman Kishchenko)
> Netty client retry mechanism may cause
>
[
https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171894#comment-17171894
]
Zhijiang commented on FLINK-18832:
--
Thanks for reporting this bug [~trohrmann]!
By des
[
https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17171894#comment-17171894
]
Zhijiang edited comment on FLINK-18832 at 8/6/20, 4:15 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-18832:
Assignee: Zhijiang
> BoundedBlockingSubpartition does not work with StreamTask
>
[
https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17172778#comment-17172778
]
Zhijiang commented on FLINK-18796:
--
Merged in master: 33bdc978a059c50ec55b8f24d40039d13
[
https://issues.apache.org/jira/browse/FLINK-18796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-18796.
Resolution: Fixed
> FlinkKinesisProducer.backpressureLatch should be volatile
> --
[
https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17175960#comment-17175960
]
Zhijiang commented on FLINK-18832:
--
Thanks for the explanation [~dwysakowicz].
If so,
[
https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-18821.
Resolution: Fixed
Merged in release-1.11: ded539e85444f9c8d34f88da31784775ed281aba
Merged in master: 33bdc
[
https://issues.apache.org/jira/browse/FLINK-18821?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176163#comment-17176163
]
Zhijiang edited comment on FLINK-18821 at 8/13/20, 3:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-18832?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17176817#comment-17176817
]
Zhijiang commented on FLINK-18832:
--
[~pnowojski] Agree with you proposal. It would be n
Zhijiang created FLINK-19003:
Summary: Add micro-benchmark for unaligned checkpoints
Key: FLINK-19003
URL: https://issues.apache.org/jira/browse/FLINK-19003
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-18955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-18955:
Assignee: Yuan Mei
> Add snapshot path to job startup message
> -
[
https://issues.apache.org/jira/browse/FLINK-18695?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17184963#comment-17184963
]
Zhijiang commented on FLINK-18695:
--
If I understood correctly, there seems three option
[
https://issues.apache.org/jira/browse/FLINK-19003?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-19003.
Resolution: Fixed
Merged in master: de049572690f4f744c9706dba5268e242f9e3bc8
> Add micro-benchmark for un
[
https://issues.apache.org/jira/browse/FLINK-19012?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-19012.
Resolution: Fixed
Merged in master : 378115ffd1642c782c7d0f203c5c46e07d18fc23
> E2E test fails with "Cann
[
https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-18694:
Assignee: Kboh
> Add unaligned checkpoint config to web ui
>
[
https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-18694.
Resolution: Fixed
Merged in master: 56ee6b49c594ac5da12a8d5d666d61bccf9e4083
> Add unaligned checkpoint c
[
https://issues.apache.org/jira/browse/FLINK-18694?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-18694:
-
Fix Version/s: 1.12.0
> Add unaligned checkpoint config to web ui
>
[
https://issues.apache.org/jira/browse/FLINK-19054?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17188111#comment-17188111
]
Zhijiang commented on FLINK-19054:
--
Anther instance
https://dev.azure.com/apache-flink
[
https://issues.apache.org/jira/browse/FLINK-15981?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-15981:
-
Affects Version/s: 1.10.1
1.11.0
1.10.2
[
https://issues.apache.org/jira/browse/FLINK-19093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-19093.
Resolution: Fixed
Merged in master: 76f37551ad51f7eae9688495130a39b0f202c3bf
> "Elasticsearch (v6.3.1) si
[
https://issues.apache.org/jira/browse/FLINK-19400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17202759#comment-17202759
]
Zhijiang commented on FLINK-19400:
--
+1 to remove, it is indeed no actual usages in core
[
https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-17331:
-
Fix Version/s: (was: 1.12.0)
> Add NettyMessageContent interface for all the class which could be wr
[
https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-17331:
Assignee: Yangze Guo
> Add NettyMessageContent interface for all the class which could be write t
[
https://issues.apache.org/jira/browse/FLINK-17331?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204445#comment-17204445
]
Zhijiang commented on FLINK-17331:
--
After offline discussing with [~karmagyz], i am awa
[
https://issues.apache.org/jira/browse/FLINK-19249?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17204453#comment-17204453
]
Zhijiang commented on FLINK-19249:
--
Thanks for reporting this [~klion26] and all the ab
[
https://issues.apache.org/jira/browse/FLINK-13010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-13010.
Resolution: Later
Close it for cleanup, then consider reopening it future once necessary and
available fo
[
https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-12110:
Assignee: (was: Zhijiang)
> Introduce API point for ShuffleEnvironment to get estimation of l
Zhijiang created FLINK-19551:
Summary: Follow up improvements for shuffle service
Key: FLINK-19551
URL: https://issues.apache.org/jira/browse/FLINK-19551
Project: Flink
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/FLINK-13642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-13642:
-
Parent: (was: FLINK-10653)
Issue Type: Task (was: Sub-task)
> Refactor ShuffleMaster to opt
[
https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12110:
-
Parent: (was: FLINK-10653)
Issue Type: Task (was: Sub-task)
> Introduce API point for Shuff
[
https://issues.apache.org/jira/browse/FLINK-13642?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-13642:
-
Parent: FLINK-19551
Issue Type: Sub-task (was: Task)
> Refactor ShuffleMaster to optionally pro
[
https://issues.apache.org/jira/browse/FLINK-12110?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12110:
-
Parent: FLINK-19551
Issue Type: Sub-task (was: Task)
> Introduce API point for ShuffleEnvironme
[
https://issues.apache.org/jira/browse/FLINK-12543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12543:
-
Parent: (was: FLINK-10653)
Issue Type: Task (was: Sub-task)
> Consider naming convention fo
[
https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12731:
-
Parent: FLINK-19551
Issue Type: Sub-task (was: Task)
> Load shuffle service implementations fro
[
https://issues.apache.org/jira/browse/FLINK-12543?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12543:
-
Parent: FLINK-19551
Issue Type: Sub-task (was: Task)
> Consider naming convention for config op
[
https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12731:
-
Parent: (was: FLINK-10653)
Issue Type: Task (was: Sub-task)
> Load shuffle service implemen
[
https://issues.apache.org/jira/browse/FLINK-12873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12873:
-
Parent: FLINK-19551
Issue Type: Sub-task (was: Task)
> Create a separate maven module for Shuff
[
https://issues.apache.org/jira/browse/FLINK-12873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-12873:
-
Parent: (was: FLINK-10653)
Issue Type: Task (was: Sub-task)
> Create a separate maven modul
[
https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-10653.
Resolution: Fixed
[~trohrmann], thanks for this kind reminder,:).
I already migrated all the pending open
[
https://issues.apache.org/jira/browse/FLINK-10653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-10653:
-
Fix Version/s: 1.9.0
> Introduce Pluggable Shuffle Service Architecture
> --
[
https://issues.apache.org/jira/browse/FLINK-16753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16753.
Resolution: Fixed
Merged in master: a1b1dc95210e99e6c23069415283fce4ec3793a5
> Exception from AsyncCheckp
[
https://issues.apache.org/jira/browse/FLINK-16428?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang reassigned FLINK-16428:
Assignee: (was: Zhijiang)
> Fine-grained network buffer management for backpressure
> ---
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-13493.
Resolution: Later
Close this issue for cleanup since it is not really important ATM and we can
reopen it
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-13478.
Resolution: Won't Fix
This issue is out of date since partition release logics have changed a lot
before.
[
https://issues.apache.org/jira/browse/FLINK-7282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-7282.
---
Resolution: Fixed
> Credit-based Network Flow Control
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-9253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17212929#comment-17212929
]
Zhijiang commented on FLINK-9253:
-
[~NicoK] I just closed the parent umbrella ticket for
[
https://issues.apache.org/jira/browse/FLINK-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-14551:
-
Fix Version/s: (was: 1.12.0)
1.11.0
> Unaligned checkpoints
> ---
[
https://issues.apache.org/jira/browse/FLINK-14551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-14551.
Resolution: Fixed
> Unaligned checkpoints
> -
>
> Key: FLINK-14551
>
[
https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-17741:
-
Parent: (was: FLINK-14551)
Issue Type: Task (was: Sub-task)
> Create integration or e2e tes
[
https://issues.apache.org/jira/browse/FLINK-15187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-15187.
Resolution: Fixed
Resolved in FLINK-15981
> Reuse LocalBufferPool for FileBufferReader in blocking partit
[
https://issues.apache.org/jira/browse/FLINK-17741?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang updated FLINK-17741:
-
Parent: FLINK-19442
Issue Type: Sub-task (was: Task)
> Create integration or e2e test for out o
[
https://issues.apache.org/jira/browse/FLINK-16739?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-16739.
Resolution: Cannot Reproduce
Close it for cleanup since it was not reproduced in recent half a year.
> Pr
[
https://issues.apache.org/jira/browse/FLINK-15963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-15963.
Resolution: Later
Close it for cleanup since it is not really critical by now and nobody has time
to work
[
https://issues.apache.org/jira/browse/FLINK-19155?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Zhijiang closed FLINK-19155.
Resolution: Won't Fix
Close it since this ut has already been removed in another refactoring work.
> Resu
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216517#comment-17216517
]
Zhijiang commented on FLINK-19596:
--
Thanks for proposing this potential improvement [~w
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216520#comment-17216520
]
Zhijiang commented on FLINK-19596:
--
I heard of this issue proposed long time ago from [
[
https://issues.apache.org/jira/browse/FLINK-19596?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17216520#comment-17216520
]
Zhijiang edited comment on FLINK-19596 at 10/19/20, 8:04 AM:
-
zhijiang created FLINK-11441:
Summary: Remove the schedule mode property from RPDD to TDD
Key: FLINK-11441
URL: https://issues.apache.org/jira/browse/FLINK-11441
Project: Flink
Issue Type: Sub-ta
zhijiang created FLINK-11460:
Summary: Remove useless AcknowledgeStreamMockEnvironment
Key: FLINK-11460
URL: https://issues.apache.org/jira/browse/FLINK-11460
Project: Flink
Issue Type: Task
zhijiang created FLINK-11461:
Summary: Remove useless MockRecordWriter
Key: FLINK-11461
URL: https://issues.apache.org/jira/browse/FLINK-11461
Project: Flink
Issue Type: Task
Components
zhijiang created FLINK-11604:
Summary: Extend the necessary methods in ResultPartitionWriter
interface
Key: FLINK-11604
URL: https://issues.apache.org/jira/browse/FLINK-11604
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-11441?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-11441.
Resolution: Won't Fix
> Remove the schedule mode property from RPDD to TDD
> -
zhijiang created FLINK-11646:
Summary: Remove legacy MockRecordWriter
Key: FLINK-11646
URL: https://issues.apache.org/jira/browse/FLINK-11646
Project: Flink
Issue Type: Test
Components:
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-6227:
---
Assignee: (was: zhijiang)
> Introduce the DataConsumptionException for downstream task failure
>
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16771597#comment-16771597
]
zhijiang commented on FLINK-6227:
-
[~Salatich], I have not worked on it yet. And I think
zhijiang created FLINK-11676:
Summary: Make ResultPartitionWriter extend AutoCloseable
Key: FLINK-11676
URL: https://issues.apache.org/jira/browse/FLINK-11676
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11707:
Summary: Make InputGate interface extend AutoCloseable
Key: FLINK-11707
URL: https://issues.apache.org/jira/browse/FLINK-11707
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11721:
Summary: Remove IOMode from NetworkEnvironment
Key: FLINK-11721
URL: https://issues.apache.org/jira/browse/FLINK-11721
Project: Flink
Issue Type: Sub-task
zhijiang created FLINK-11723:
Summary: Remove KvState related components from NetworkEnvironment
Key: FLINK-11723
URL: https://issues.apache.org/jira/browse/FLINK-11723
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16774949#comment-16774949
]
zhijiang commented on FLINK-6227:
-
I think this task seems a bit complicated for the begi
zhijiang created FLINK-11726:
Summary: Refactor the creation of ResultPartition and InputGate
into NetworkEnvironment
Key: FLINK-11726
URL: https://issues.apache.org/jira/browse/FLINK-11726
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-6227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16777549#comment-16777549
]
zhijiang commented on FLINK-6227:
-
The initial motivation of this task is to give a hint/
zhijiang created FLINK-11750:
Summary: Refactor the creation of ResultPartitionID in
IntermediateResultPartition
Key: FLINK-11750
URL: https://issues.apache.org/jira/browse/FLINK-11750
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-11750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-11750:
-
Description:
The motivation of task is for preparing the creation of {{ResultPartition}} via
{{ShuffleS
[
https://issues.apache.org/jira/browse/FLINK-11750?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-11750:
-
Summary: Replace IntermediateResultPartitionID with ResultPartitionID in
ResultPartitionDeploymentDescri
[
https://issues.apache.org/jira/browse/FLINK-11393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778842#comment-16778842
]
zhijiang commented on FLINK-11393:
--
[~Salatich], I am glad to see you are interested in
[
https://issues.apache.org/jira/browse/FLINK-1275?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16778988#comment-16778988
]
zhijiang commented on FLINK-1275:
-
[~uce], thanks for creating this valuable ticket befor
zhijiang created FLINK-11776:
Summary: Refactor to simplify the process of
scheduleOrUpdateConsumers
Key: FLINK-11776
URL: https://issues.apache.org/jira/browse/FLINK-11776
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12882:
-
Description:
The {{ExecutionAttemptID}} is only used for constructing {{ResultPartitionID}}
during crea
zhijiang created FLINK-12882:
Summary: Remove ExecutionAttemptID field from
ShuffleEnvironment#createResultPartitionWriters
Key: FLINK-12882
URL: https://issues.apache.org/jira/browse/FLINK-12882
Project:
[
https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871941#comment-16871941
]
zhijiang commented on FLINK-12909:
--
The ticket does not describes the issue well.
Any
[
https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16871942#comment-16871942
]
zhijiang commented on FLINK-12909:
--
Also you should connect the PR #7191 to this Jira t
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12889:
-
Component/s: (was: API / DataStream)
Runtime / Coordination
> Job keeps in FAILING
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12889:
-
Affects Version/s: (was: 1.7.2)
> Job keeps in FAILING state
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933
]
zhijiang commented on FLINK-12889:
--
My previous analysis in ML was as follows:
Actual
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933
]
zhijiang edited comment on FLINK-12889 at 6/26/19 5:32 AM:
---
My
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12889:
-
Priority: Minor (was: Blocker)
> Job keeps in FAILING state
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-12889?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16872933#comment-16872933
]
zhijiang edited comment on FLINK-12889 at 6/26/19 5:33 AM:
---
My
[
https://issues.apache.org/jira/browse/FLINK-12284?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12284:
-
Component/s: Runtime / Metrics
> InputBufferPoolUsage is incorrect in credit-based network control flow
zhijiang created FLINK-13010:
Summary: Refactor the process of SchedulerNG#requestPartitionState
Key: FLINK-13010
URL: https://issues.apache.org/jira/browse/FLINK-13010
Project: Flink
Issue Type:
[
https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12882:
-
Description: The ResultPartitionID could be got directly from
ResultPartitionDeploymentDescriptor, so it
[
https://issues.apache.org/jira/browse/FLINK-12882?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-12882:
-
Summary: Remove ExecutionAttemptID argument from
ResultPartitionFactory#create (was: Remove ExecutionAt
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877073#comment-16877073
]
zhijiang commented on FLINK-12852:
--
[~StephanEwen] thanks for concerning this issue and
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877605#comment-16877605
]
zhijiang commented on FLINK-12852:
--
The spill way could solve the deadlock issue in fun
[
https://issues.apache.org/jira/browse/FLINK-12852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16877616#comment-16877616
]
zhijiang commented on FLINK-12852:
--
Hey [~gaoyunhaii], considering the second point for
501 - 600 of 1087 matches
Mail list logo