[jira] [Created] (FLINK-14228) The runtime support for Bounded[One|Multi]Input#endInput does not properly implement their semantics

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

[jira] [Created] (FLINK-14229) Change the endinput call of the downstream operator to after the upstream operator closes

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

[jira] [Created] (FLINK-14230) Change the endinput call of the downstream operator to after the upstream operator closes

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

[jira] [Created] (FLINK-14231) Support the timers of the upstream operator with endInput properly

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

[jira] [Created] (FLINK-14239) Emitting the max watermark in StreamSource#run may cause it to arrive the downstream early

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

[jira] [Created] (FLINK-12291) 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

[jira] [Created] (FLINK-12292) Add benchmarks for the input processors

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

[jira] [Created] (FLINK-12529) Release buffers of the record deserializer timely to improve the efficiency of heap memory usage on taskmanager

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

[jira] [Created] (FLINK-12547) Deadlock when the task thread downloads jars using BlobClient

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

[jira] [Created] (FLINK-12895) TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on travis

Haibo Sun created FLINK-12895: - Summary: TaskManagerProcessFailureBatchRecoveryITCase.testTaskManagerProcessFailure failed on travis Key: FLINK-12895 URL: https://issues.apache.org/jira/browse/FLINK-12895

[jira] [Created] (FLINK-12967) Change the input selection switching in StreamTwoInputSelectableProcessor#checkFinished to invoking the nextSelection method of the stream operator

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

[jira] [Created] (FLINK-13014) ChainBreakTest failed on Travis

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

[jira] [Created] (FLINK-13051) Drop the non-selectable two-input StreamTask and Processor

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

[jira] [Created] (FLINK-13299) flink-python failed on Travis

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:

[jira] [Created] (FLINK-11875) Enhance stream operator API to support selective reading and EndOfInput event

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

[jira] [Created] (FLINK-11876) Introduce the new interfaces TwoInputSelectable, BoundedOneInput and BoundedTwoInput

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

[jira] [Created] (FLINK-11879) Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput

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

[jira] [Created] (FLINK-11880) Add JobGraph validators for the uses of TwoInputSelectable, BoundedOneInput and BoundedTwoInput

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

[jira] [Created] (FLINK-11877) Implement the runtime handling of TwoInputSelectable

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

[jira] [Created] (FLINK-11878) Implement the runtime handling of BoundedOneInput and BoundedTwoInput

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

[jira] [Created] (FLINK-16174) Add a better tryYield() method to MailboxExecutor to return the lowest priority of the remaining mails

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