问答 2022-09-02 来自:开发者社区

flink-mysql-cdc streaming模式时区问题要怎么处理啊?

flink-mysql-cdc streaming模式时区问题要怎么处理啊,现在不加time-zone设置,全量部分数据正常,但是进入增量部分就差了8个小时,如果time-zone设置上Asia/shanghai,全量和增量时间就都不对了

问答 2022-08-24 来自:开发者社区

flink-sql-connector-oracle -cdc-2.2.1 时区没找到,这个问题

flink-sql-connector-oracle -cdc-2.2.1 时区没找到,这个问题怎么解决呢

问答 2022-07-13 来自:开发者社区

大佬,请教下,flink写数据后用spark读数据,这个时区问题有好的解决方案不

大佬,请教下,flink写数据后用spark读数据,这个时区问题有好的解决方案不

问答 2022-07-10 来自:开发者社区

flink SQL 时区问题怎么处理,百度有说在SQL语句上修改,还有说在job上配置,正常情况下应

flink SQL 时区问题怎么处理,百度有说在SQL语句上修改,还有说在job上配置,正常情况下应该是怎么解决

文章 2021-12-27 来自:开发者社区

Flink线上问题汇总篇(2)-时区不一致系统时间少8小时导致数据丢失问题

初学flink的人绕不开的东西就是窗口,为什么这么说呢?首先要从流和批的概念介绍起,flink我认为其能火起来的一个必不可少的原因就是流批一体,而窗口正是界分流批的重要概念。初学的时候我们可能会学习滑动窗口和滚动窗口。但实际上我们可能通过顶层的table api或者sql api直接实现窗口的部分功能。切入正题因为我们的需求是要针对每个月的数据进行分组聚合并展示,所以如果按照需求分析来说我们需要....

问答 2021-12-03 来自:开发者社区

flink 1.11.2 如何配置时区

你好!       我使用的是flink sql 1.11.2版本,通过proctime()在源上添加处理时间,发现生成的时间为UTC时间,而我需要的是+08的时间;而我通过设计env.java.opts参数设计jvm的时区参数也没有解决,请问我如何配置才可以拿到+08的时间? 我的程序的数据是json格式输出*来自志愿者整理的flink邮件归档

问答 2021-11-18 来自:开发者社区

Flink SQL TIMESTAMP 类型没有考虑时区的问题怎么解决?

Flink SQL TIMESTAMP 类型没有考虑时区的问题怎么解决?

问答 2021-11-18 来自:开发者社区

Flink SQL 造成时区问题的原因有哪些?

Flink SQL 造成时区问题的原因有哪些?

问答 2021-11-18 来自:开发者社区

Flink 1.13 中对于时区支持有什么改良?

Flink 1.13 中对于时区支持有什么改良?

问答 2021-01-31 来自:开发者社区

请教下,有遇到时区问题的吗,我如下这样处理时间戳,相差8小时,之前没有在flink-co#Flink

请教下,有遇到时区问题的吗,我如下这样处理时间戳,相差8小时,之前没有在flink-conf.yanl 设置时区参数,转换后比实际小8个小时,在配置文件配置了两个时区参数之后,反而大8小时 了 TO_TIMESTAMP(FROM_UNIXTIME(COALESCE(cast(time as bigint) / 1000 ,UNIX_TIMESTAMP()),'yyyy-MM-dd HH:mm:s....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注