pyflink1.18.0 keyby之后使用自定义keyedProcessfunction报错
现象概述
使用可自定义的keyedProcessFunction,本地运行没问题,数据输入输出没问题. 但是上线后出现问题,最终无疾而终,怀疑线上环境导致的.
环境
flink1.18.0(代码 线上 环境版本统一的) python3.9
报错关键词
- Failed to deserialize consumer record due to
- Failed to start remote bundle
- Caused by: org.apache.beam.vendor.grpc.v1p48p1.io.grpc.StatusRuntimeException: CANCELLED: call already cancelled. Use ServerCallStreamObserver.setOnCancelHandler() to disable this exception
- Caught exception while processing timer.
- Caused by: TimerException{java.lang.RuntimeException: Error while waiting for BeamPythonFunctionRunner flush}
- Caused by: java.lang.RuntimeException: Failed to close remote bundle
- Suppressed: java.lang.IllegalStateException: Processing bundle failed, TODO: [https://github.com/apache/beam/issues/18756] abort bundle.
conda 虚拟环境
apache-beam==2.48.0
apache-flink==1.18.0
apache-flink-libraries&#