fix compile errors

This commit is contained in:
Simon Willnauer 2016-01-13 12:16:26 +01:00
parent ce42ae4cf3
commit aa464778b1
2 changed files with 2 additions and 2 deletions

View File

@ -67,7 +67,7 @@ public class SimulateDocumentSimpleResult implements SimulateDocumentResult<Simu
Exception exception = in.readThrowable(); Exception exception = in.readThrowable();
return new SimulateDocumentSimpleResult(exception); return new SimulateDocumentSimpleResult(exception);
} }
return new SimulateDocumentSimpleResult(WriteableIngestDocument.readWriteableIngestDocumentFrom(in)); return new SimulateDocumentSimpleResult(new WriteableIngestDocument(in));
} }
@Override @Override

View File

@ -108,7 +108,7 @@ public class WriteableIngestDocumentTests extends ESTestCase {
BytesStreamOutput out = new BytesStreamOutput(); BytesStreamOutput out = new BytesStreamOutput();
writeableIngestDocument.writeTo(out); writeableIngestDocument.writeTo(out);
StreamInput streamInput = StreamInput.wrap(out.bytes()); StreamInput streamInput = StreamInput.wrap(out.bytes());
WriteableIngestDocument otherWriteableIngestDocument = WriteableIngestDocument.readWriteableIngestDocumentFrom(streamInput); WriteableIngestDocument otherWriteableIngestDocument = new WriteableIngestDocument(streamInput);
assertThat(otherWriteableIngestDocument, equalTo(writeableIngestDocument)); assertThat(otherWriteableIngestDocument, equalTo(writeableIngestDocument));
} }
} }