[ https://issues.apache.org/jira/browse/FLINK-19245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232411#comment-17232411 ]
Stephan Ewen commented on FLINK-19245: -------------------------------------- Fixed in 1.11.3 (release-1.11) via 406aa9f3f647568410ca0d9d27c475ce84a58ece > Set default queue capacity for FLIP-27 source handover queue to 2 > ----------------------------------------------------------------- > > Key: FLINK-19245 > URL: https://issues.apache.org/jira/browse/FLINK-19245 > Project: Flink > Issue Type: Improvement > Components: Connectors / Common > Reporter: Stephan Ewen > Assignee: Stephan Ewen > Priority: Major > Fix For: 1.12.0, 1.11.3 > > > Based on initial investigation by [~jqin] a capacity value of two results in > good queue throughput while still keeping the number of elements small. -- This message was sent by Atlassian Jira (v8.3.4#803005)