You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/05/24 07:54:34 UTC
[flink] branch master updated: [FLINK-12591][test] Fix
synchronization issue in StatsDReporterTest
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new 0d7a5a4 [FLINK-12591][test] Fix synchronization issue in StatsDReporterTest
0d7a5a4 is described below
commit 0d7a5a41c60765f2e63fd337d222f53697bf91b3
Author: Biao Liu <mm...@gmail.com>
AuthorDate: Fri May 24 15:54:23 2019 +0800
[FLINK-12591][test] Fix synchronization issue in StatsDReporterTest
---
.../test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java b/flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java
index 101326a..06086e6 100644
--- a/flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java
+++ b/flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java
@@ -327,8 +327,8 @@ public class StatsDReporterTest extends TestLogger {
long endTimeout = System.currentTimeMillis() + timeout;
long remainingTimeout = timeout;
- while (numberLines > lines.size() && remainingTimeout > 0) {
- synchronized (lines) {
+ synchronized (lines) {
+ while (numberLines > lines.size() && remainingTimeout > 0) {
try {
lines.wait(remainingTimeout);
} catch (InterruptedException e) {