diff --git a/CHANGES.md b/CHANGES.md index 3b4190992..9dad1554f 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -23,6 +23,10 @@ Release Notes. - Add test case for span limit mechanism. - Add telemetry module and prometheus implementation, with grafana setting. - A refactor for register API in storage module. +- Fix H2 and MySQL endpoint dependency map miss upstream side. +- Optimize the inventory register and refactor the implementation. +- Speed up the trace buffer read. +- Fix and removed unnecessary inventory register operations. #### UI - Add new trace view. diff --git a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopologyQueryDAO.java b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopologyQueryDAO.java index f1d73cc97..4b527eca6 100644 --- a/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopologyQueryDAO.java +++ b/oap-server/server-storage-plugin/storage-jdbc-hikaricp-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/jdbc/h2/dao/H2TopologyQueryDAO.java @@ -72,7 +72,9 @@ public class H2TopologyQueryDAO implements ITopologyQueryDAO { int destEndpointId) throws IOException { String tableName = DownSamplingModelNameBuilder.build(step, EndpointRelationServerSideIndicator.INDEX_NAME); - return loadEndpointFromSide(tableName, startTB, endTB, EndpointRelationServerSideIndicator.SOURCE_ENDPOINT_ID, EndpointRelationServerSideIndicator.DEST_ENDPOINT_ID, destEndpointId, false); + List calls = loadEndpointFromSide(tableName, startTB, endTB, EndpointRelationServerSideIndicator.SOURCE_ENDPOINT_ID, EndpointRelationServerSideIndicator.DEST_ENDPOINT_ID, destEndpointId, false); + calls.addAll(loadEndpointFromSide(tableName, startTB, endTB, EndpointRelationServerSideIndicator.SOURCE_ENDPOINT_ID, EndpointRelationServerSideIndicator.DEST_ENDPOINT_ID, destEndpointId, true)); + return calls; } private List loadServiceCalls(String tableName, long startTB, long endTB, String sourceCName,