想问下 flink sql 有办法让 changelog 按主键 shuffle 到对应的 sink

是的，Flink SQL支持将数据按照主键进行分组和shuffle。在这种情况下，您可以使用Flink SQL的GROUP BY语句来将数据按照主键进行分组，并使用Flink SQL的ORDER BY语句来将数据按照主键进行排序。然后，您可以使用Flink SQL的SELECT语句来选择需要的字段，并将数据发送到对应的Sink中。
例如，如果您有一个表“t”，其中包含主键id和其他字段，您可以使用如下代码将数据按照主键id进行分组和shuffle：

SELECT id, field1, field2
FROM t
GROUP BY id
ORDER BY id;

然后，您可以使用Flink SQL的SELECT语句来选择需要的字段，并将数据发送到对应的Sink中：

SELECT id, field1, field2
FROM (
  SELECT id, field1, field2
  FROM t
  GROUP BY id
  ORDER BY id
) t
INTO TABLE sink;

希望这些信息能够帮助您解决问题。