Repository: zeppelin Updated Branches: refs/heads/master 794e18971 -> 39dc9a51a
[HOTFIX] Fix flaky test of LuceneSearchTest Project: http://git-wip-us.apache.org/repos/asf/zeppelin/repo Commit: http://git-wip-us.apache.org/repos/asf/zeppelin/commit/39dc9a51 Tree: http://git-wip-us.apache.org/repos/asf/zeppelin/tree/39dc9a51 Diff: http://git-wip-us.apache.org/repos/asf/zeppelin/diff/39dc9a51 Branch: refs/heads/master Commit: 39dc9a51a4a8598ed3b38b4be0231a809a3df16f Parents: 794e189 Author: Jeff Zhang <zjf...@apache.org> Authored: Wed Sep 26 20:56:15 2018 +0800 Committer: Jeff Zhang <zjf...@apache.org> Committed: Thu Sep 27 09:40:09 2018 +0800 ---------------------------------------------------------------------- .../apache/zeppelin/search/LuceneSearchTest.java | 19 ++++--------------- 1 file changed, 4 insertions(+), 15 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/zeppelin/blob/39dc9a51/zeppelin-zengine/src/test/java/org/apache/zeppelin/search/LuceneSearchTest.java ---------------------------------------------------------------------- diff --git a/zeppelin-zengine/src/test/java/org/apache/zeppelin/search/LuceneSearchTest.java b/zeppelin-zengine/src/test/java/org/apache/zeppelin/search/LuceneSearchTest.java index 35484d4..0c5bf6c 100644 --- a/zeppelin-zengine/src/test/java/org/apache/zeppelin/search/LuceneSearchTest.java +++ b/zeppelin-zengine/src/test/java/org/apache/zeppelin/search/LuceneSearchTest.java @@ -71,17 +71,6 @@ public class LuceneSearchTest { noteSearchService.close(); } - @Test - public void canIndexNotebook() throws IOException { - // give - Note note1 = newNoteWithParagraph("Notebook1", "test"); - Note note2 = newNoteWithParagraph("Notebook2", "not test"); - List<Note> notebook = Arrays.asList(note1, note2); - - // when - noteSearchService.addIndexDocs(notebook); - } - // @Test public void canIndexAndQuery() throws IOException, InterruptedException { // given @@ -116,11 +105,11 @@ public class LuceneSearchTest { } @Test - public void canIndexAndQueryByParagraphTitle() throws IOException { + public void canIndexAndQueryByParagraphTitle() throws IOException, InterruptedException { // given Note note1 = newNoteWithParagraph("Notebook1", "test", "testingTitleSearch"); Note note2 = newNoteWithParagraph("Notebook2", "not test", "notTestingTitleSearch"); - noteSearchService.addIndexDocs(Arrays.asList(note1, note2)); + noteSearchService.drainEvents(); // when List<Map<String, String>> results = noteSearchService.query("testingTitleSearch"); @@ -163,11 +152,11 @@ public class LuceneSearchTest { } @Test - public void canIndexAndReIndex() throws IOException { + public void canIndexAndReIndex() throws IOException, InterruptedException { // given Note note1 = newNoteWithParagraph("Notebook1", "test"); Note note2 = newNoteWithParagraphs("Notebook2", "not test", "not test at all"); - noteSearchService.addIndexDocs(Arrays.asList(note1, note2)); + noteSearchService.drainEvents(); // when Paragraph p2 = note2.getLastParagraph();
