Flink-sql CURRENT_DATE

本文涉及的产品
实时计算 Flink 版,5000CU*H 3个月
简介: 在flink实时处理中,时间函数的作用不言而喻!文中记录个人的一次亲身经历。记录一下,开森一下。

如下看图:第一次接触FLink获取当前日期如下图
1.png
在Sql的Where条件中做条件查询,如下图:
2.png
3.png
其结果造成数据的不更新,结果数据不正确;
原因:FlinkSql函数中,获取当前日期:CURRENT_DATE ,以返回当前系统日期;

相关实践学习
基于Hologres轻松玩转一站式实时仓库
本场景介绍如何利用阿里云MaxCompute、实时计算Flink和交互式分析服务Hologres开发离线、实时数据融合分析的数据大屏应用。
Linux入门到精通
本套课程是从入门开始的Linux学习课程,适合初学者阅读。由浅入深案例丰富,通俗易懂。主要涉及基础的系统操作以及工作中常用的各种服务软件的应用、部署和优化。即使是零基础的学员,只要能够坚持把所有章节都学完,也一定会受益匪浅。
相关文章
|
1月前
|
SQL 存储 Apache
在 Apache Flink SQL 中,并没有内置的 GROUP_CONCAT 函数
【2月更文挑战第16天】在 Apache Flink SQL 中,并没有内置的 GROUP_CONCAT 函数
198 2
|
3月前
|
NoSQL MongoDB 数据库
在Flink的BEGIN STATEMENT SET;END;语句
在Flink的BEGIN STATEMENT SET;END;语句【1月更文挑战第19天】【1月更文挑战第93篇】
65 7
|
4月前
|
SQL Apache 流计算
Flink table&SQL 的使用
Flink table&SQL 的使用
32 0
|
5月前
|
SQL 分布式计算 HIVE
196 Spark SQL概述
196 Spark SQL概述
36 0
|
6月前
|
SQL 消息中间件 API
Flink---14、Flink SQL(SQL-Client准备、流处理中的表、时间属性、DDL)
Flink---14、Flink SQL(SQL-Client准备、流处理中的表、时间属性、DDL)
|
8月前
|
SQL NoSQL Java
Flink SQL Client初探
体验Flink SQL Client
159 1
Flink SQL Client初探
|
11月前
|
SQL 关系型数据库
Postgre SQL date_trunc() 和timestamp
Postgre SQL date_trunc() 和timestamp
82 0
Hive SQL开发中10个特殊日期获取方法
Hive SQL开发中10个特殊日期获取方法
|
SQL API 流计算
Flink SQL 使用时间属性
事件时间 处理时间

相关课程

更多