按我的理解，你描述错了吧，是kafka_ods_table里面的数据，是按照客户端自定义分区发送 过来的，接下来你希望处理完以后，还要保证kafka_dwd_table里面的数据，也需要保证数据按partition有序吧。因为你是把数据insert到kafka_dwd_table吧，你的描述有问题。
如果我理解的没有问题，那你看一下https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/kafka.html#sink-partitioner ，最关键的就是sink.partitioner这个参数的设置。 -- Sent from: http://apache-flink.147419.n8.nabble.com/
