You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by superainbower <su...@163.com> on 2021/03/16 07:11:52 UTC

Temproal Tables

请教下大家，官网中对于时态表的定义的案例是基于debezium的，我现在具基于canal这样定义有问题吗？定义如下
create table produce(
id string,
name string,
price decimal(10,4)
update_time timestamp(3) metadata from ‘timestamp’ virtual,
primary key(id) not enforced,
watermark for update_time as update_time
)with(
‘connector’=‘Kafka’,
‘topic’=‘product’,
‘scan.startup.mode’=‘earliest-offset’,
‘properties.bootstrap.server’=‘localhost:9092’
‘value.format’=‘canal-Jason’
);


主要是 metadata那块 填写timestamp 对吗？

Re: Temproal Tables

Posted by superainbower <su...@163.com>.

这个问题我解决了，这样定义应该是可以
On 03/16/2021 15:11, superainbower wrote:
请教下大家，官网中对于时态表的定义的案例是基于debezium的，我现在具基于canal这样定义有问题吗？定义如下
create table produce(
id string,
name string,
price decimal(10,4)
update_time timestamp(3) metadata from ‘timestamp’ virtual,
primary key(id) not enforced,
watermark for update_time as update_time
)with(
‘connector’=‘Kafka’,
‘topic’=‘product’,
‘scan.startup.mode’=‘earliest-offset’,
‘properties.bootstrap.server’=‘localhost:9092’
‘value.format’=‘canal-Jason’
);


主要是 metadata那块 填写timestamp 对吗？