Hongshun Wang created FLINK-38335: ------------------------------------- Summary: SplitEnumeratorContext supports fixed delay async call. Key: FLINK-38335 URL: https://issues.apache.org/jira/browse/FLINK-38335 Project: Flink Issue Type: Improvement Components: Connectors / Common Affects Versions: 2.1 Reporter: Hongshun Wang Fix For: 2.2
Currently, SplitEnumeratorContext#callAsync only supports fixed rate but not supports fixed delay. That means if the io call cost two much time, io thread will will backlog a lot. -- This message was sent by Atlassian Jira (v8.20.10#820010)