Partition 和 Offset 开始消费，还支持了指定时间点进行消费的功能。这里说明下对应参数的配置关系。 有三个相关参数： ：指定待消费的 partition 列表，如："0, 1, 2, 3"。 ：指定每个分区的起始offset，必须和 列表个数对应。如："1000, 1000, 2000, 2000" ：指定分区默认的起始offset。 在创建导入作业时，这三个参数可以有以下组合： CREATE CREATE-TABLE CREATE TABLE CREATE TABLE Description Description 该命令用于创建一张表。本文档主语介绍创建 Doris 自维护的表的语法。 列定义列表： 列定义： 列类型，支持以下类型： CREATE CREATE TABLE TABLE [[IFIF NOT NOT EXISTS EXISTS]] [[database database is column v4" ``` ``` index_definition_list index_definition_list Baidu 百度智能云文档 SQL手册 52 索引列表定义： 索引定义： 示例： 表引擎类型。本文档中类型皆为 OLAP。示例： 数据模型。 支持以下模型： DUPLICATE KEY（默认）：其后指定的列为排序列。 AGGREGATE

ction_num_singleton_deltas  优化 BE 提交逻辑：定期缓存 BE 列表，按批次随机提交到 BE 节点，细化负载均 衡粒度。 优化背景：在写入时发现某一个 BE 负载会远远高于其他的 BE，甚至出现 OOM。结合源 码发现：作业启动后会获取一次 BE 地址列表，从中随机选出一个 BE 作为 Coordinator 协 调者，该节点主要负责接收数据、并分发到其他的 节点，除非作业异常报错，否则该节 点不会发生切换。 对于少量 Flink 作业大数据场景会导致选中的 BE 节点负载较高，因此我们尝试对 BE 提 交逻辑进行优化，设置每 1 小时缓存一次 BE 列表，每写入一个批次都随机从 BE 缓存列 表中获取一个进行提交，这样负载均衡的粒度就从 job 级别细化到每次提交的批次，使得 BE 间负载更加的均衡，这部分实现我们已经贡献到社区，欢迎大家一起使用并反馈。