You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by bh...@apache.org on 2016/11/29 06:43:40 UTC
apex-malhar git commit: APEXMALHAR-2357 changing exit condition for
JdbcPojoOperatorApplicationTest, due to which it was failing intermittently
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 <fo...@gmail.com>
Authored: Mon Nov 28 14:01:08 2016 +0530
Committer: Hitesh-Scorpio <fo...@gmail.com>
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