Hi,
the problem is that Flink is trying to parse the input data as CSV, but
there seem to be rows in the data which do not conform to the specified
schema.
On Thu, Jun 18, 2015 at 12:51 PM, hagersaleh
wrote:
> when run progrm on big data customer 2.5GB orders 5GB disply error
when run progrm on big data customer 2.5GB orders 5GB disply error why
DataSource (at getCustomerDataSet(TPCHQuery3.java:252)
(org.apache.flink.api.java.io.CsvInputFormat)) (1/1) switched to FAILED
org.apache.flink.api.common.io.ParseException: Row too short:
1499|Customer#01499
