[skywalking] 01/02: Ease the payload.

[wusheng]

This is an automated email from the ASF dual-hosted git repository.

wusheng pushed a commit to branch ease-e2e
in repository https://gitbox.apache.org/repos/asf/skywalking.git

commit 901be6116d3077c55da7ee181dd87dac9f87f34e
Author: Wu Sheng <wu.sh...@foxmail.com>
AuthorDate: Fri Jul 19 16:25:04 2019 +0800

    Ease the payload.
---
 .../skywalking/e2e/ClusterVerificationITCase.java  | 34 ++++++++++++++--------
 1 file changed, 22 insertions(+), 12 deletions(-)

diff --git 
a/test/e2e/e2e-cluster/test-runner/src/test/java/org/apache/skywalking/e2e/ClusterVerificationITCase.java
 
b/test/e2e/e2e-cluster/test-runner/src/test/java/org/apache/skywalking/e2e/ClusterVerificationITCase.java
index eb45ef0..832cae1 100644
--- 
a/test/e2e/e2e-cluster/test-runner/src/test/java/org/apache/skywalking/e2e/ClusterVerificationITCase.java
+++ 
b/test/e2e/e2e-cluster/test-runner/src/test/java/org/apache/skywalking/e2e/ClusterVerificationITCase.java
@@ -98,18 +98,28 @@ public class ClusterVerificationITCase {
         final Map<String, String> user = new HashMap<>();
         user.put("name", "SkyWalking");
         List<Service> services = Collections.emptyList();
+
         while (services.size() < 2) {
             try {
-                restTemplate.postForEntity(
-                    instrumentedServiceUrl + "/e2e/users",
-                    user,
-                    String.class
-                );
                 services = queryClient.services(
                     new ServicesQuery()
                         .start(startTime)
                         .end(LocalDateTime.now(ZoneOffset.UTC).plusMinutes(1))
                 );
+
+                Thread.sleep(2000L);
+            } catch (Throwable ignored) {
+            }
+        }
+
+        for (int i = 0; i < 20; i++) {
+            try {
+                restTemplate.postForEntity(
+                    instrumentedServiceUrl + "/e2e/users",
+                    user,
+                    String.class
+                );
+                Thread.sleep(1000L);
             } catch (Throwable ignored) {
             }
         }
@@ -232,13 +242,13 @@ public class ClusterVerificationITCase {
                 while (!matched) {
                     LOGGER.warn("instanceRespTime is null, will retry to 
query");
                     Metrics instanceRespTime = queryClient.metrics(
-                            new MetricsQuery()
-                                .stepByMinute()
-                                .metricsName(metricsName)
-                                .start(minutesAgo)
-                                
.end(LocalDateTime.now(ZoneOffset.UTC).plusMinutes(1))
-                                .id(instance.getKey())
-                        );
+                        new MetricsQuery()
+                            .stepByMinute()
+                            .metricsName(metricsName)
+                            .start(minutesAgo)
+                            
.end(LocalDateTime.now(ZoneOffset.UTC).plusMinutes(1))
+                            .id(instance.getKey())
+                    );
                     AtLeastOneOfMetricsMatcher instanceRespTimeMatcher = new 
AtLeastOneOfMetricsMatcher();
                     MetricsValueMatcher greaterThanZero = new 
MetricsValueMatcher();
                     greaterThanZero.setValue("gt 0");