pyflink1.18专题

pyflink1.18.0 keyby之后使用自定义keyedProcessfunction报错

现象概述 使用可自定义的keyedProcessFunction,本地运行没问题,数据输入输出没问题. 但是上线后出现问题,最终无疾而终,怀疑线上环境导致的.  环境 flink1.18.0(代码 线上 环境版本统一的) python3.9 报错关键词 - Failed to deserialize consumer record due to - Failed to start re