How to use pipeline (ingest) in Java Index/Update API

[LoadingZhang (Lucas Zhang)]

I have trouble in this problem,this is what I do:

this.esClient.add(new IndexRequest(esIndexName + "-" + TimeUtil.getNowTimeByFormat(indexSuffixFormat),indexTypeName).setPipeline(esIndexPipeline));

But I got errors:

org.elasticsearch.common.compress.NotXContentException: Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes
        at org.elasticsearch.common.compress.CompressorFactory.compressor(CompressorFactory.java:57) ~[elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.common.xcontent.XContentHelper.convertToMap(XContentHelper.java:66) ~[elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.action.index.IndexRequest.sourceAsMap(IndexRequest.java:410) ~[elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.ingest.PipelineExecutionService.innerExecute(PipelineExecutionService.java:164) ~[elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.ingest.PipelineExecutionService.access$000(PipelineExecutionService.java:41) ~[elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.ingest.PipelineExecutionService$2.doRun(PipelineExecutionService.java:88) [elasticsearch-5.2.1.jar:5.2.1]
        at org.elasticsearch.common.util.concurrent.ThreadContext$ContextPreservingAbstractRunnable.doRun(ThreadContext.java:596) [elasticsearch-5.2.1.jar:5.2.1]

Can someone give me some tips?