[
https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17126319#comment-17126319
]
Haibo Sun commented on FLINK-17706:
---
I'm ok with licensing my contributions to the Apa
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-14228.
-
Resolution: Fixed
> The runtime support for Bounded[One|Multi]Input#endInput does not properly
> implem
[
https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039990#comment-17039990
]
Haibo Sun edited comment on FLINK-16174 at 2/19/20 12:57 PM:
-
[
https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17039990#comment-17039990
]
Haibo Sun commented on FLINK-16174:
---
CC [~pnowojski][~roman_khachatryan]
> Add a bett
Haibo Sun created FLINK-16174:
-
Summary: Add a better tryYield() method to MailboxExecutor to
return the lowest priority of the remaining mails
Key: FLINK-16174
URL: https://issues.apache.org/jira/browse/FLINK-16174
[
https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-15070.
-
> Supplement cases of blocking partition with compression for benchmark
> --
[
https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun resolved FLINK-15070.
---
Resolution: Fixed
> Supplement cases of blocking partition with compression for benchmark
>
[
https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17009245#comment-17009245
]
Haibo Sun commented on FLINK-15070:
---
Hotfix PR: https://github.com/dataArtisans/flink-
[
https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16994334#comment-16994334
]
Haibo Sun commented on FLINK-15070:
---
The PR: https://github.com/dataArtisans/flink-ben
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Fix Version/s: (was: 1.10.0)
1.11.0
> The runtime support for Bounded[One|Multi
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-14230.
-
> Change the endInput call of the downstream operator to after the upstream
> operator closes
> --
Haibo Sun created FLINK-14239:
-
Summary: Emitting the max watermark in StreamSource#run may cause
it to arrive the downstream early
Key: FLINK-14239
URL: https://issues.apache.org/jira/browse/FLINK-14239
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14230:
--
Summary: Change the endInput call of the downstream operator to after the
upstream operator closes (
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14230:
--
Summary: Change the endinput call of the downstream operator to after the
upstream operator closes (
Haibo Sun created FLINK-14231:
-
Summary: Support the timers of the upstream operator with endInput
properly
Key: FLINK-14231
URL: https://issues.apache.org/jira/browse/FLINK-14231
Project: Flink
[
https://issues.apache.org/jira/browse/FLINK-14230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14230:
--
Summary: Change the endinput call of the downstream operator to after
closing the upstream operator
Haibo Sun created FLINK-14230:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14230
URL: https://issues.apache.org/jira/browse/FLINK-14230
[
https://issues.apache.org/jira/browse/FLINK-14229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-14229.
-
Resolution: Invalid
> Change the endinput call of the downstream operator to after the upstream
> oper
Haibo Sun created FLINK-14229:
-
Summary: Change the endinput call of the downstream operator to
after the upstream operator closes
Key: FLINK-14229
URL: https://issues.apache.org/jira/browse/FLINK-14229
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
[
https://issues.apache.org/jira/browse/FLINK-14228?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-14228:
--
Description:
Currently, the runtime support implementation of
{{Bounded[One|Multi]Input#endInput}} ha
Haibo Sun created FLINK-14228:
-
Summary: The runtime support for Bounded[One|Multi]Input#endInput
does not properly implement their semantics
Key: FLINK-14228
URL: https://issues.apache.org/jira/browse/FLINK-14228
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:58 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:58 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:43 AM:
---
Th
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16923044#comment-16923044
]
Haibo Sun commented on FLINK-13516:
---
The failure of the case is due to the failure of
[
https://issues.apache.org/jira/browse/FLINK-13515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920617#comment-16920617
]
Haibo Sun commented on FLINK-13515:
---
Sorry for the delay. This week I will work on thi
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16920618#comment-16920618
]
Haibo Sun commented on FLINK-13516:
---
Sorry for the delay. This week I will work on thi
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16913989#comment-16913989
]
Haibo Sun commented on FLINK-12818:
---
{quote}Alternatively until this is confirmed as a
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910939#comment-16910939
]
Haibo Sun commented on FLINK-13516:
---
Hi, [~Zentol]. I can help with this task. Can you
[
https://issues.apache.org/jira/browse/FLINK-13515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16910938#comment-16910938
]
Haibo Sun commented on FLINK-13515:
---
Hi, [~Zentol]. I can help with this task. Can you
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895958#comment-16895958
]
Haibo Sun edited comment on FLINK-13491 at 7/30/19 9:52 AM:
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895973#comment-16895973
]
Haibo Sun commented on FLINK-13491:
---
For two-input operator, {{endInput(int inputId)}}
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895958#comment-16895958
]
Haibo Sun edited comment on FLINK-13491 at 7/30/19 9:37 AM:
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16895958#comment-16895958
]
Haibo Sun commented on FLINK-13491:
---
So for one-input operator, `endInput ()` repeats
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894906#comment-16894906
]
Haibo Sun edited comment on FLINK-12818 at 7/29/19 7:19 AM:
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16894906#comment-16894906
]
Haibo Sun commented on FLINK-12818:
---
Hi [~pnowojski],
The benchmark on
`TwoInputSele
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12818:
--
Attachment: RecordWriter-emit.png
> Improve stability of twoInputMapSink benchmark
> -
[
https://issues.apache.org/jira/browse/FLINK-13242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16887573#comment-16887573
]
Haibo Sun commented on FLINK-13242:
---
Another instance: [https://api.travis-ci.com/v3/j
[
https://issues.apache.org/jira/browse/FLINK-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13299:
--
Affects Version/s: 1.10.0
> flink-python failed on Travis
> -
>
>
[
https://issues.apache.org/jira/browse/FLINK-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13299:
--
Description:
Log: [https://api.travis-ci.com/v3/job/216620643/log.txt]
Error:
__
[
https://issues.apache.org/jira/browse/FLINK-13299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13299:
--
Description:
Log: [https://api.travis-ci.com/v3/job/216620643/log.txt]
Error:
__
Haibo Sun created FLINK-13299:
-
Summary: flink-python failed on Travis
Key: FLINK-13299
URL: https://issues.apache.org/jira/browse/FLINK-13299
Project: Flink
Issue Type: Bug
Reporter:
[
https://issues.apache.org/jira/browse/FLINK-12916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16885897#comment-16885897
]
Haibo Sun commented on FLINK-12916:
---
Another instance: [https://api.travis-ci.com/v3/j
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16876835#comment-16876835
]
Haibo Sun edited comment on FLINK-12573 at 7/2/19 10:06 AM:
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16876835#comment-16876835
]
Haibo Sun commented on FLINK-12573:
---
Hi, [~LouisXu777]
Is there any progress on this
[
https://issues.apache.org/jira/browse/FLINK-13051?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13051:
--
Description: After `StreamTwoInputSelectableProcessor` supports
`CheckpointBarrierHandler`, we should
Haibo Sun created FLINK-13051:
-
Summary: Drop the non-selectable two-input StreamTask and Processor
Key: FLINK-13051
URL: https://issues.apache.org/jira/browse/FLINK-13051
Project: Flink
Issue Ty
[
https://issues.apache.org/jira/browse/FLINK-13014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-13014:
--
Description:
Log: [https://api.travis-ci.org/v3/job/551094138/log.txt]
07:12:52.246 [ERROR] Tests
Haibo Sun created FLINK-13014:
-
Summary: ChainBreakTest failed on Travis
Key: FLINK-13014
URL: https://issues.apache.org/jira/browse/FLINK-13014
Project: Flink
Issue Type: Bug
Reporte
Haibo Sun created FLINK-12967:
-
Summary: Change the input selection switching in
StreamTwoInputSelectableProcessor#checkFinished to invoking the nextSelection
method of the stream operator
Key: FLINK-12967
URL: https
[
https://issues.apache.org/jira/browse/FLINK-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869298#comment-16869298
]
Haibo Sun commented on FLINK-12895:
---
(y)
> TaskManagerProcessFailureBatchRecoveryITCa
[
https://issues.apache.org/jira/browse/FLINK-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12895:
--
Description:
Logs: [https://api.travis-ci.org/v3/job/547509708/log.txt]
Build: [https://travis-ci.or
Haibo Sun created FLINK-12895:
-
Summary:
TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure
failed on travis
Key: FLINK-12895
URL: https://issues.apache.org/jira/browse/FLINK-12895
[
https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11879:
--
Description:
- Rejects the jobs containing operators which were implemented
`InputSelectable` in case
[
https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11879:
--
Description:
- Rejects the jobs containing operators which were implemented
`TwoInputSelectable` in c
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun reassigned FLINK-12818:
-
Assignee: Haibo Sun
> Improve stability of twoInputMapSink benchmark
>
[
https://issues.apache.org/jira/browse/FLINK-12426?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855247#comment-16855247
]
Haibo Sun commented on FLINK-12426:
---
[~QiLuo], the pull request of FLINK-12547 has be
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-12547.
-
> Deadlock when the task thread downloads jars using BlobClient
> --
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16855222#comment-16855222
]
Haibo Sun commented on FLINK-1722:
--
OK, I will.
> Streaming not respecting FinalizeOnM
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun reassigned FLINK-1722:
Assignee: Haibo Sun
> Streaming not respecting FinalizeOnMaster for output formats
> -
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~a
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~a
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~a
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16852871#comment-16852871
]
Haibo Sun commented on FLINK-1722:
--
[~aljoscha] [~rmetzger] , I wrote a simple design do
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848633#comment-16848633
]
Haibo Sun edited comment on FLINK-12547 at 5/27/19 6:08 AM:
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16848633#comment-16848633
]
Haibo Sun commented on FLINK-12547:
---
[~QiLuo], because the blob client has a retry mec
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12547:
--
Description:
The jstack is as follows (this jstack is from an old Flink version, but the
master branc
Haibo Sun created FLINK-12547:
-
Summary: Deadlock when the task thread downloads jars using
BlobClient
Key: FLINK-12547
URL: https://issues.apache.org/jira/browse/FLINK-12547
Project: Flink
Issu
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:25 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:23 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:22 AM:
-
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16842078#comment-16842078
]
Haibo Sun commented on FLINK-12529:
---
>But as far as I understand you would only need t
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12529:
--
Summary: Release record-deserializer buffers timely to improve the
efficiency of heap usage on taskman
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12529:
--
Summary: Release buffers of the record deserializers timely to improve the
efficiency of heap memory u
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841470#comment-16841470
]
Haibo Sun commented on FLINK-12529:
---
[~pnowojski], do you think there is any proble
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16841470#comment-16841470
]
Haibo Sun edited comment on FLINK-12529 at 5/16/19 3:35 PM:
Haibo Sun created FLINK-12529:
-
Summary: Release buffers of the record deserializer timely to
improve the efficiency of heap memory usage on taskmanager
Key: FLINK-12529
URL: https://issues.apache.org/jira/browse/FLIN
[
https://issues.apache.org/jira/browse/FLINK-12292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-12292.
-
Resolution: Invalid
> Add micro benchmarks for two-input processors
> --
[
https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11877:
--
Description:
- Introduces a new `Input` interface to represent the logical input of
operators.
- Int
[
https://issues.apache.org/jira/browse/FLINK-12292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-12292:
--
Summary: Add micro benchmarks for two-input processors (was: Add
benchmarks for the input processors)
[
https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11877:
--
Description:
- Introduces a new `Input` interface to represent the logical input of
operators.
- Int
Haibo Sun created FLINK-12292:
-
Summary: Add benchmarks for the input processors
Key: FLINK-12292
URL: https://issues.apache.org/jira/browse/FLINK-12292
Project: Flink
Issue Type: Sub-task
[
https://issues.apache.org/jira/browse/FLINK-12291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-12291.
-
Resolution: Invalid
> Add benchmarks for the input processors
> ---
Haibo Sun created FLINK-12291:
-
Summary: Add benchmarks for the input processors
Key: FLINK-12291
URL: https://issues.apache.org/jira/browse/FLINK-12291
Project: Flink
Issue Type: Task
[
https://issues.apache.org/jira/browse/FLINK-11876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11876:
--
Summary: Introduce the new interfaces InputSelectable, BoundedOneInput and
BoundedMultiInput (was: In
[
https://issues.apache.org/jira/browse/FLINK-11879?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11879:
--
Summary: Add JobGraph validators for the uses of InputSelectable,
BoundedOneInput and BoundedMultiInpu
[
https://issues.apache.org/jira/browse/FLINK-11878?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11878:
--
Summary: Implement the runtime handling of BoundedOneInput and
BoundedMultiInput (was: Implement the
[
https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11877:
--
Summary: Implement the runtime handling of the InputSelectable interface
(was: Implement the runtime
[
https://issues.apache.org/jira/browse/FLINK-11880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun closed FLINK-11880.
-
Resolution: Duplicate
It repeats FLINK-11879 .
> Add JobGraph validators for the uses of TwoInputSelect
Haibo Sun created FLINK-11879:
-
Summary: Add JobGraph validators for the uses of
TwoInputSelectable, BoundedOneInput and BoundedTwoInput
Key: FLINK-11879
URL: https://issues.apache.org/jira/browse/FLINK-11879
Haibo Sun created FLINK-11880:
-
Summary: Add JobGraph validators for the uses of
TwoInputSelectable, BoundedOneInput and BoundedTwoInput
Key: FLINK-11880
URL: https://issues.apache.org/jira/browse/FLINK-11880
[
https://issues.apache.org/jira/browse/FLINK-11877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Haibo Sun updated FLINK-11877:
--
Description:
- Introduces a new class `Input` to represent the logical input of operators.
- Introduc
Haibo Sun created FLINK-11878:
-
Summary: Implement the runtime handling of BoundedOneInput and
BoundedTwoInput
Key: FLINK-11878
URL: https://issues.apache.org/jira/browse/FLINK-11878
Project: Flink
1 - 100 of 104 matches
Mail list logo