[Bug] paimon query error

[bulolo]

Search before asking

• [x] I had searched in the issues and found no similar issues.

What happened

What you expected to happen

query with paimon ,a error happlen

org.apache.paimon.data.columnar.heap.HeapShortVector cannot be cast to org.apache.paimon.data.columnar.IntColumnVector

How to reproduce

Anything else

No response

Version

1.2.2

Are you willing to submit PR?

• [ ] Yes I am willing to submit a PR!

Code of Conduct

• [x] I agree to follow this project's Code of Conduct

[aiwenmo]

Please provide the complete Paimon table creation statement.

[bulolo]

> Please provide the complete Paimon table creation statement.

SHOW CREATE TABLE paimon_lab.user.ods_user_org;

CREATE TABLE `paimon_lab`.`user`.`ods_user_org` (
  `id` INT NOT NULL,
  `user_id` INT NOT NULL,
  `org_id` INT NOT NULL,
  `org_code` VARCHAR(20) NOT NULL,
  `roles` VARCHAR(2147483647),
  `is_ord_inspector` SMALLINT,
  `is_whse_inspector` SMALLINT,
  `sales_type` VARCHAR(20),
  `available` SMALLINT NOT NULL,
  `authed_whse_locations` VARCHAR(2147483647),
  `cost_center` VARCHAR(45) COMMENT '成本中心',
  `last_login_at` TIMESTAMP(6),
  `next_to_last` TIMESTAMP(6),
  `creator` INT,
  `created_at` TIMESTAMP(6) NOT NULL,
  `updater` INT,
  `updated_at` TIMESTAMP(6) NOT NULL,
  `is_specify_location` SMALLINT NOT NULL,
  `location_rule_code` VARCHAR(191) NOT NULL,
  `specify_location_ext` VARCHAR(2147483647),
  CONSTRAINT `PK_id` PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
  'bucket' = '1',
  'path' = 's3://lakedata/paimon/user.db/ods_user_org',
  'changelog-producer' = 'input',
  'sink.parallelism' = '1'
)

or

show create table paimon_lab.user.ods_role;

CREATE TABLE `paimon_lab`.`user`.`ods_role` (
  `id` INT NOT NULL,
  `app` VARCHAR(50) NOT NULL,
  `name` VARCHAR(50) NOT NULL,
  `remark` VARCHAR(191) NOT NULL,
  `status` SMALLINT NOT NULL,
  `creator` INT,
  `created_at` TIMESTAMP(6) NOT NULL,
  `updater` INT,
  `updated_at` TIMESTAMP(6) NOT NULL,
  CONSTRAINT `PK_id` PRIMARY KEY (`id`) NOT ENFORCED
) WITH (
  'bucket' = '1',
  'path' = 's3://lakedata/paimon/user.db/ods_role',
  'changelog-producer' = 'input',
  'sink.parallelism' = '1'
)

take a look on this paimon example file: https://files.junyao.tech/uPic/ods_role.zip

[bulolo]

i test ,maybe is because SMALLINT and tintyint

[bulolo]

the table above is solved,but some table still exist the error

CREATE TABLE `paimon`.`user`.`ods_user_beisen_dept` ( `id` INT NOT NULL, `user_id` INT NOT NULL, `dept_id` INT NOT NULL, `type` TINYINT NOT NULL, CONSTRAINT `PK_id` PRIMARY KEY (`id`) NOT ENFORCED ) WITH ( 'bucket' = '1', 'path' = 's3://lakedata/paimon/user.db/ods_user_beisen_dept', 'changelog-producer' = 'input', 'sink.parallelism' = '1' )

@aiwenmo

[aiwenmo]

#4337

[bulolo]

please reopen it ，

now ARRAY<INT> will error

CREATE TABLE IF NOT EXISTS dim_bpm_user (
  `id` INT COMMENT '用户ID',
  `user_name` STRING COMMENT '用户名',
  `wecom_user_id` STRING COMMENT '企业微信用户ID',
  `sap_code` STRING COMMENT 'SAP编码',
  `extra_wecom_notices` ARRAY <STRING> COMMENT '额外企业微信通知',
  `password` STRING COMMENT '密码',
  `name` STRING COMMENT '姓名',
  `cellphone` STRING COMMENT '手机号码',
  `email` STRING COMMENT '电子邮件',
  `boss_id` INT COMMENT '直属上司ID',
  `boss_name` STRING COMMENT '直属上司姓名',
  `status` BOOLEAN COMMENT '用户状态',
  `status_label` STRING COMMENT '用户状态标签',
  `avatar` STRING COMMENT '头像URL',
  `is_super` BOOLEAN COMMENT '是否超级用户（0：否、1：是）',
  `belong_org` STRING COMMENT '所属组织',
  `belong_org_label` STRING COMMENT '所属组织标签',
  `affiliated_org` STRING COMMENT '附属组织(报表使用,只保留 北京、上海、深圳, 香港会替换成深圳)',
  `affiliated_org_label` STRING COMMENT '附属组织标签',
  `default_org` STRING COMMENT '默认组织',
  `default_org_label` STRING COMMENT '默认组织标签',
  `office_id` INT COMMENT '办公地点ID',
  `office_name` STRING COMMENT '办公地点名称',
  `scope` ARRAY <STRING> COMMENT '权限范围',
  `specified_users` ARRAY <INT> COMMENT '指定用户',
  `authed_users` ARRAY<INT> COMMENT '授权用户',
  `areastore_ids` ARRAY <INT> COMMENT '地区仓ID',
  `purchase_group` ARRAY <STRING> COMMENT '采购组',
  `main_department` INT COMMENT '主部门',
  `sales_team` INT COMMENT '销售团队',
  `entry_time` TIMESTAMP(3) COMMENT '入职时间',
  `creator` INT COMMENT '创建者ID',
  `created_at` TIMESTAMP(3) COMMENT '创建时间',
  `updater` INT COMMENT '更新者ID',
  `updated_at` TIMESTAMP(3) COMMENT '更新时间',
  `sap_sync_at` TIMESTAMP(3) COMMENT 'SAP同步时间',
  `sap_sync_status` STRING COMMENT 'SAP同步状态',
  `sap_sync_msg` STRING COMMENT 'SAP同步消息',
  `has_departed` BOOLEAN COMMENT '已离职状态（0：否、1：是）',
  `openid` STRING COMMENT '企业微信openid',
  `sales_teams` ARRAY <STRING> COMMENT '销售团队列表',
  `approve_wecom_id` STRING COMMENT '审批企业微信ID',
  `beisen_id` STRING COMMENT '北森ID',
  `beisen_belong_org` STRING COMMENT '北森归属组织',
  `beisen_place` STRING COMMENT '北森工作城市',
  `from_source` INT COMMENT '来源（1:企微创建、2:BPM手工创建）',
  `sales_team_id` INT COMMENT '销售团队ID',
  `sales_team_name` STRING COMMENT '销售团队名称',
  PRIMARY KEY (id) NOT ENFORCED
);

[github-actions[bot]]

Hello @, this issue has not been active for more than 30 days. This issue will be closed in 7 days if there is no response. If you have any questions, you can comment and reply.

你好 @, 这个 issue 30 天内没有活跃，7 天后将关闭，如需回复，可以评论回复。