This is an automated email from the ASF dual-hosted git repository. ningjiang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/servicecomb-pack.git
commit 54c0d6c4b886007b479820b22cfeb58cf74823f3 Author: Lei Zhang <[email protected]> AuthorDate: Wed Aug 7 23:02:15 2019 +0800 SCB-1411 Add the get of slow transactions TOP N for API v1 --- .../elasticsearch/ElasticsearchTransactionRepository.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java index b7745ee..903b223 100644 --- a/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java +++ b/alpha/alpha-fsm/src/main/java/org/apache/servicecomb/pack/alpha/fsm/repository/elasticsearch/ElasticsearchTransactionRepository.java @@ -158,6 +158,7 @@ public class ElasticsearchTransactionRepository implements TransactionRepository @Override public List<GlobalTransaction> getSlowGlobalTransactionsTopN(int n) { + // ElasticsearchTemplate.prepareScroll() does not add sorting https://jira.spring.io/browse/DATAES-457 ObjectMapper jsonMapper = new ObjectMapper(); List<GlobalTransaction> globalTransactions = new ArrayList(); SearchResponse response = this.template.getClient().prepareSearch(INDEX_NAME) @@ -167,12 +168,12 @@ public class ElasticsearchTransactionRepository implements TransactionRepository .setFrom(0).setSize(10).setExplain(true) .get(); response.getHits().forEach(hit -> { - try{ + try { GlobalTransactionDocument dto = jsonMapper .readValue(hit.getSourceAsString(), GlobalTransactionDocument.class); globalTransactions.add(dto); - }catch (Exception e){ - LOG.error(e.getMessage(),e); + } catch (Exception e) { + LOG.error(e.getMessage(), e); } }); return globalTransactions;
