flink sql 操作doris 如何设置位动态sink.label-prefix

要在 Flink SQL 中操作 Doris 并设置动态的 sink.label-prefix，可以按照以下步骤进行：

1. 在 Flink SQL 中定义一个变量，用于存储动态的 sink.label-prefix，例如：

   SET @prefix = 'my_prefix';

2. 在创建 Doris 表时，可以使用 CONCAT 函数将动态的前缀与表名拼接起来作为表的标签，例如：

   CREATE TABLE my_table (
     -- 定义表结构
   ) WITH (
     'connector' = 'doris',
     'database-name' = 'my_database',
     'table-name' = CONCAT(@prefix, '_my_table'),
     -- 其他 Doris 连接器配置
   );

3. 使用动态的 sink.label-prefix 将 Doris 表与 Flink SQL 中的查询结果进行关联，例如：

   INSERT INTO my_table
   SELECT *
   FROM my_source_table
   WHERE event_time >= TIMESTAMP '2022-01-01'
   WITH (
     'sink.label-prefix' = @prefix,
     -- 其他 Doris 连接器配置
   );

这样，就可以动态地设置 sink.label-prefix，并将查询结果写入到带有动态前缀的 Doris 表中。注意，在使用动态前缀的过程中，需要确保所有涉及到表名的地方都使用了 CONCAT 函数拼接前缀，以保证表名的一致性。