[ https://issues.apache.org/jira/browse/FLINK-5018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-5018. ----------------------------------- Resolution: Won't Do Thanks for the reminder. > Make source idle timeout user configurable > ------------------------------------------ > > Key: FLINK-5018 > URL: https://issues.apache.org/jira/browse/FLINK-5018 > Project: Flink > Issue Type: Sub-task > Components: API / DataStream > Reporter: Tzu-Li (Gordon) Tai > Priority: Major > Labels: pull-request-available > Time Spent: 20m > Remaining Estimate: 0h > > There are 2 cases where sources are considered idle and should emit an idle > {{StreamStatus}} downstream, taking Kafka consumer as example: > - The source instance was not assigned any partitions > - The source instance was assigned partitions, but they currently don't have > any data. > For the second case, we can only consider it idle after a timeout threshold. > It would be good to make this timeout user configurable besides a default > value. -- This message was sent by Atlassian Jira (v8.3.4#803005)