Hi,
java.util.Date没有sql中的常规类型和它对应,因此使用的兜底的Raw类型(结构化类型)。实际上java.sql.Date
对应的是sql中的Date。
具体可以参考下这张表:https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/types/#data-type-extraction
--
Best!
Xuyang
在 2024-03-05 09:23:38,"ha.fen...@aisino.com" 写道:
>从流转换成Table
>DataSt
Flink有一个端到端延迟的指标,可以参考以下文档[1],看看是否有帮助。
[1]
https://nightlies.apache.org/flink/flink-docs-release-1.18/zh/docs/ops/metrics/#end-to-end-latency-tracking
Best,
Shawn Huang
casel.chen 于2024年2月21日周三 15:31写道:
> flink sql作业从kafka消费mysql过来的canal
> json消息,经过复杂处理后写入doris,请问如何统计doris表记录的端到端时延?mysql表有upda
Hi,退订可以发送任意内容的邮件到 user-zh-unsubscr...@flink.apache.org 来取消订阅来自
user-zh@flink.apache.org 邮件列表的邮件,邮件列表的订阅管理,可以参考[1]
[1] https://flink.apache.org/zh/what-is-flink/community/
Best,
Shawn Huang
雷刚 于2024年2月29日周四 14:41写道:
> 退订