You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by zh...@apache.org on 2019/04/16 07:14:11 UTC

[geode] branch feature/GEODE-6640 updated: fix potential race condition for async jdbc-mapping

This is an automated email from the ASF dual-hosted git repository.

zhouxj pushed a commit to branch feature/GEODE-6640
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEODE-6640 by this push:
     new 053b96a  fix potential race condition for async jdbc-mapping
053b96a is described below

commit 053b96ab31d8003e1c11d17126609128443f5852
Author: zhouxh <gz...@pivotal.io>
AuthorDate: Tue Apr 16 00:13:32 2019 -0700

    fix potential race condition for async jdbc-mapping
---
 .../org/apache/geode/connectors/jdbc/JdbcDistributedTest.java     | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
index 19cea46..0532de8 100644
--- a/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
+++ b/geode-connectors/src/acceptanceTest/java/org/apache/geode/connectors/jdbc/JdbcDistributedTest.java
@@ -630,7 +630,9 @@ public abstract class JdbcDistributedTest implements Serializable {
 
       String key = "emp1";
       ClusterStartupRule.getCache().getRegion(REGION_NAME).put(key, pdxEmployee1);
-      assertTableHasEmployeeData(1, pdxEmployee1, key);
+      await().untilAsserted(() -> {
+        assertTableHasEmployeeData(1, pdxEmployee1, key);
+      });
     });
   }
 
@@ -647,7 +649,9 @@ public abstract class JdbcDistributedTest implements Serializable {
 
       String key = "emp1";
       ClusterStartupRule.getCache().getRegion(REGION_NAME).put(key, pdxEmployee1);
-      assertTableHasEmployeeData(1, pdxEmployee1, key);
+      await().untilAsserted(() -> {
+        assertTableHasEmployeeData(1, pdxEmployee1, key);
+      });
     });
   }