Re: Csv data stream

[Fabian Hueske-2]

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 <[hidden email]>:

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
Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.

[drystan mazur]

Hi Fabian,
I am running on a IDE and the code runs all ok just no output from the datastream
Thanks