Skip to content

Commit cb742a2

Browse files
authored
Fix wrong merged table check in JFRDataQueryEsDAO (#13805)
1 parent ad12d91 commit cb742a2

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

  • oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query

oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/query/JFRDataQueryEsDAO.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,6 @@
2525
import org.apache.skywalking.library.elasticsearch.requests.search.SearchBuilder;
2626
import org.apache.skywalking.library.elasticsearch.response.search.SearchHit;
2727
import org.apache.skywalking.library.elasticsearch.response.search.SearchResponse;
28-
import org.apache.skywalking.oap.server.core.profiling.asyncprofiler.storage.AsyncProfilerTaskRecord;
2928
import org.apache.skywalking.oap.server.core.profiling.asyncprofiler.storage.JFRProfilingDataRecord;
3029
import org.apache.skywalking.oap.server.core.storage.profiling.asyncprofiler.IJFRDataQueryDAO;
3130
import org.apache.skywalking.oap.server.library.client.elasticsearch.ElasticSearchClient;
@@ -52,7 +51,7 @@ public List<JFRProfilingDataRecord> getByTaskIdAndInstancesAndEvent(String taskI
5251
}
5352
final String index = IndexController.LogicIndicesRegister.getPhysicalTableName(JFRProfilingDataRecord.INDEX_NAME);
5453
final BoolQueryBuilder query = Query.bool();
55-
if (IndexController.LogicIndicesRegister.isMergedTable(AsyncProfilerTaskRecord.INDEX_NAME)) {
54+
if (IndexController.LogicIndicesRegister.isMergedTable(JFRProfilingDataRecord.INDEX_NAME)) {
5655
query.must(Query.term(IndexController.LogicIndicesRegister.RECORD_TABLE_NAME, JFRProfilingDataRecord.INDEX_NAME));
5756
}
5857
query.must(Query.term(JFRProfilingDataRecord.TASK_ID, taskId));

0 commit comments

Comments
 (0)