Mason Chen created FLINK-28722:
----------------------------------
Summary: Hybrid Source should use .equals() for Integer comparison
Key: FLINK-28722
URL: https://issues.apache.org/jira/browse/FLINK-28722
Project: Flink
Issue Type: Improvement
Components: Connectors / Common
Affects Versions: 1.15.1
Reporter: Mason Chen
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)
