From 178fa9b8e3db9f9090f7ec87c036c6e94f5210a7 Mon Sep 17 00:00:00 2001 From: Dominik Moritz Date: Mon, 10 Mar 2014 14:22:44 -0700 Subject: [PATCH] Use a new encoder for each csv writer to avoid concurrency problems. --- src/edu/washington/escience/myria/CsvTupleWriter.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/edu/washington/escience/myria/CsvTupleWriter.java b/src/edu/washington/escience/myria/CsvTupleWriter.java index f34295b7c..2f3d433b5 100644 --- 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); }