【已解决】flink batch 模式下 join 后查询错列

Viewed 94
2.1 query

doris 版本：2.1.3
connector 版本：1.6.1

doris 中测试建表：
image.png

flink batch 模式下读取 doris 表作为 source，join 后查询 city 列值变成了 age 列：
image.png

xialei7
2 Answers

更新

已暂时解决，给用户打了 1.5.2 的patchy，如有类似报错，可联系 Doris 小助手微信支持处理：ApacheDoris_Official

能否提供一下表的schema

vinlee273

建表语句：

create table `nw_dw`.`user_test`(
  `user_id` VARCHAR(64),
  `age`     INT,
  `city`    TEXT
)
engine = OLAP 
DUPLICATE key(`user_id`) 
comment 'OLAP' distributed by HASH(`user_id`) 
BUCKETS AUTO 
PROPERTIES (
  "replication_allocation" = "tag.location.default: 1", 
  "min_load_replica_num" = "-1", 
  "is_being_synced" = "false", 
  "storage_medium" = "hdd", 
  "storage_format" = "V2", 
  "inverted_index_storage_format" = "V1", 
  "light_schema_change" = "true",
  "disable_auto_compaction" = "false", 
  "enable_single_replica_compaction" = "false", 
  "group_commit_interval_ms" = "10000", 
  "group_commit_data_bytes" = "134217728"
);

另外试了主键模型也存在相同的问题

xialei7