You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Mason Chen (Jira)" <ji...@apache.org> on 2022/07/27 22:04:00 UTC

[jira] [Commented] (FLINK-28722) Hybrid Source should use .equals() for Integer comparison

    [ https://issues.apache.org/jira/browse/FLINK-28722?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17572145#comment-17572145 ] 

Mason Chen commented on FLINK-28722:
------------------------------------

[~thw@apache.org] [~martijnvisser] mind if I take a look?

> 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)