Thanks for the feedback!
Fabian
2018-03-23 8:02 GMT+01:00 James Yu :
> Hi,
>
> When I proceed further to timePrediction exercise (http://training.data-
> artisans.com/exercises/timePrediction.html), I realize that the
> nycTaxiRides.gz's
> format is fine.
> The problem is in TaxiRide.toString()
Hi,
When I proceed further to timePrediction exercise (
http://training.data-artisans.com/exercises/timePrediction.html), I realize
that the nycTaxiRides.gz's format is fine.
The problem is in TaxiRide.toString(), the columns were serialized in wrong
order. Hence the data persisted in Kafka has wr
Just figured out the data format in nycTaxiRides.gz doesn't match to the
way TaxiRide.java interpreting the lines fed into it.
Then I check the exercise training github and found the TaxiRide.java (
https://github.com/dataArtisans/flink-training-exercises/tree/master/src/main/java/com/dataartisans/
Hi,
I fail to run the PopularPlacesFromKafka example with the following
exception, and I wonder what might cause this "Invalid record" error?
when running within Intellij IDEA -->
07:52:23.960 [Source: Custom Source -> Map (7/8)] INFO
org.apache.flink.runtime.taskmanager.Task - Source: Custom S
