Repository: apex-malhar Updated Branches: refs/heads/master 7237c0e06 -> 1683e6e94
APEXMALHAR-2357 changing exit condition for JdbcPojoOperatorApplicationTest, due to which it was failing intermittently Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/1683e6e9 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/1683e6e9 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/1683e6e9 Branch: refs/heads/master Commit: 1683e6e949b16601f1aef195cf73404dce2efe7f Parents: 7237c0e Author: Hitesh-Scorpio <[email protected]> Authored: Mon Nov 28 14:01:08 2016 +0530 Committer: Hitesh-Scorpio <[email protected]> Committed: Mon Nov 28 14:30:58 2016 +0530 ---------------------------------------------------------------------- .../datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/1683e6e9/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java ---------------------------------------------------------------------- diff --git a/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java b/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java index fe43327..f852577 100644 --- a/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java +++ b/library/src/test/java/com/datatorrent/lib/db/jdbc/JdbcPojoOperatorApplicationTest.java @@ -44,7 +44,6 @@ import com.datatorrent.stram.StramLocalCluster; public class JdbcPojoOperatorApplicationTest extends JdbcOperatorTest { public static int TupleCount; - public static com.datatorrent.lib.parser.XmlParserTest.EmployeeBean obj; public int getNumOfRowsinTable(String tableName) { @@ -76,7 +75,7 @@ public class JdbcPojoOperatorApplicationTest extends JdbcOperatorTest @Override public Boolean call() throws Exception { - return TupleCount == 10; + return getNumOfRowsinTable(TABLE_POJO_NAME) == 10; } }); lc.run(10000);// runs for 10 seconds and quits
