[
https://issues.apache.org/jira/browse/FLINK-17706?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126319#comment-17126319
]
Haibo Sun commented on FLINK-17706:
---
I'm ok with licensing my contributions to the Apache License 2.0.
[
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
>
[
https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039990#comment-17039990
]
Haibo Sun edited comment on FLINK-16174 at 2/19/20 12:57 PM:
-
CC
[
https://issues.apache.org/jira/browse/FLINK-16174?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17039990#comment-17039990
]
Haibo Sun commented on FLINK-16174:
---
CC [~pnowojski][~roman_khachatryan]
> Add a better tryYield()
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=17009245#comment-17009245
]
Haibo Sun commented on FLINK-15070:
---
Hotfix PR:
[
https://issues.apache.org/jira/browse/FLINK-15070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16994334#comment-16994334
]
Haibo Sun commented on FLINK-15070:
---
The PR: https://github.com/dataArtisans/flink-benchmarks/pull/39
[
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
[
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}}
[
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}}
[
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}}
[
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}}
[
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}}
[
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
>
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}}
[
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}}
[
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}}
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=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:58 AM:
---
The failure of the
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:58 AM:
---
The failure of the
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923044#comment-16923044
]
Haibo Sun edited comment on FLINK-13516 at 9/5/19 4:43 AM:
---
The failure of the
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16923044#comment-16923044
]
Haibo Sun commented on FLINK-13516:
---
The failure of the case is due to the failure of authentication
[
https://issues.apache.org/jira/browse/FLINK-13515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920617#comment-16920617
]
Haibo Sun commented on FLINK-13515:
---
Sorry for the delay. This week I will work on this JIRA.
>
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16920618#comment-16920618
]
Haibo Sun commented on FLINK-13516:
---
Sorry for the delay. This week I will work on this JIRA.
>
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16913989#comment-16913989
]
Haibo Sun commented on FLINK-12818:
---
{quote}Alternatively until this is confirmed as a production code
[
https://issues.apache.org/jira/browse/FLINK-13516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910939#comment-16910939
]
Haibo Sun commented on FLINK-13516:
---
Hi, [~Zentol]. I can help with this task. Can you assign it to
[
https://issues.apache.org/jira/browse/FLINK-13515?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16910938#comment-16910938
]
Haibo Sun commented on FLINK-13515:
---
Hi, [~Zentol]. I can help with this task. Can you assign it to
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895958#comment-16895958
]
Haibo Sun edited comment on FLINK-13491 at 7/30/19 9:52 AM:
So for one-input
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895973#comment-16895973
]
Haibo Sun commented on FLINK-13491:
---
For two-input operator, {{endInput(int inputId)}} is semantically
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895958#comment-16895958
]
Haibo Sun edited comment on FLINK-13491 at 7/30/19 9:37 AM:
So for one-input
[
https://issues.apache.org/jira/browse/FLINK-13491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895958#comment-16895958
]
Haibo Sun commented on FLINK-13491:
---
So for one-input operator, `endInput ()` repeats `close ()`
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894906#comment-16894906
]
Haibo Sun edited comment on FLINK-12818 at 7/29/19 7:19 AM:
Hi [~pnowojski],
[
https://issues.apache.org/jira/browse/FLINK-12818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16894906#comment-16894906
]
Haibo Sun commented on FLINK-12818:
---
Hi [~pnowojski],
The benchmark on
[
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=16887573#comment-16887573
]
Haibo Sun commented on FLINK-13242:
---
Another instance:
[
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
[
https://issues.apache.org/jira/browse/FLINK-12916?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16885897#comment-16885897
]
Haibo Sun commented on FLINK-12916:
---
Another instance:
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876835#comment-16876835
]
Haibo Sun edited comment on FLINK-12573 at 7/2/19 10:06 AM:
Hi,
[
https://issues.apache.org/jira/browse/FLINK-12573?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16876835#comment-16876835
]
Haibo Sun commented on FLINK-12573:
---
Hi, [~LouisXu777]
Is there any progress on this issue? I think
[
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
[
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
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://issues.apache.org/jira/browse/FLINK-12895?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869298#comment-16869298
]
Haibo Sun commented on FLINK-12895:
---
(y)
>
[
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:
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
[
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
[
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=16855247#comment-16855247
]
Haibo Sun commented on FLINK-12426:
---
[~QiLuo], the pull request of FLINK-12547 has been merged into
[
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=16855222#comment-16855222
]
Haibo Sun commented on FLINK-1722:
--
OK, I will.
> Streaming not respecting FinalizeOnMaster for output
[
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=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~aljoscha]
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~aljoscha]
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852871#comment-16852871
]
Haibo Sun edited comment on FLINK-1722 at 5/31/19 9:57 AM:
---
[~aljoscha]
[
https://issues.apache.org/jira/browse/FLINK-1722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16852871#comment-16852871
]
Haibo Sun commented on FLINK-1722:
--
[~aljoscha] [~rmetzger] , I wrote a simple design document, and
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848633#comment-16848633
]
Haibo Sun edited comment on FLINK-12547 at 5/27/19 6:08 AM:
[~QiLuo],
[
https://issues.apache.org/jira/browse/FLINK-12547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16848633#comment-16848633
]
Haibo Sun commented on FLINK-12547:
---
[~QiLuo], because the blob client has a retry mechanism, I
[
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
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
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:25 AM:
-
> But as far
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:23 AM:
-
> But as far
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842078#comment-16842078
]
Haibo Sun edited comment on FLINK-12529 at 5/17/19 10:22 AM:
-
> But as far
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16842078#comment-16842078
]
Haibo Sun commented on FLINK-12529:
---
>But as far as I understand you would only need to modify the
[
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
[
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
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841470#comment-16841470
]
Haibo Sun commented on FLINK-12529:
---
[~pnowojski], do you think there is any problem with this
[
https://issues.apache.org/jira/browse/FLINK-12529?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16841470#comment-16841470
]
Haibo Sun edited comment on FLINK-12529 at 5/16/19 3:35 PM:
[~pnowojski],
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/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.
-
[
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
[
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.
-
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:
[
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
[
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
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.
-
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
