| commit | 1c902dfb22b5f815f9b5ec5441e646beec424ced | [log] [tgz] |
|---|---|---|
| author | ajaygit158 <ajaygit158@gmail.com> | Tue May 16 17:06:00 2017 +0530 |
| committer | ajaygit158 <ajaygit158@gmail.com> | Wed May 24 23:52:58 2017 +0530 |
| tree | f43e1aed266ca5557d7e11c514f56e82c887840c | |
| parent | 2f70751e7852cc8e2be94189e1bbf8be85a19559 [diff] |
APEXMALHAR-2491 Changes to shutdown the controller after completion of waittime in GenericFileOutputOperatorTest
diff --git a/library/src/test/java/org/apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java b/library/src/test/java/org/apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java index f248266..6bbbd3a 100644 --- a/library/src/test/java/org/apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java +++ b/library/src/test/java/org/apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java
@@ -166,6 +166,7 @@ for (int i = 0; i < MAX && (!outputFile.exists()); ++i) { Thread.sleep(1000); } + lc.shutdown(); if (!outputFile.exists()) { String msg = String.format("Error: output file not found after %d seconds%n", MAX); throw new RuntimeException(msg);