Hi,

how are you executing your code? From an IDE or on a running Flink instance?
If you execute it on a running Flink instance, you have to look into the
.out files of the task managers (located in ./log/).

Best, Fabian


2016-10-06 22:08 GMT+02:00 drystan mazur <drystan.ma...@gmail.com>:

> Hello I am reading a csv file with flink 1.1.2 the file loads and runs but
> printi= ng shows nothing ? TupleCsvInputFormat oilDataIn;
> TupleTypeInfo<Tuple9<String,String,String, String,String,String,
> String,String,String>> oildataTypes; BasicTypeInfo[] types =3D
> {BasicTypeInfo.STRING_TYPE_INFO,BasicTypeIn= fo.STRING_TYPE_INFO,
> BasicTypeInfo.STRING_TYPE_INFO, BasicTypeInfo.STRING_TYPE_
> INFO,BasicTypeInfo.STRING_TYPE_INFO= ,BasicTypeInfo.STRING_TYPE_INFO,
> BasicTypeInfo.STRING_TYPE_INFO,BasicTypeInfo.STRING_TYPE_INFO=
> ,BasicTypeInfo.STRING_TYPE_INFO}; oildataTypes =3D new
> TupleTypeInfo<>(types); oilDataIn =3D new 
> TupleCsvInputFormat<>(oilPath,"\n",",",oildataTypes=
> ); oilDataStream =3D env.createInput(oilDataIn,new TupleTypeInfo(Tuple9.=
> class, types)); oilDataStream.print(); env.execute("Flink Java API
> Skeleton"); The code runs ok I just wanted to view the datastream what I
> am doing wrong= ? Thanks
> ------------------------------
> View this message in context: Csv data stream
> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Csv-data-stream-tp9375.html>
> Sent from the Apache Flink User Mailing List archive. mailing list archive
> <http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/> at
> Nabble.com.
>

Reply via email to