Re:Re: KeyBy fields do not support java.lang.Array?

Hi Aljoscha: Thanks for your reply. Look forward to the final solution. Best Regards Xu Pingyong 在 2017-07-31 22:39:38，"Aljoscha Krettek" 写道： >Hi, > >Which version of Flink are you using? This issue should have been resolved at >least by 1.3.0:

Re: KeyBy fields do not support java.lang.Array?

Hi, Which version of Flink are you using? This issue should have been resolved at least by 1.3.0: https://issues.apache.org/jira/browse/FLINK-5874 . Currently such keys should be rejected. There is also this issue, that aims to re-introduce

KeyBy fields do not support java.lang.Array?

Hi Aljoscha： The java.lang.Array hashCode depends on the reference instead of the content. If the keyBy field contains an array, Two records are hash-partitioned to different stream although their keys are equal. int a1[] = new int[]{1, 2}; // hashcode is :