回复：Position out of bounds.

Thu, 02 Jul 2020 03:40:08 -0700 

你好,请问解决了么,我看了下源码,好像是一个bug
DataOutputSerializer

@Override
public void write(int b) throws IOException {
   if (this.position >= this.buffer.length) {
      resize(1);
   }
   this.buffer[this.position++] = (byte) (b & 0xff);
}
此处position应该自增


------------------------------------------------------------------
发件人：xuhaiLong <[email protected]>
发送时间：2020年7月2日(星期四) 17:46
收件人：flink 中文社区 <[email protected]>
主　题：Position out of bounds.

  
flink 1.10  onYarn
job 中 有一个MapState[Long,Bean]
https://www.helloimg.com/image/Pe1QR
 程序启动一段时间（20分钟）后出现了 附件中的异常
查看对应源码也没看懂是什么引起的异常
https://www.helloimg.com/image/Peqc5

回复