public int hashPartitionValue(RowData rowData) {
    partitionKey.partition(rowDataWrapper.wrap(rowData));
    int hashcode = Math.abs(partitionKey.hashCode());
    return hashcode == Integer.MIN_VALUE ? Integer.MAX_VALUE : hashcode;
  }
Should open firstly to initial RowDataWrapper, because it cannot be serialized.
amoro-format-mixed/amoro-mixed-flink/amoro-mixed-flink-common/src/main/java/org/apache/amoro/flink/shuffle/ShuffleHelper.java