honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ElasticSearchIllegalStateException: stream marked as compressed, but no compressor found on transport layer, closes #2076.

This commit is contained in:
Shay Banon 2012-07-01 20:26:04 +02:00
parent 743d3f7e4b
commit 6cd9b92f95
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/org/elasticsearch/transport/netty/MessageChannelHandler.java
View File

@ -218,13 +218,16 @@ public class MessageChannelHandler extends SimpleChannelUpstreamHandler {
byte status = buffer.readByte(); byte status = buffer.readByte();
boolean isRequest = TransportStreams.statusIsRequest(status); boolean isRequest = TransportStreams.statusIsRequest(status);
// we have additional bytes to read, outside of the header
boolean hasBytesToRead = (size - (TransportStreams.HEADER_SIZE - 4)) != 0;
StreamInput wrappedStream; StreamInput wrappedStream;
if (TransportStreams.statusIsCompress(status) && buffer.readable()) { if (TransportStreams.statusIsCompress(status) && hasBytesToRead && buffer.readable()) {
Compressor compressor = CompressorFactory.compressor(buffer); Compressor compressor = CompressorFactory.compressor(buffer);
if (compressor == null) { if (compressor == null) {
int maxToRead = Math.min(buffer.readableBytes(), 10); int maxToRead = Math.min(buffer.readableBytes(), 10);
int offset = buffer.readerIndex(); int offset = buffer.readerIndex();
StringBuilder sb = new StringBuilder("stream marked as compressed, but no compressor found, first [").append(maxToRead).append("] content bytes out of [").append(buffer.readableBytes()).append("] are ["); StringBuilder sb = new StringBuilder("stream marked as compressed, but no compressor found, first [").append(maxToRead).append("] content bytes out of [").append(buffer.readableBytes()).append("] readable bytes with message size [").append(size).append("] ").append("] are [");
for (int i = 0; i < maxToRead; i++) { for (int i = 0; i < maxToRead; i++) {
sb.append(buffer.getByte(offset + i)).append(","); sb.append(buffer.getByte(offset + i)).append(",");
} }