Skip to content

Commit 178fa9b

Browse files
committed
Use a new encoder for each csv writer to avoid concurrency problems.
1 parent b951ed4 commit 178fa9b

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

src/edu/washington/escience/myria/CsvTupleWriter.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,7 @@
66
import java.io.OutputStreamWriter;
77
import java.util.List;
88

9+
import org.supercsv.encoder.DefaultCsvEncoder;
910
import org.supercsv.io.CsvListWriter;
1011
import org.supercsv.prefs.CsvPreference;
1112

@@ -47,7 +48,7 @@ public CsvTupleWriter(final OutputStream out) {
4748
public CsvTupleWriter(final char separator, final OutputStream out) {
4849
final CsvPreference separatorPreference =
4950
new CsvPreference.Builder(Character.toChars(CsvPreference.STANDARD_PREFERENCE.getQuoteChar())[0], separator,
50-
CsvPreference.STANDARD_PREFERENCE.getEndOfLineSymbols()).build();
51+
CsvPreference.STANDARD_PREFERENCE.getEndOfLineSymbols()).useEncoder(new DefaultCsvEncoder()).build();
5152
csvWriter = new CsvListWriter(new BufferedWriter(new OutputStreamWriter(out)), separatorPreference);
5253
}
5354

0 commit comments

Comments
 (0)