Flink这个是什么原因呀？ -[阿里云_云淘科技]

匿名 • 2023年12月13日下午6:14 • 阿里云

Flink这个是什么原因呀？

以下为热心网友提供的参考意见

从你写的这个结构看，没有使用 catalog
那点调试的前提是你这个脚本要完整
完整的 source 的 DDL 完整的 sink DDL 完整的 DML
如下所示：
CREATE TEMPORARY TABLE datagenSource (
input varchar
)with (
‘connector’ = ‘datagen’
);

CREATE TEMPORARY TABLE printSink (
b1 bigint
)with (
‘connector’ = ‘print’,
‘limit’ = ‘100’
);

INSERT INTO printSink
SELECT
cast(substring(cast(CURRENT_TIMESTAMP as varchar),-3,3)as bigint)+unix_timestamp(CURRENT_TIMESTAMP)*1000
FROM
datagenSource;
source sink 的 temporary 关键词、DML 的INSERT INTO 。此回答整理自钉群“实时计算Flink产品交流群”

本文来自投稿，不代表新手站长_郑州云淘科技有限公司立场，如若转载，请注明出处：https://www.cnzhanzhang.com/12374.html