@@ -292,7 +292,7 @@ class BlockManagerReplicationSuite extends SparkFunSuite
292292
293293 // Add another normal block manager and test that 2x replication works
294294 makeBlockManager(10000 , " anotherStore" )
295- eventually(timeout(1000 milliseconds), interval(10 milliseconds)) {
295+ eventually(timeout(1000 . milliseconds), interval(10 . milliseconds)) {
296296 assert(replicateAndGetNumCopies(" a2" ) === 2 )
297297 }
298298 }
@@ -317,14 +317,14 @@ class BlockManagerReplicationSuite extends SparkFunSuite
317317
318318 // Add another store, 3x replication should work now, 4x replication should only replicate 3x
319319 val newStore1 = makeBlockManager(storeSize, s " newstore1 " )
320- eventually(timeout(1000 milliseconds), interval(10 milliseconds)) {
320+ eventually(timeout(1000 . milliseconds), interval(10 . milliseconds)) {
321321 assert(replicateAndGetNumCopies(" a3" , 3 ) === 3 )
322322 }
323323 assert(replicateAndGetNumCopies(" a4" , 4 ) === 3 )
324324
325325 // Add another store, 4x replication should work now
326326 val newStore2 = makeBlockManager(storeSize, s " newstore2 " )
327- eventually(timeout(1000 milliseconds), interval(10 milliseconds)) {
327+ eventually(timeout(1000 . milliseconds), interval(10 . milliseconds)) {
328328 assert(replicateAndGetNumCopies(" a5" , 4 ) === 4 )
329329 }
330330
@@ -340,7 +340,7 @@ class BlockManagerReplicationSuite extends SparkFunSuite
340340 val newStores = (3 to 5 ).map {
341341 i => makeBlockManager(storeSize, s " newstore $i" )
342342 }
343- eventually(timeout(1000 milliseconds), interval(10 milliseconds)) {
343+ eventually(timeout(1000 . milliseconds), interval(10 . milliseconds)) {
344344 assert(replicateAndGetNumCopies(" a7" , 3 ) === 3 )
345345 }
346346 }
0 commit comments