You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2017/05/24 19:32:48 UTC
apex-malhar git commit: APEXMALHAR-2491 Changes to shutdown the
controller after completion of waittime in GenericFileOutputOperatorTest
Repository: apex-malhar
Updated Branches:
refs/heads/master 2f70751e7 -> 1c902dfb2
APEXMALHAR-2491 Changes to shutdown the controller after completion of waittime in GenericFileOutputOperatorTest
Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/1c902dfb
Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/1c902dfb
Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/1c902dfb
Branch: refs/heads/master
Commit: 1c902dfb22b5f815f9b5ec5441e646beec424ced
Parents: 2f70751
Author: ajaygit158 <aj...@gmail.com>
Authored: Tue May 16 17:06:00 2017 +0530
Committer: ajaygit158 <aj...@gmail.com>
Committed: Wed May 24 23:52:58 2017 +0530
----------------------------------------------------------------------
.../apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/1c902dfb/library/src/test/java/org/apache/apex/malhar/lib/fs/GenericFileOutputOperatorTest.java
----------------------------------------------------------------------
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 @@ public class GenericFileOutputOperatorTest extends AbstractFileOutputOperatorTes
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);