问答 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

大数据技术交流 Taier 袋鼠开源开源框架 taier答疑大数据调度开源项目 ChunJun 数据集成

5条回答

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

语法检查确实通过了

0 0

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

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

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

0 0

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

不是这么写的，1.12 用row

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

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

0 0