flinkcdc支持将posgtresql的分区表同步到doris中吗?求大佬们指教 #2733
Unanswered
IT-Forerunner
asked this question in
Q&A
Replies: 1 comment
-
我也是读不到 ,你解决了吗 |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
问题描述:flinkcdc将pg数据的表同步到doris中,正常的表都能同步,就是分区表同步一直读取不到数据。
以下是简单个pg分区表建表语句:
CREATE TABLE "xb_test_tb" (
"pk_uid" int8 NOT NULL ,
"id" varchar(50) COLLATE "pg_catalog"."default",
"sheng" varchar(2) COLLATE "pg_catalog"."default" NOT NULL,
)
PARTITION BY LIST (
"sheng" COLLATE "pg_catalog"."default" "pg_catalog"."text_ops"
)
;
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_11_beijing" FOR VALUES IN ('11');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_65_xinjiang" FOR VALUES IN ('65');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_91_dxalsg" FOR VALUES IN ('91');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_92_longjiangsengong" FOR VALUES IN ('92');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_93_neimenggusengong" FOR VALUES IN ('93');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_94_jilinsengong" FOR VALUES IN ('94');
ALTER TABLE "xb_test_tb" ATTACH PARTITION "xb_test_tb_95_xjbt" FOR VALUES IN ('95');
请教大佬们两个问题。
Beta Was this translation helpful? Give feedback.
All reactions