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

Viewed 94

doris 版本:2.1.3
connector 版本:1.6.1

doris 中测试建表:
image.png

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

2 Answers

更新

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


能否提供一下表的schema

建表语句:

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"
);

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