You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Jim Hughes (Jira)" <ji...@apache.org> on 2026/05/13 17:44:00 UTC

[jira] [Created] (FLINK-39677) ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements

Jim Hughes created FLINK-39677:
----------------------------------

             Summary: ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements
                 Key: FLINK-39677
                 URL: https://issues.apache.org/jira/browse/FLINK-39677
             Project: Flink
          Issue Type: Bug
    Affects Versions: 2.2.1, 2.0.2, 2.1.2, 1.20.4, 2.3.0
            Reporter: Jim Hughes


*Title:* ARRAY_SORT fails at runtime with "Comparison method violates its general contract!" on arrays with duplicate elements

*Affects Versions:* 2.0 and earlier (wherever {{ArraySortFunction}} exists)

h3. Description

{{ArraySortFunction.ArraySortComparator.compare}} is built from a single SQL {{>}} evaluator and returns {{+1}} or {{-1}} based on the boolean result — it never returns {{0}}. For two equal elements {{a}} and {{b}}, both {{a > b}} and {{b > a}} are {{FALSE}}, so {{compare(a, b) == compare(b, a) == -1}}. This violates {{java.util.Comparator}}'s antisymmetry requirement.

TimSort detects the contradiction once the array is large enough to take the merge path (≥32 elements with duplicates), throwing:

{noformat}
java.lang.IllegalArgumentException: Comparison method violates its general contract!
    at java.util.TimSort.mergeHi(TimSort.java:903)
    at java.util.Arrays.sort(Arrays.java:1234)
    at org.apache.flink.table.runtime.functions.scalar.ArraySortFunction.eval(ArraySortFunction.java:91)
{noformat}




--
This message was sent by Atlassian Jira
(v8.20.10#820010)