eventInfo_eventTime 我猜测是 BIGINT 类型的吧？
order by | range 需要用到 timestamp 类型，需要用计算列转换一下
At 2021-12-24 16:38:00, "Pinjie Huang"
wrote:
>我的原SQL：
>CREATE TABLE consumer_session_created
>(
>consumer ROW (consumerUuid STRING),
>clientIp STRING,
>deviceId STRING,
>eventInfo ROW <
看文章介绍说Flink CDC 2.0 支持整库同步，见 https://www.jianshu.com/p/b81859d67fec
整库同步：用户要同步整个数据库只需一行 SQL 语法即可完成，而不用每张表定义一个 DDL 和 query。
想知道Flink CDC 2.0 整库同步如何实现？有没有例子？谢谢！
client-local的文件，不是镜像里面的。这句话该怎么理解？因为run-application
模式下是需要将用户jar包跟flink标准镜像打到一起形成自己镜像然后进行提交。那么这个文件该放在哪个地方？目前我指定路径发现读的是镜像包中的路径。如/opt/my-pod-template。读的是镜像中/opt/my-pod-template文件。
谢谢您的回复。
Yang Wang 于2021年12月24日周五 11:18写道：
>
> 使用flink
>
clean install ??
?? 2021-12-17 17:41:32??"??" <2572805...@qq.com.INVALID> ??
>??
>
>flinkKafka??
>
>??
>
>[ERROR]
>org.apache.flink.connector.kafka.source.reader.KafkaPartitionSplitReaderTest
> Time elapsed: 1.398 s <<<
我的原SQL：
CREATE TABLE consumer_session_created
(
consumer ROW (consumerUuid STRING),
clientIp STRING,
deviceId STRING,
eventInfo ROW < eventTime BIGINT >,
ts AS TO_TIMESTAMP(FROM_UNIXTIME(eventInfo.eventTime / 1000, '-MM-dd
HH:mm:ss')),
WATERMARK FOR ts AS ts - INTERVAL '5' SECOND
) WITH (
