Use a new encoder for each csv writer to avoid concurrency problems.

uwescience · Mar 10, 2014 · 178fa9b · 178fa9b
1 parent b951ed4
commit 178fa9b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/edu/washington/escience/myria/CsvTupleWriter.java b/src/edu/washington/escience/myria/CsvTupleWriter.java
@@ -6,6 +6,7 @@
 import java.io.OutputStreamWriter;
 import java.util.List;
 
+import org.supercsv.encoder.DefaultCsvEncoder;
 import org.supercsv.io.CsvListWriter;
 import org.supercsv.prefs.CsvPreference;
 
@@ -47,7 +48,7 @@ public CsvTupleWriter(final OutputStream out) {
   public CsvTupleWriter(final char separator, final OutputStream out) {
     final CsvPreference separatorPreference =
         new CsvPreference.Builder(Character.toChars(CsvPreference.STANDARD_PREFERENCE.getQuoteChar())[0], separator,
-            CsvPreference.STANDARD_PREFERENCE.getEndOfLineSymbols()).build();
+            CsvPreference.STANDARD_PREFERENCE.getEndOfLineSymbols()).useEncoder(new DefaultCsvEncoder()).build();
     csvWriter = new CsvListWriter(new BufferedWriter(new OutputStreamWriter(out)), separatorPreference);
   }