Update wait time

ging · Oct 18, 2019 · fc591fe · fc591fe
1 parent dbb6de2
commit fc591fe
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/test/scala/org.fiware.cosmos.orion.flink.connector.tests/OrionConnectorTest.scala b/src/test/scala/org.fiware.cosmos.orion.flink.connector.tests/OrionConnectorTest.scala
@@ -158,11 +158,11 @@ class OrionConnectorTest extends  BaseTest{
 
   @Test def orionSource() : Unit = {
     run(() =>FlinkJobTest.main(Array()))
-    Thread.sleep(Utils.SleepTime)
+    Thread.sleep(Utils.SleepTime*2)
     for ( x <- 0 to 10){
       val json = simulatedNotification.notification(10*x,x).toString
       sendPostRequest(Utils.OtherUrl,json)
-      Thread.sleep(Utils.SleepTimeShort)
+      Thread.sleep(Utils.SleepTimeShort*2)
     }
     Thread.sleep(Utils.SleepTimeShort)
     Assert.assertEquals(simulatedNotification.maxTempVal,100*1,0)