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寫，所以要注意這個問題： 使用對 ...