ES：Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes

Elasticsearch

发布日期: 2023-04-14

文章字数: 301

阅读时长: 1 分

发生缘故

jmeter 压测，写入 elasticsearch 报错

运行环境

elasticsearch 6.7.2
jmeter 5.5
jdbc 1.8

报错信息

error_information

分析排查

Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes
压缩器检测只能在某些 xcontent 字节或压缩的 xcontent 字节上面调用

根据报错原因可以将错误定位至 io.xwt.BulkDoument.runTest(BulkDoument.java 87)，代码如下：

// 解析 json
for(int i = 0; i < datas.length; ++i) {
    datas[i] = datas[i].replace("{DATET}", datasdf.format(System.currentTimeMillis()));
    if (this.threadNum != 0) {
        String id = "t" + this.threadNum + "_" + System.currentTimeMillis() + "_" + UUID.randomUUID();
        br.add((new IndexRequest(this.indexName, default_type, id)).source(datas[i], XContentType.JSON));
    } else {
br.add((new IndexRequest()).source(datas[i], XContentType.JSON));
    }
}
try {
// 生成 bulk 连接
    sampleResult.sampleStart();
    BulkResponse bulkResponse = this.client.bulk(br, RequestOptions.DEFAULT);
    sampleResult.sampleEnd();
    sampleResult.setSuccessful(true);
    sampleResult.setResponseCodeOK();
    if (bulkResponse.hasFailures()) {
        sampleResult.setSuccessful(false);
        sampleResult.setResponseCode("500");
        sampleResult.setResponseData(bulkResponse.buildFailureMessage(), "utf-8");
    } else {
        sampleResult.setResponseData("all in", "utf-8");
    }
// 报错
} catch (Exception var8) {
    sampleResult.sampleEnd();
    sampleResult.setSuccessful(false);
    sampleResult.setResponseCode("500");
    sampleResult.setResponseMessage(var8.getMessage());
    var8.printStackTrace();
}