298299300301302303304305306307308
// make sure the WAL syncs Thread.sleep(TimeUnit.SECONDS.toMillis(1)); // This should block until shards have failed over client.shardServerLayout("test"); assertEquals(length, client.query("test", blurQuery).getTotalResults()); }
762763764765766767768769770771772
// make sure the WAL syncs Thread.sleep(TimeUnit.SECONDS.toMillis(1)); // This should block until shards have failed over client.shardServerLayout(tableName); assertEquals(numberOfDocs, client.query(tableName, blurQuery).getTotalResults()); }