[FLINK-12591][test] Fix synchronization issue in StatsDReporterTest

0d7a5a41 · Biao Liu · Chesnay Schepler · b046dd81 · 0d7a5a41
隐藏空白更改
内联并排

Showing with 2 addition and 2 deletion

flink-metrics/flink-metrics-statsd/src/test/java/org/apache/flink/metrics/statsd/StatsDReporterTest.java ...a/org/apache/flink/metrics/statsd/StatsDReporterTest.java +2 -2

未找到文件。
--- 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) {