calcite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jh...@apache.org
Subject [2/3] calcite git commit: Remove race condition in CsvTest
Date Fri, 08 Jul 2016 18:51:48 GMT
Remove race condition in CsvTest


Project: http://git-wip-us.apache.org/repos/asf/calcite/repo
Commit: http://git-wip-us.apache.org/repos/asf/calcite/commit/5bc0e0e5
Tree: http://git-wip-us.apache.org/repos/asf/calcite/tree/5bc0e0e5
Diff: http://git-wip-us.apache.org/repos/asf/calcite/diff/5bc0e0e5

Branch: refs/heads/master
Commit: 5bc0e0e536bd12d8c1551271097af229e68c88c6
Parents: d9eb438
Author: Julian Hyde <jhyde@apache.org>
Authored: Thu Jul 7 23:41:55 2016 -0700
Committer: Julian Hyde <jhyde@apache.org>
Committed: Thu Jul 7 23:44:51 2016 -0700

----------------------------------------------------------------------
 example/csv/src/test/java/org/apache/calcite/test/CsvTest.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/calcite/blob/5bc0e0e5/example/csv/src/test/java/org/apache/calcite/test/CsvTest.java
----------------------------------------------------------------------
diff --git a/example/csv/src/test/java/org/apache/calcite/test/CsvTest.java b/example/csv/src/test/java/org/apache/calcite/test/CsvTest.java
index 353758a..dbb52d5 100644
--- a/example/csv/src/test/java/org/apache/calcite/test/CsvTest.java
+++ b/example/csv/src/test/java/org/apache/calcite/test/CsvTest.java
@@ -554,9 +554,9 @@ public class CsvTest {
 
       // Add some rows so that the table can deduce its row type.
       final Iterator<String> lines = Arrays.asList(strings).iterator();
-      worker.queue.put(writeLine(pw, lines.next())); // header
+      pw.println(lines.next()); // header
+      pw.flush();
       worker.queue.put(writeLine(pw, lines.next())); // first row
-      worker.queue.put(sleep(10));
       worker.queue.put(writeLine(pw, lines.next())); // second row
       final CalciteConnection calciteConnection =
           connection.unwrap(CalciteConnection.class);


Mime
View raw message