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
The following commit(s) were added to refs/heads/master by this push:
new 4764901 SCB-1419 Add debug info for CI
4764901 is described below
commit 476490171e0f76b23f40f003a5b16e3e9d43a2df
Author: Lei Zhang <[email protected]>
AuthorDate: Tue Aug 6 14:02:43 2019 +0800
SCB-1419 Add debug info for CI
---
.../repository/elasticsearch/ElasticsearchTransactionRepository.java | 1 +
.../alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java | 4 ++--
2 files changed, 3 insertions(+), 2 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 3a1a430..8625ef2 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
@@ -176,6 +176,7 @@ public class ElasticsearchTransactionRepository implements
TransactionRepository
metricsService.metrics().doRepositoryAccepted(queries.size());
long end = System.currentTimeMillis();
metricsService.metrics().doRepositoryAvgTime((end - begin) /
queries.size());
+ LOG.info("save queries={}, received={},
accepted={}",queries.size(),metricsService.metrics().getRepositoryReceived(),metricsService.metrics().getRepositoryAccepted());
}
class RefreshTimer implements Runnable {
diff --git
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java
index 4192000..e29585c 100644
---
a/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java
+++
b/alpha/alpha-fsm/src/test/java/org/apache/servicecomb/pack/alpha/fsm/repository/ElasticsearchTransactionRepositoryTest.java
@@ -109,9 +109,9 @@ public class ElasticsearchTransactionRepositoryTest {
@Test
public void asyncWithBatchSizeAndRefreshTimeTest() throws Exception {
- int size = 100;
+ int size = 15;
int refreshTime = 2;
- int batchSize = 95;
+ int batchSize = 10;
TransactionRepository repository = new
ElasticsearchTransactionRepository(template,
metricsService, batchSize, refreshTime * 1000);
for (int i = 0; i < size; i++) {
