提交 895c9ba0 编写于 作者: Q qiaojialin

fix when batch is not full, time serialize overflow buffer size bug

上级 e7ea34d5
......@@ -176,8 +176,8 @@ public class Utils {
public static ByteBuffer getTimeBuffer(RowBatch rowBatch) {
ByteBuffer timeBuffer = ByteBuffer.allocate(rowBatch.getTimeBytesSize());
for (long time: rowBatch.timestamps) {
timeBuffer.putLong(time);
for (int i = 0; i < rowBatch.batchSize; i++) {
timeBuffer.putLong(rowBatch.timestamps[i]);
}
timeBuffer.flip();
return timeBuffer;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册