[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911537#comment-16911537
]
zhijiang commented on FLINK-13798:
--
Thanks for this notification [~StephanEwen]. Wish it would make the
[
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
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911455#comment-16911455
]
zhijiang commented on FLINK-13798:
--
Thanks for the replies. [~StephanEwen]
Wish it would make logic
[
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
[
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
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-13798?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16911275#comment-16911275
]
zhijiang commented on FLINK-13798:
--
Thanks for the offline discussion and suggestion. [~pnowojski]
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:
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
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
[
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
>
[
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
[
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:
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:
[
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
[
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
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
[
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
[
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 :
[
https://issues.apache.org/jira/browse/FLINK-13435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898697#comment-16898697
]
zhijiang commented on FLINK-13435:
--
Thanks for helping merge into 1.9, I forgot that. [~Zentol]
>
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:10 PM:
---
Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:09 PM:
---
Thanks for the
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998
]
zhijiang edited comment on FLINK-13493 at 8/1/19 12:07 PM:
---
Thanks for the
[
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
[
https://issues.apache.org/jira/browse/FLINK-13493?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897998#comment-16897998
]
zhijiang commented on FLINK-13493:
--
Thanks for the clarification [~azagrebin]!
I agree it should be no
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897491#comment-16897491
]
zhijiang commented on FLINK-10672:
--
Could you also test the release-1.8.1 or current master branch
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16897482#comment-16897482
]
zhijiang commented on FLINK-13478:
--
[~azagrebin], thanks for the consideration.
I think it would no
[
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
[
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)
>
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896163#comment-16896163
]
zhijiang commented on FLINK-13478:
--
I think it might belong to a pure refactoring.
>From behavior
[
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
[
https://issues.apache.org/jira/browse/FLINK-13478?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896149#comment-16896149
]
zhijiang commented on FLINK-13478:
--
I think it might belong to a pure refactoring.
>From behavior
[
https://issues.apache.org/jira/browse/FLINK-13487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896083#comment-16896083
]
zhijiang commented on FLINK-13487:
--
Thanks for the cooperation from [~SleePy] and [~gaoyunhaii] to
[
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)
>
[
https://issues.apache.org/jira/browse/FLINK-13442?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895932#comment-16895932
]
zhijiang commented on FLINK-13442:
--
I change the priority of this issue as not blocker and create
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
[
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
[
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=16895832#comment-16895832
]
zhijiang commented on FLINK-13478:
--
[~StephanEwen] [~pnowojski] [~azagrebin] What do you think this
[
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 `
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=16893462#comment-16893462
]
zhijiang commented on FLINK-13325:
--
Yes, I already reviewed this PR several days ago. Waiting for the
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16893427#comment-16893427
]
zhijiang commented on FLINK-13245:
--
Thanks for joining this discussion and giving helpful suggestions
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16890630#comment-16890630
]
zhijiang commented on FLINK-13245:
--
[~azagrebin] I totally agree with your above point. The first
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16889022#comment-16889022
]
zhijiang commented on FLINK-13245:
--
After confirming the comments from [~Zentol] in PR, I found that
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16888788#comment-16888788
]
zhijiang commented on FLINK-13245:
--
Thanks for these further thoughts and I think it would make things
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887642#comment-16887642
]
zhijiang commented on FLINK-10672:
--
[~ibzib] I think it is the case of back pressure. The producer is
[
https://issues.apache.org/jira/browse/FLINK-10672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16887201#comment-16887201
]
zhijiang commented on FLINK-10672:
--
[~ibzib] which fix do you mean?
In addition which flink version
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885832#comment-16885832
]
zhijiang edited comment on FLINK-13245 at 7/16/19 4:16 AM:
---
We have some
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885832#comment-16885832
]
zhijiang commented on FLINK-13245:
--
We have some previous assumptions that ResultSubpartitionView could
[
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.
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:47 PM:
---
[~azagrebin] I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:46 PM:
---
[~azagrebin] I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:44 PM:
---
[~azagrebin] I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885396#comment-16885396
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:43 PM:
---
[~azagrebin] I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885396#comment-16885396
]
zhijiang commented on FLINK-13245:
--
[~azagrebin] I have not seen your latest comments before I
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885371#comment-16885371
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the investigation!
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885371#comment-16885371
]
zhijiang edited comment on FLINK-13245 at 7/15/19 4:22 PM:
---
Thanks for finding
[
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=16885280#comment-16885280
]
zhijiang commented on FLINK-13245:
--
For the first issue, I think it is not very important currently,
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885280#comment-16885280
]
zhijiang edited comment on FLINK-13245 at 7/15/19 2:27 PM:
---
For the first
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885251#comment-16885251
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the investigation!
[
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=16885241#comment-16885241
]
zhijiang edited comment on FLINK-13245 at 7/15/19 1:46 PM:
---
Thanks for finding
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885241#comment-16885241
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the investigation!
[
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=16885076#comment-16885076
]
zhijiang edited comment on FLINK-13245 at 7/15/19 10:46 AM:
Thanks for
[
https://issues.apache.org/jira/browse/FLINK-13245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885076#comment-16885076
]
zhijiang commented on FLINK-13245:
--
Thanks for finding this potential issue and the investigation!
[
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
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:
[
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
[
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
[
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
[
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=16881029#comment-16881029
]
zhijiang commented on FLINK-13100:
--
Yes, the ITCase is also necessary and I think it should already
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16881003#comment-16881003
]
zhijiang commented on FLINK-13100:
--
[~pnowojski] the previous deadlock was ever happened on our side
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880999#comment-16880999
]
zhijiang commented on FLINK-13100:
--
In netty internal implementation of writeAndFlush(), the write
[
https://issues.apache.org/jira/browse/FLINK-11082?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880499#comment-16880499
]
zhijiang commented on FLINK-11082:
--
Yes, I also thought it was not an issue.
> Fix the calculation of
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880465#comment-16880465
]
zhijiang edited comment on FLINK-13100 at 7/8/19 3:30 PM:
--
Yes, the previous
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880465#comment-16880465
]
zhijiang edited comment on FLINK-13100 at 7/8/19 3:29 PM:
--
Yes, the previous
[
https://issues.apache.org/jira/browse/FLINK-13100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16880465#comment-16880465
]
zhijiang edited comment on FLINK-13100 at 7/8/19 3:28 PM:
--
Yes, the previous
701 - 800 of 1161 matches
Mail list logo
