@@ -185,7 +185,7 @@ private List<String> lsR(List<String> fileNames, Path dir)
185185 return fileNames ;
186186 }
187187
188- private void run (String configYaml , final Optional < Integer > sleep )
188+ private void run (String configYaml )
189189 {
190190 ConfigSource config = getConfigFromYaml (configYaml );
191191 runner .transaction (config , SCHEMA , 1 , new Control ()
@@ -204,16 +204,10 @@ public List<TaskReport> run(TaskSource taskSource)
204204 true , 2L , 3.0D , "45" , Timestamp .ofEpochMilli (678L ), newMap (newString ("k" ), newString ("v" )),
205205 true , 2L , 3.0D , "45" , Timestamp .ofEpochMilli (678L ), newMap (newString ("k" ), newString ("v" )))) {
206206 pageOutput .add (page );
207- if (sleep .isPresent ()) {
208- Thread .sleep (sleep .get () * 1000 );
209- }
210207 }
211208 pageOutput .commit ();
212209 committed = true ;
213210 }
214- catch (InterruptedException e ) {
215- logger .debug (e .getMessage (), e );
216- }
217211 finally {
218212 if (!committed ) {
219213 pageOutput .abort ();
@@ -372,7 +366,7 @@ public void testUserPasswordAndPutToUserDirectoryRoot()
372366 " default_timezone: 'UTC'" ;
373367
374368 // runner.transaction -> ...
375- run (configYaml , Optional .< Integer > absent () );
369+ run (configYaml );
376370
377371 List <String > fileList = lsR (Lists .<String >newArrayList (), Paths .get (testFolder .getRoot ().getAbsolutePath ()));
378372 assertThat (fileList , hasItem (containsString (pathPrefix + "001.00.txt" )));
@@ -408,7 +402,7 @@ public void testUserSecretKeyFileAndPutToRootDirectory()
408402 " default_timezone: 'UTC'" ;
409403
410404 // runner.transaction -> ...
411- run (configYaml , Optional .< Integer > absent () );
405+ run (configYaml );
412406
413407 List <String > fileList = lsR (Lists .<String >newArrayList (), Paths .get (testFolder .getRoot ().getAbsolutePath ()));
414408 assertThat (fileList , hasItem (containsString (pathPrefix + "001.00.txt" )));
@@ -456,7 +450,7 @@ public void testUserSecretKeyFileWithProxy()
456450 " default_timezone: 'UTC'" ;
457451
458452 // runner.transaction -> ...
459- run (configYaml , Optional .< Integer > absent () );
453+ run (configYaml );
460454
461455 List <String > fileList = lsR (Lists .<String >newArrayList (), Paths .get (testFolder .getRoot ().getAbsolutePath ()));
462456 assertThat (fileList , hasItem (containsString (pathPrefix + "001.00.txt" )));
0 commit comments