报错信息：
Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes
发生缘故
jmeter 压测，写入 elasticsearch 报错
运行环境
- elasticsearch 6.7.2
- jmeter 5.5
- jdbc 1.8
报错信息
分析排查
- Compressor detection can only be called on some xcontent bytes or compressed xcontent bytes
- 压缩器检测只能在某些 xcontent 字节或压缩的 xcontent 字节上面调用
根据报错原因可以将错误定位至 io.xwt.BulkDoument.runTest(BulkDoument.java 87)，代码如下：
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
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 {
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();
}
|
那么就可以将报错信息转为人话了：语句的类型不是JSON风格的或者JSON格式化错误了。
定位写入数据，数据如下：
@timestamp 为 date类型，这里用了 string，修改这个值/jmx上替换。
注：
