开发者社区大数据与机器学习实时计算 Flink 正文

flink1.14 用fromDataStream 从流转表指定schema时，这样出来的pro

flink1.14 用fromDataStream 从流转表指定schema时，这样出来的proctime时区不对，怎么办？图片.png

展开

收起

wenti 2023-02-07 14:21:46 296 版权

2 条回答

写回答

取消提交回答

认真学习的heart

可以通过设置flink1.14的TimeZone参数来指定proctime的时区。

2023-02-08 18:23:20

赞同展开评论
665661

度广播状态为空时,open方法查询一次库这样就ok了,以后广播流数据有了依然读广播流——该回答整理自钉群“【③群】Apache Flink China社区”

2023-02-07 17:19:28

赞同展开评论

问答分类：

实时计算 Flink版

问答标签：

实时计算 Flink版schema 实时计算 Flink版流转表

问答地址：

开发者社区 > 大数据与机器学习 > 实时计算 Flink > 问答

相关问答

实时计算 Flink版

实时计算Flink报错schema evolution table operations t...

Flink CDC 3.0版本是否支持通过代码实现整库同步和schema变更功能？

188

Flink用jdbc catalog连接postgresql时pg的schema里有横线该怎么处理？

334

Flink CDC怎么获取source的schema?

251

flink cdc用cdc-mysql 抽的数据有没有办法把dbz-json的schema去掉？

在Flink CDC中用3.1.1版本监听schema，出现中文乱码，这个有什么解决方案吗？

129

对于Flink CDC，schema中fields的name是指字段名字吗？

在Flink CDC中mysql到doris 支持schema change吗？

203

在Flink CDC中flink程序就会挂了，已经开了schema change，如何操作？

现在的flink cdc3.0版本会检测源表的schema change吗？

大数据与机器学习

实时计算 Flink

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。

我要提问

收录在圈子:

阿里云实时计算Flink

199212

+ 订阅

实时计算 Flink 版（Alibaba Cloud Realtime Compute for Apache Flink，Powered by Ververica）是阿里云基于 Apache Flink 构建的企业级、高性能实时大数据处理系统，由 Apache Flink 创始团队官方出品，拥有全球统一商业化品牌，完全兼容开源 Flink API，提供丰富的企业级增值功能。