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
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
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
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
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
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
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
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
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
Haibo Sun created FLINK-12895:
-
Summary:
TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure
failed on travis
Key: FLINK-12895
URL: https://issues.apache.org/jira/browse/FLINK-12895
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
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-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
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:
Haibo Sun created FLINK-11875:
-
Summary: Enhance stream operator API to support selective reading
and EndOfInput event
Key: FLINK-11875
URL: https://issues.apache.org/jira/browse/FLINK-11875
Project: Flin
Haibo Sun created FLINK-11876:
-
Summary: Introduce the new interfaces TwoInputSelectable,
BoundedOneInput and BoundedTwoInput
Key: FLINK-11876
URL: https://issues.apache.org/jira/browse/FLINK-11876
Projec
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
Haibo Sun created FLINK-11877:
-
Summary: Implement the runtime handling of TwoInputSelectable
Key: FLINK-11877
URL: https://issues.apache.org/jira/browse/FLINK-11877
Project: Flink
Issue Type: Su
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
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
21 matches
Mail list logo