这种错误一般是什么方面的错误呢？ java.lang.runtimeexception: Inte
这种错误一般是什么方面的错误呢？
java.lang.runtimeexception: Interrupted while waiting for bufferat org.apache.flink.streaming.runtime.io.RecordWriterOutput.(RecordWriterOutput.java:109) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:93) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at org.apache.flink.streaming.runtime.io.RecordWriterOutput.collect(RecordWriterOutput.java:44) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at org.apache.flink.streaming.api.operators.TimestampedCollector.collect(TimestampedCollector.java:50) ~[flink-dist_2.12-1.13.6.jar:1.13.6]at cn.enn.bigdata.flink.function.IndexParamFactorDecodeFunction.processElement(IndexParamFactorDecodeFunction.java:64) [blob_p-e02a9d0deb7e92147f6550d0f6976d9f0588e822-5b270e8318cafdab055b878b64c67e78:?]at%20cn.enn.bigdata.flink.function.IndexParamFactorDecodeFunction.processElement(IndexParamFactorDecodeFunction.java:18)%20[blob_p-e02a9d0deb7e92147f6550d0f6976d9f0588e822-5b270e8318cafdab055b878b64c67e78:?]at%20org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)%20[flink-dist_2.12-1.13.6.jar:1.13.6]at%20org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.pushToOperator(CopyingChainingOutput.java:71)%20[flink-dist_2.12-1.13.6.jar:1.13.6]at%20org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:46)%20[flink-dist_2.12-1.13.6.jar:1.13.6]at%20org.apache.flink.streaming.runtime.tasks.CopyingChainingOutput.collect(CopyingChainingOutput.java:26)%20[flink-dist_2.12-1.13.6.jar:1.13.6]at%20org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:50)%20[flink-dist_2.12-1.13.6.jar:1.13.6]at%20org.apache.flink.streaming.api.operators.CountingOutput.collect(CountingOutput.java:28)%20[flink-dist_2.12-1.13.6.jar:1.13.6]
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务，基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎，提高作业开发运维效率。
