DBZ-3099 Race condition in waiting for metrics
This commit is contained in:
parent
21b15facb2
commit
b0f906df35
@ -10,6 +10,7 @@
|
||||
import java.lang.management.ManagementFactory;
|
||||
import java.nio.file.Path;
|
||||
import java.sql.Connection;
|
||||
import java.time.Duration;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
|
||||
import javax.management.InstanceNotFoundException;
|
||||
@ -17,6 +18,7 @@
|
||||
import javax.management.MalformedObjectNameException;
|
||||
import javax.management.ObjectName;
|
||||
|
||||
import org.awaitility.Awaitility;
|
||||
import org.junit.After;
|
||||
import org.junit.Assert;
|
||||
import org.junit.Before;
|
||||
@ -251,6 +253,8 @@ private void assertStreamingMetrics(long events) throws Exception {
|
||||
assertThat((Long) mBeanServer.getAttribute(getStreamingMetricsObjectName(), "TotalNumberOfEventsSeen"))
|
||||
.isGreaterThanOrEqualTo(events);
|
||||
|
||||
Awaitility.await().atMost(Duration.ofMinutes(1)).until(() -> ((String[]) mBeanServer
|
||||
.getAttribute(getStreamingMetricsObjectName(), "MonitoredTables")).length > 0);
|
||||
assertThat(mBeanServer.getAttribute(getStreamingMetricsObjectName(), "MonitoredTables"))
|
||||
.isEqualTo(new String[]{ DATABASE.qualifiedTableName("simple") });
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user