From 2d1a368fd2bb455b7bec909f0cdd4f44a86ad1dc Mon Sep 17 00:00:00 2001 From: Marco Ziccardi Date: Mon, 4 Jan 2016 19:48:08 +0100 Subject: [PATCH] Wait for table to be created in testInsertAllWithSuffix --- .../java/com/google/gcloud/bigquery/ITBigQueryTest.java | 9 +++++++-- 1 file changed, 7 insertions(+), 2 deletions(-) diff --git a/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java b/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java index 34f4f6893187..c07aa9f05f4c 100644 --- a/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java +++ b/gcloud-java-bigquery/src/test/java/com/google/gcloud/bigquery/ITBigQueryTest.java @@ -476,7 +476,7 @@ public void testInsertAll() { } @Test - public void testInsertAllWithSuffix() { + public void testInsertAllWithSuffix() throws InterruptedException { String tableName = "test_insert_all_with_suffix_table"; BaseTableInfo tableInfo = TableInfo.of(TableId.of(DATASET, tableName), TABLE_SCHEMA); assertNotNull(bigquery.create(tableInfo)); @@ -505,7 +505,12 @@ public void testInsertAllWithSuffix() { assertFalse(response.hasErrors()); assertEquals(0, response.insertErrors().size()); String newTableName = tableName + "_suffix"; - assertNotNull(bigquery.getTable(DATASET, newTableName, TableOption.fields())); + BaseTableInfo suffixTable = bigquery.getTable(DATASET, newTableName, TableOption.fields()); + while (suffixTable == null) { + Thread.sleep(1000L); + suffixTable = bigquery.getTable(DATASET, newTableName, TableOption.fields()); + } + assertNotNull(suffixTable); assertTrue(bigquery.delete(TableId.of(DATASET, tableName))); assertTrue(bigquery.delete(TableId.of(DATASET, newTableName))); }