去返回你要的類型，可以用return()函數來解決 報錯的代碼如下： 修改：使用ret ...

最近遇到一個很奇怪的問題，Flink任務正常啟動正常運行一段時間后就會報錯，,錯誤詳情如下 初步判斷應該是觸發了akka的超時機制，那就先調整集群的akka超時間配置，在conf/flink-conf.yaml最后增加下面參數 觀察Job Manager ...

1、輸出錯誤日志信息 編輯tomcat/bin/startup.bat，尾部加上PAUSE，保存后重新運行startup.bat，可至tomcat/logs查看到錯誤日志信息。 2、如上 ...

簡介 記錄一些使用Flink SQL時遇到的報錯日志信息。 一：Caused by: java.lang.Exception: Pod terminated, container termination statuses: [flink-task-manager(exitCode=239 ...

程序批量插入數據時報錯，將sql在navicat執行又不報錯。報錯信息：Caused by: java.io.IOException: Tried to send an out-of-range integer as a 2-byte value: 43800 查詢資料參考資料發現 ...

最近2周開始接手apache flink全鏈路監控數據的作業，包括指標統計，業務規則匹配等邏輯，計算結果實時寫入elasticsearch. 昨天遇到生產環境有作業無法正常重啟的問題，我負責對這個問題進行排查跟進。 第一步，基礎排查 首先拿到jobmanager和taskmanager的日志 ...

遇到異常 發現異常： hostname 在shell中解析不完整 調整hostname后 增加hosts配置 屏蔽錯誤ho ...

當存儲和計算分離之后，給容器掛載的硬盤一般是塊設備，但這個塊設備可能是在其他主機上，使用iscsi協議來讀寫。 最近遇到一個問題，當iscsi的對應target出問題之后，容器中寫盤出現io err ...