false, false, false, false,
>>> false, false, false
>>> , false, false, false, false, false, false, false)
>>> .types(String.class, Long.class, Double.class, Double.class)
>>> .map(new TuplePointConverter());
>>>
;
>> http://data.gdeltproject.org/events/index.html
>>
>> 2015-05-13 13:09 GMT+02:00 Pa Rö :
>>
>>> hi,
>>>
>>> i read a csv file from disk with flink (java, maven version 8.1) and get
>>> the following exception:
>>>
>>
2015-05-13 13:09 GMT+02:00 Pa Rö :
> hi,
>
> i read a csv file from disk with flink (java, maven version 8.1) and get the
> following exception:
>
> ERROR operators.DataSinkTask: Error in user code: Channel received an event
> before completing the curr
> i read a csv file from disk with flink (java, maven version 8.1) and get
>> the following exception:
>>
>> ERROR operators.DataSinkTask: Error in user code: Channel received an
>> event before completing the current partial record.: DataSink(Print to
>> System.out)
ERROR operators.DataSinkTask: Error in user code: Channel received an
> event before completing the current partial record.: DataSink(Print to
> System.out) (4/4)
> java.lang.IllegalStateException: Channel received an event before
> completing the current partial record.
>
hi,
i read a csv file from disk with flink (java, maven version 8.1) and get
the following exception:
ERROR operators.DataSinkTask: Error in user code: Channel received an event
before completing the current partial record.: DataSink(Print to
System.out) (4/4)
java.lang.IllegalStateException
