问答 taier 1.3 master , 创建 FlinkSQL 任务,以kakfa中数据作为数据源, sql语法检查通过不了,这么写是问题在哪里呢,怎么修改

taier 1.3 master , 创建 FlinkSQL 任务,以kakfa中数据作为数据源, sql语法检查通过不了,这么写是问题在哪里呢,怎么修改

   匿名用户    发布于 2023-02-14 14:48 最新回复 2023-02-14 14:59  来自于   srgyk  557  5

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/question/85cd28eced9aee2f9a2abc6ae3637e14..png

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user1/question/bee7142345e86dd96b809f89a1aa36d6..png

5条回答
srgyk
回复于 2023-02-14 14:59

语法检查确实通过了

0 0
srgyk
回复于 2023-02-14 14:59

那这个order_info_kafka表里的字段 , 应该是 message 和 proc_time 吧

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user159766/answer/66053f1ec05c6805ef806a2b2dfc4423..png

0 0
群内解答
回复于 2023-02-14 14:58

CREATE TABLE order_info_kafka
(
message ROW< `schema` varchar,
opTime bigint,
type varchar,
`table` varchar,
after ROW<id varchar,
name varchar,
price decimal(15, 2) >>,
proc_time AS PROCTIME()
) WITH (
'properties.bootstrap.servers' = 'flink01:9092,flink02:9092,flink03:9092',
'connector' = 'kafka-x',
'scan.parallelism' = '1',
'format' = 'json',
'default.codec' = 'json',
'scan.startup.mode' = 'latest-offset',
'topic' = 'tiezhu_in_one'
);

0 0
srgyk
回复于 2023-02-14 14:58

修改成 只有 id INT 这种,语法检查能过,但是不确定能否得到kafka中的数据,然后跑任务报错 the instance's per memory larger than then maximum containerMemory

http://dtstack-static.oss-cn-hangzhou.aliyuncs.com/2021bbs/files_user159766/answer/15725e501e77662cce9c891fe8597f59..png

0 0
群内解答
回复于 2023-02-14 14:57

不是这么写的,1.12 用row


想了解或咨询更多有关袋鼠云大数据产品、行业解决方案、客户案例的朋友,浏览袋鼠云官网:
https://www.dtstack.com/?src=bbs

同时,欢迎对大数据开源项目有兴趣的同学加入「袋鼠云开源框架钉钉技术群」,交流最新开源技术信息,群号码:30537511,项目地址:https://github.com/DTStack/Taier

0 0
社区公告
  • 大数据领域最专业的产品&技术交流社区,专注于探讨与分享大数据领域有趣又火热的信息,专业又专注的数据人园地

最新活动更多
微信扫码获取数字化转型资料
钉钉扫码加入技术交流群