Flink ParserError NUMERIC_VALUE_ILLEGAL_CHARACTER - PullRequest
Новая
       7

Flink ParserError NUMERIC_VALUE_ILLEGAL_CHARACTER

0 голосов
/ 17 февраля 2019 
DataSet<Tuple3<Integer, Integer, Integer>> text1 = env.readCsvFile("/home/maple/Downloads/2.18.0_rc2/dbgen/lineitem.csv")
            .includeFields("1110000000000000")
            .types(Integer.class, Integer.class, Integer.class);

Это csv-файл, автоматически сгенерированный dbgen. Должно быть исключение 

Caused by: org.apache.flink.api.common.io.ParseException: Line could not be parsed: '149924|9005|292|6|37|33818.00|0.08|0.02|A|F|1994-12-14|1995-01-16|1994-12-15|TAKE BACK RETURN|RAIL|xcuses across the fina'
ParserError NUMERIC_VALUE_ILLEGAL_CHARACTER 
Expect field types: class java.lang.Integer, class java.lang.Integer, class java.lang.Integer 
in file: /home/maple/Downloads/2.18.0_rc2/dbgen/lineitem.csv

Почему

Кстати, я не могу написать .includeFields("1110000000000000"), если мне нужно толькопервые три столбца?

1 Ответ

0 голосов
/ 17 февраля 2019

evn.readCsvFile() возвращает CsvReader.Я предполагаю, что исключением является то, что вы не установили строку разделителя равной "|", а разделитель по умолчанию - ",".

...