如下看图:第一次接触FLink获取当前日期如下图
在Sql的Where条件中做条件查询,如下图:
其结果造成数据的不更新,结果数据不正确;
原因:FlinkSql函数中,获取当前日期:CURRENT_DATE ,以返回当前系统日期;
相关文章
- 12-24Flink实战(八十七):flink-sql使用(十四)Flink 与 hive 结合使用(六)Hive 函数
- 12-24Flink实战(八十七):flink-sql使用(十四)Flink 与 hive 结合使用(六)Hive 函数
- 12-24Flink实战(八十六):flink-sql使用(十三)Flink 与 hive 结合使用(五)Hive Streaming
- 12-24Flink实例(120):flink-sql使用(二十六)一文了解基于Flink构建流批一体数仓的技术点(三)
- 12-24Flink实战(八十六):flink-sql使用(十三)Flink 与 hive 结合使用(五)Hive Streaming
- 12-24Flink基础(128):FLINK-SQL语法 (22) DQL(14) OPERATIONS(11) Joins(5) 其他
- 12-24Flink基础(121):FLINK-SQL语法 (15) DQL(7) OPERATIONS(4) 窗口 (2) 窗口聚合
- 12-24Flink基础(119):FLINK-SQL语法 (13) DQL(5) OPERATIONS(2) SELECT & WHERE clause/ SELECT DISTINCT(FLINK 1.13
- 12-24Flink基础(120):FLINK-SQL语法 (14) DQL(6) OPERATIONS(3) 窗口 (1) Windowing table-valued functions (Windowi
- 12-24flink-sql解析canal-json实现实时同步