You are viewing a plain text version of this content. The canonical link for it is here.
Posted to notifications@skywalking.apache.org by wu...@apache.org on 2019/10/30 12:24:50 UTC
[skywalking] branch remove-500 created (now 361ba13)
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a change to branch remove-500
in repository https://gitbox.apache.org/repos/asf/skywalking.git.
at 361ba13 Remove two max size 500 limit.
This branch includes the following new commits:
new 361ba13 Remove two max size 500 limit.
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[skywalking] 01/01: Remove two max size 500 limit.
Posted by wu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
wusheng pushed a commit to branch remove-500
in repository https://gitbox.apache.org/repos/asf/skywalking.git
commit 361ba13db09f5e67fc8af36987c587d791fae7be
Author: Wu Sheng <wu...@foxmail.com>
AuthorDate: Wed Oct 30 17:54:34 2019 +0530
Remove two max size 500 limit.
---
.../plugin/elasticsearch/cache/NetworkAddressInventoryCacheEsDAO.java | 2 +-
.../storage/plugin/elasticsearch/cache/ServiceInventoryCacheEsDAO.java | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/NetworkAddressInventoryCacheEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/NetworkAddressInventoryCacheEsDAO.java
index b53d024..58154d0 100644
--- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/NetworkAddressInventoryCacheEsDAO.java
+++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/NetworkAddressInventoryCacheEsDAO.java
@@ -84,7 +84,7 @@ public class NetworkAddressInventoryCacheEsDAO extends EsDAO implements INetwork
try {
SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
searchSourceBuilder.query(QueryBuilders.rangeQuery(NetworkAddressInventory.LAST_UPDATE_TIME).gte(lastUpdateTime));
- searchSourceBuilder.size(500);
+ searchSourceBuilder.size(Integer.MAX_VALUE);
SearchResponse response = getClient().search(NetworkAddressInventory.INDEX_NAME, searchSourceBuilder);
diff --git a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/ServiceInventoryCacheEsDAO.java b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/ServiceInventoryCacheEsDAO.java
index 395a98b..f20d9d1 100644
--- a/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/ServiceInventoryCacheEsDAO.java
+++ b/oap-server/server-storage-plugin/storage-elasticsearch-plugin/src/main/java/org/apache/skywalking/oap/server/storage/plugin/elasticsearch/cache/ServiceInventoryCacheEsDAO.java
@@ -99,7 +99,7 @@ public class ServiceInventoryCacheEsDAO extends EsDAO implements IServiceInvento
boolQuery.must().add(QueryBuilders.rangeQuery(ServiceInventory.LAST_UPDATE_TIME).gte(lastUpdateTime));
searchSourceBuilder.query(boolQuery);
- searchSourceBuilder.size(500);
+ searchSourceBuilder.size(Integer.MAX_VALUE);
SearchResponse response = getClient().search(ServiceInventory.INDEX_NAME, searchSourceBuilder);