[ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Chesnay Schepler updated FLINK-28722: ------------------------------------- Issue Type: Bug (was: Improvement) > Hybrid Source should use .equals() for Integer comparison > --------------------------------------------------------- > > Key: FLINK-28722 > URL: https://issues.apache.org/jira/browse/FLINK-28722 > Project: Flink > Issue Type: Bug > Components: Connectors / Common > Affects Versions: 1.15.1 > Reporter: Mason Chen > Priority: Major > Fix For: 1.16.0, 1.15.2 > > > HybridSource should use .equals() for Integer comparison in filtering out the > underlying sources. This causes the HybridSource to stop working when it hits > the 128th source (would not work for anything past 127 sources). > https://github.com/apache/flink/blob/release-1.14.3-rc1/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSourceSplitEnumerator.java#L358 > > A user reported this issue here: > https://lists.apache.org/thread/7h2rblsdt7rjf85q9mhfht77bghtbswh -- This message was sent by Atlassian Jira (v8.20.10#820010)