首页
Python
Java
前端
数据库
Linux
Chatgpt专题
开发者工具箱
pyflink1.18专题
pyflink1.18.0 keyby之后使用自定义keyedProcessfunction报错
现象概述 使用可自定义的keyedProcessFunction,本地运行没问题,数据输入输出没问题. 但是上线后出现问题,最终无疾而终,怀疑线上环境导致的. 环境 flink1.18.0(代码 线上 环境版本统一的) python3.9 报错关键词 - Failed to deserialize consumer record due to - Failed to start re
阅读更多...