diff --git a/dockertests/docker_test.go b/dockertests/docker_test.go
index 87eff5d..0851a41 100644
--- a/dockertests/docker_test.go
+++ b/dockertests/docker_test.go
@@ -121,7 +121,7 @@
 		It("should get data according to data scope", func(done Done) {
 			tableName := "docker_test_b"
 			targetTablename := "edgex_" + tableName
-			handler := &newTableHandler{
+			handler := &newTableScopeHandler{
 				targetTablename: targetTablename,
 				done:            done,
 			}
@@ -141,6 +141,8 @@
 	Expect(err).Should(Succeed())
 	_, err = tx.Exec("ALTER TABLE edgex." + tableName + " replica identity full;")
 	Expect(err).Should(Succeed())
+	_, err = tx.Exec("INSERT INTO edgex." + tableName + " values ('three', 3, '" + clusterIdFromConfig + "');")
+	Expect(err).Should(Succeed())
 	tx.Commit()
 }
 
@@ -302,6 +304,7 @@
 
 func (n *newTableHandler) Handle(event apid.Event) {
 	if s, ok := event.(*common.Snapshot); ok {
+		defer GinkgoRecover()
 		sqliteDb, err := dataService.DBVersion(s.SnapshotInfo)
 		Expect(err).Should(Succeed())
 		Expect(verifyTestTableExist(n.targetTablename, sqliteDb)).To(BeTrue())
@@ -333,6 +336,7 @@
 
 func (n *newTableScopeHandler) Handle(event apid.Event) {
 	if s, ok := event.(*common.Snapshot); ok {
+		defer GinkgoRecover()
 		sqliteDb, err := dataService.DBVersion(s.SnapshotInfo)
 		Expect(err).Should(Succeed())
 		verifyTestTableData(n.targetTablename, sqliteDb)