Flink udf的小问题：无参数的udf函数会被优化成常量表达式
这两天有一个使用flink sql的实时流项目，需要在每个结果中标记当前时间。因为flink没有获取当前时间的函数，于是我自己定义了一个udf： 然后注册成currentUnixTime()进行使用： 本来以为就是这么简单的事情，结果看实时流数据的时候发现，这个时间 ...
原文：Flink 1.10 UDF 的一个小问题
在使用 Flink . 的 SQL 的时候，遇到个小问题： 一个返回当前时间的函数返回的结果是启动的时间，并且保持不变。 比如下面这个UDF，获取当前时间的 时分秒 HH:mm:ss 格式 最开始用的时候，直接写了这么个UDF，还自我感觉很溜。。。 在测试的时候，也没有留意到返回的值都是相同的，在线上跑了几天才发现。。。 如sql ： 返回值如下： 全是一样的 在代码里面添加 日志信息，只有在启动 ...
2020-05-25 13:27 0 727 推荐指数：
相关推荐
UniversalImageLoader的一个小问题
最近在使用UniversalImageLoader时遇到了一个小问题，多个地方同时通过ImageLoader.getInstance().loadImage(url, new ImageSize(dp72, dp72)...加载图像时，有一定机率只有部分地方能正确地加载到图片，其他地方是什么 ...
Flink 1.10 SQL 写 Hbase 数据无法写入hbase问题
接之前的：Flink 1.10 SQL 写HBase 有朋友看了之前的 sql 写 Hbase 的博客，自己试了写，可能没有得到预期的结果 之前在捣腾的时候，也花了不少时间，这里大概写下遇到的两个问题 1、hbase 表参数问题 我们有多套hbase 集群，之前 ...
在自定义Flink1.10 Sql Sink遇到的问题
1.org.apache.flink.table.api.TableException: Table sink does not implement a table schema. 问题：在RedisTableSink中没有重写getTableSchema方法 解决：增加 ...
Flink aggregate 的一个小问题 Cannot resolve method 'aggregate(com.dianshang.Util.CountAgg, com.dianshang.Util.WindowResultFunction)'
使用aggregate 函数报错： 报错：Cannot resolve method 'aggregate(com.dianshang.Util.CountAgg, com.dianshang. ...
【Flink】Windows环境部署Flink 1.10版本问题解决
在Windows环境部署Flink 1.10版本，发现TaskManager启动失败，看日志主要是几个内存参数没有配置导致的，简单记录一下。 直接通过start-cluster.bat启动会拉起JobManager和TaskManager，如果下列参数不配置的话 ...
Flink 1.10 SQL 写HBase
Hbase 也是我们很常用的数据存储组件，所以提前尝试下用SQL 写Hbase，中间也遇到一些坑，跟大家分享一下。 官网地址：https://ci.apache.org/projects/flink/flink-docs-release-1.10/dev/table ...
Flink aggregate()函数使用遇到的一点小问题
不对，改成String类型，果然是这个问题。 因为是java写，所以要注意这个问题： 使用对 ...