[
https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572148#comment-17572148
]
Thomas Weise commented on FLINK-28722:
--------------------------------------
[~mason6345] please take a look at the PR in linked JIRA.
> 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
> 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)
