Position out of bounds.

[hailong]

flink 1.10  onYarn
job 中 有一个MapState[Long,Bean]

 https://www.helloimg.com/image/Pe1QR

 程序启动一段时间（20分钟）后出现了 附件中的异常

查看对应源码也没看懂是什么引起的异常

https://www.helloimg.com/image/Peqc5

[Shuai Xia]

你好,请问解决了么,我看了下源码,好像是一个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 <[hidden email]>
发送时间：2020年7月2日(星期四) 17:46
收件人：flink 中文社区 <[hidden email]>
主　题：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

[hailong]

感谢
没看明白这个bug引起的原因是什么，或者说有什么合适的解决方案？


| |
夏*
|
|
邮箱：[hidden email]
|

签名由 网易邮箱大师 定制

在2020年07月02日 18:39，夏帅 写道：
你好,请问解决了么,我看了下源码,好像是一个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 <[hidden email]>
发送时间：2020年7月2日(星期四) 17:46
收件人：flink 中文社区 <[hidden email]>
主　题：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

[Shuai Xia]

不好意思，看错了，这里是自增了





来自钉钉专属商务邮箱------------------------------------------------------------------
发件人：xuhaiLong<[hidden email]>
日　期：2020年07月02日 18:46:37
收件人：夏帅<[hidden email]>
抄　送：user-zh<[hidden email]>
主　题：回复：Position out of bounds.

感谢
没看明白这个bug引起的原因是什么，或者说有什么合适的解决方案？


| |
夏*
|
|
邮箱：[hidden email]
|

签名由 网易邮箱大师 定制

在2020年07月02日 18:39，夏帅 写道：
你好,请问解决了么,我看了下源码,好像是一个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 <[hidden email]>
发送时间：2020年7月2日(星期四) 17:46
收件人：flink 中文社区 <[hidden email]>
主　题：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

[hailong]

感谢
没看明白这个bug引起的原因是什么，或者说有什么合适的解决方案？


On 7/2/2020 18:39，夏帅<[hidden email]> wrote：
你好,请问解决了么,我看了下源码,好像是一个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 <[hidden email]>
发送时间：2020年7月2日(星期四) 17:46
收件人：flink 中文社区 <[hidden email]>
主　题：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