[jira] [Created] (FLINK-10116) createComparator fails on case class with Unit type fields prior to the join-keyl

["Will (JIRA)" <ji...@apache.org>]

Will created FLINK-10116:
----------------------------

             Summary: createComparator fails on case class with Unit type fields prior to the join-keyl
                 Key: FLINK-10116
                 URL: https://issues.apache.org/jira/browse/FLINK-10116
             Project: Flink
          Issue Type: Bug
    Affects Versions: 1.6.0, 1.3.3
            Reporter: Will
         Attachments: JobFail.scala, JobPass.scala

h1. Overview

When joining between case classes, if the attribute representing the join-key comes after Unit definition of fields (that are not being used) the join will fail with the error
{quote}{{Exception in thread "main" java.lang.IllegalArgumentException: Could not add a comparator for the logicalkey field index 0.}}
{{ at org.apache.flink.api.common.typeutils.CompositeType.createComparator(CompositeType.java:162)}}
{{ at org.apache.flink.optimizer.postpass.JavaApiPostPass.createComparator(JavaApiPostPass.java:293)}}
{{ at org.apache.flink.optimizer.postpass.JavaApiPostPass.traverse(JavaApiPostPass.java:193)}}
{quote}
Using TypeInformation keys does not exhibit the same issue. Initial debugging suggests that when calculating the index of the key for strings doesn't count Unit elements, however they are included during iteration in CompositeType.createComparator which leads to the search failing on the key appearing to be a Unit type.
h1. Code Examples to Reproduce

[^JobFail.scala]

[^JobPass.scala]

 

 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)