[
https://issues.apache.org/jira/browse/FLINK-13754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13754:
-
Description:
The current OperatorChain is heavy-weight to take some unrelated roles like
StreamStatusMa
[
https://issues.apache.org/jira/browse/FLINK-13754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13754:
-
Summary: Decouple OperatorChain with StreamStatusMaintainer (was: Decouple
OperatorChain from StreamSta
[
https://issues.apache.org/jira/browse/FLINK-13754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13754:
-
Description:
The current OperatorChain is heavy-weight to take some unrelated roles like
StreamStatusMa
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911537#comment-16911537
]
zhijiang commented on FLINK-13798:
--
Thanks for this notification [~StephanEwen]. Wish i
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Comment: was deleted
(was: Thanks for the replies. [~StephanEwen]
Wish it would make logic easy underst
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911455#comment-16911455
]
zhijiang commented on FLINK-13798:
--
Thanks for the replies. [~StephanEwen]
Wish it wou
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13798:
-
Description:
As we know, the watermark could be emitted to downstream only when the stream
status is ac
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16911275#comment-16911275
]
zhijiang commented on FLINK-13798:
--
Thanks for the offline discussion and suggestion.
zhijiang created FLINK-13798:
Summary: Refactor the process of checking stream status while
emitting watermark in source
Key: FLINK-13798
URL: https://issues.apache.org/jira/browse/FLINK-13798
Project: Fl
zhijiang created FLINK-13767:
Summary: Migrate isFinished method from AvailabilityListener to
AsyncDataInput
Key: FLINK-13767
URL: https://issues.apache.org/jira/browse/FLINK-13767
Project: Flink
zhijiang created FLINK-13766:
Summary: Refactor the implementation of StreamInputProcessor based
on StreamTaskInput#emitNext
Key: FLINK-13766
URL: https://issues.apache.org/jira/browse/FLINK-13766
Project
zhijiang created FLINK-13765:
Summary: Introduce the InputSelectionHandler for selecting next
input in StreamTwoInputSelectableProcessor
Key: FLINK-13765
URL: https://issues.apache.org/jira/browse/FLINK-13765
zhijiang created FLINK-13764:
Summary: Pass the counter of numRecordsIn into the constructors of
StreamOne/TwoInputProcessor
Key: FLINK-13764
URL: https://issues.apache.org/jira/browse/FLINK-13764
Project
[
https://issues.apache.org/jira/browse/FLINK-13764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13764:
-
Component/s: Runtime / Metrics
> Pass the counter of numRecordsIn into the constructors of
> StreamOne/
[
https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13762:
-
Description:
Currently StreamOneInputProcessor and StreamTwoInputSelectableProcessor have
separate impl
[
https://issues.apache.org/jira/browse/FLINK-13762?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13762:
-
Summary: Implement a unified StatusWatermarkOutputHandler for
StreamOne/TwoInputProcessor (was: Integra
zhijiang created FLINK-13762:
Summary: Integrate the implementation of
ForwardingValveOutputHandler for StreamOne/TwoInputProcessor
Key: FLINK-13762
URL: https://issues.apache.org/jira/browse/FLINK-13762
zhijiang created FLINK-13754:
Summary: Decouple OperatorChain from StreamStatusMaintainer
Key: FLINK-13754
URL: https://issues.apache.org/jira/browse/FLINK-13754
Project: Flink
Issue Type: Sub-ta
[
https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13753:
-
Description:
This is the umbrella issue for integrating new source operator with mailbox
model in Strea
[
https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13753:
-
Description:
This is the umbrella issue for integrating new source operator with mailbox
model in Strea
zhijiang created FLINK-13753:
Summary: Integrate new Source Operator with Mailbox Model in
StreamTask
Key: FLINK-13753
URL: https://issues.apache.org/jira/browse/FLINK-13753
Project: Flink
Issue
[
https://issues.apache.org/jira/browse/FLINK-13753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13753:
-
Description:
This is the umbrella issue for integrating new source operator with mailbox
model in Strea
[
https://issues.apache.org/jira/browse/FLINK-12630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-12630.
Resolution: Won't Fix
> Refactor abstract InputGate to general interface
> ---
[
https://issues.apache.org/jira/browse/FLINK-12576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-12576.
Resolution: Fixed
Fix in master : 302fc1d5de38bb6db99ddc45470efcc9ebd782bc
Fix in release-1.9 : 2a6fb9af7
[
https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16898697#comment-16898697
]
zhijiang commented on FLINK-13435:
--
Thanks for helping merge into 1.9, I forgot that. [
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:10 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:09 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:07 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-13435.
Resolution: Fixed
Fixed in master : 6ce4e2b7ec958570068838491bd8f56f880c
> Remove ShuffleDescriptor.R
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897998#comment-16897998
]
zhijiang commented on FLINK-13493:
--
Thanks for the clarification [~azagrebin]!
I agree
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897491#comment-16897491
]
zhijiang commented on FLINK-10672:
--
Could you also test the release-1.8.1 or current ma
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16897482#comment-16897482
]
zhijiang commented on FLINK-13478:
--
[~azagrebin], thanks for the consideration.
I thin
[
https://issues.apache.org/jira/browse/FLINK-13489?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-13489:
Assignee: Yingjie Cao (was: zhijiang)
> Heavy deployment end-to-end test fails on Travis with TM
[
https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-13487:
Assignee: Yun Gao (was: Yun Gao)
> TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfterR
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13478:
-
Description:
We have two basic release strategies atm. One is based on consumption via
network notifica
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13478:
-
Description:
We have two basic release strategies atm. One is based on consumption via
network notifica
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896163#comment-16896163
]
zhijiang commented on FLINK-13478:
--
I think it might belong to a pure refactoring.
>Fr
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13478:
-
Comment: was deleted
(was: I think it might belong to a pure refactoring.
>From behavior aspect, this f
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896149#comment-16896149
]
zhijiang commented on FLINK-13478:
--
I think it might belong to a pure refactoring.
>Fr
[
https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16896083#comment-16896083
]
zhijiang commented on FLINK-13487:
--
Thanks for the cooperation from [~SleePy] and [~gao
[
https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-13487:
Assignee: Yun Gao (was: zhijiang)
> TaskExecutorPartitionLifecycleTest.testPartitionReleaseAfter
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895932#comment-16895932
]
zhijiang commented on FLINK-13442:
--
I change the priority of this issue as not blocker
zhijiang created FLINK-13493:
Summary: BoundedBlockingSubpartition only notifies
onConsumedSubpartition when all the readers are empty
Key: FLINK-13493
URL: https://issues.apache.org/jira/browse/FLINK-13493
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Fix Version/s: (was: 1.9.0)
1.10
> Remove unnecessary notifySubpartitionConsumed
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Issue Type: Improvement (was: Bug)
> Remove unnecessary notifySubpartitionConsumed method from view rea
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Priority: Minor (was: Blocker)
> Remove unnecessary notifySubpartitionConsumed method from view reader
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Issue Type: Bug (was: Improvement)
> Remove unnecessary notifySubpartitionConsumed method from view rea
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Priority: Blocker (was: Minor)
> Remove unnecessary notifySubpartitionConsumed method from view reader
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895832#comment-16895832
]
zhijiang commented on FLINK-13478:
--
[~StephanEwen] [~pnowojski] [~azagrebin] What do yo
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Fix Version/s: 1.9.0
> Remove unnecessary notifySubpartitionConsumed method from view reader
>
zhijiang created FLINK-13478:
Summary: Decouple two different release strategies in
BoundedBlockingSubpartition
Key: FLINK-13478
URL: https://issues.apache.org/jira/browse/FLINK-13478
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13442:
-
Description:
Currently the methods of `NetworkSequenceViewReader#notifySubpartitionConsumed`
and ` Netw
zhijiang created FLINK-13442:
Summary: Remove unnecessary notifySubpartitionConsumed method from
view reader
Key: FLINK-13442
URL: https://issues.apache.org/jira/browse/FLINK-13442
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-13325?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16893462#comment-16893462
]
zhijiang commented on FLINK-13325:
--
Yes, I already reviewed this PR several days ago. W
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16893427#comment-16893427
]
zhijiang commented on FLINK-13245:
--
Thanks for joining this discussion and giving helpf
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16890630#comment-16890630
]
zhijiang commented on FLINK-13245:
--
[~azagrebin] I totally agree with your above point.
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16889022#comment-16889022
]
zhijiang commented on FLINK-13245:
--
After confirming the comments from [~Zentol] in PR,
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16888788#comment-16888788
]
zhijiang commented on FLINK-13245:
--
Thanks for these further thoughts and I think it wo
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887642#comment-16887642
]
zhijiang commented on FLINK-10672:
--
[~ibzib] I think it is the case of back pressure. T
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887201#comment-16887201
]
zhijiang commented on FLINK-10672:
--
[~ibzib] which fix do you mean?
In addition which
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885832#comment-16885832
]
zhijiang edited comment on FLINK-13245 at 7/16/19 4:16 AM:
---
We
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885832#comment-16885832
]
zhijiang commented on FLINK-13245:
--
We have some previous assumptions that ResultSubpar
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13245:
-
Comment: was deleted
(was: [~azagrebin] I have not seen your latest comments before submitting above.
I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:47 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:46 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:44 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:43 PM:
---
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885396#comment-16885396
]
zhijiang commented on FLINK-13245:
--
[~azagrebin] I have not seen your latest comments b
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885371#comment-16885371
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the inv
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885371#comment-16885371
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:22 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13245:
-
Comment: was deleted
(was: Thanks for finding this potential issue and the investigation! [~Zentol]
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13245:
-
Comment: was deleted
(was: For the first issue, I think it is not very important currently, because
we
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885280#comment-16885280
]
zhijiang commented on FLINK-13245:
--
For the first issue, I think it is not very importa
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885280#comment-16885280
]
zhijiang edited comment on FLINK-13245 at 7/15/19 2:27 PM:
---
Fo
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885251#comment-16885251
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the inv
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13245:
-
Comment: was deleted
(was: Thanks for finding this potential issue and the investigation! [~Zentol]
[~
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885241#comment-16885241
]
zhijiang edited comment on FLINK-13245 at 7/15/19 1:46 PM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885241#comment-16885241
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the inv
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13245:
-
Comment: was deleted
(was: Thanks for finding this potential issue and the investigation! [~Zentol]
[~a
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885076#comment-16885076
]
zhijiang edited comment on FLINK-13245 at 7/15/19 10:46 AM:
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885076#comment-16885076
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the inv
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-13100.
Resolution: Resolved
Fixed in 2c8ee78f714af4995f618c768661f5b638cd3025
> Fix the bug of throwing IOExcept
zhijiang created FLINK-13235:
Summary: Change the Netty default transport mode to auto
Key: FLINK-13235
URL: https://issues.apache.org/jira/browse/FLINK-13235
Project: Flink
Issue Type: Improveme
[
https://issues.apache.org/jira/browse/FLINK-13141?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang closed FLINK-13141.
Resolution: Resolved
Fixed in b6563e385263beb556ce19855ca6dfdbb7f6c853
> Remove getBufferSize method fro
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13100:
-
Summary: Fix the bug of throwing IOException while
FileBufferReader#nextBuffer (was: Fix the bug of thr
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang updated FLINK-13100:
-
Summary: Fix the bug of throwing IOException during
FileBufferReader#nextBuffer (was: Fix the unexpecte
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
zhijiang reassigned FLINK-13100:
Assignee: zhijiang
> Fix the unexpected IOException during FileBufferReader#nextBuffer
>
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881029#comment-16881029
]
zhijiang commented on FLINK-13100:
--
Yes, the ITCase is also necessary and I think it sh
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16881003#comment-16881003
]
zhijiang commented on FLINK-13100:
--
[~pnowojski] the previous deadlock was ever happene
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880999#comment-16880999
]
zhijiang commented on FLINK-13100:
--
In netty internal implementation of writeAndFlush()
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880499#comment-16880499
]
zhijiang commented on FLINK-11082:
--
Yes, I also thought it was not an issue.
> Fix the
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880465#comment-16880465
]
zhijiang edited comment on FLINK-13100 at 7/8/19 3:30 PM:
--
Yes,
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16880465#comment-16880465
]
zhijiang edited comment on FLINK-13100 at 7/8/19 3:29 PM:
--
Yes,
701 - 800 of 1163 matches
Mail list logo