Mailing-List: contact user-help@flink.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@flink.apache.org
MIME-Version: 1.0
In-Reply-To: <1475784539621-9375.post@n4.nabble.com>
References: <1475784539621-9375.post@n4.nabble.com>
From: Fabian Hueske <fhueske@gmail.com>
Date: Thu, 6 Oct 2016 22:31:06 +0200
Message-ID: <CAAdrtT1q8gM8XBO3jcqAM2bwKP-7r9SgH1hc=rUVYs7n16a-ug@mail.gmail.com>
Subject: Re: Csv data stream
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=047d7b6dc5d02e3a48053e382e35
archived-at: Thu, 06 Oct 2016 20:31:50 -0000

--047d7b6dc5d02e3a48053e382e35
Content-Type: text/plain; charset=UTF-8

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.mazur@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.
>

--047d7b6dc5d02e3a48053e382e35
Content-Type: text/html; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr"><div><div><div><div>Hi,<br><br></div>how are you executing=
 your code? From an IDE or on a running Flink instance?<br></div>If you exe=
cute it on a running Flink instance, you have to look into the .out files o=
f the task managers (located in ./log/).<br><br></div>Best, Fabian<br><br><=
/div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quote">2016-1=
0-06 22:08 GMT+02:00 drystan mazur <span dir=3D"ltr">&lt;<a href=3D"mailto:=
drystan.mazur@gmail.com" target=3D"_blank">drystan.mazur@gmail.com</a>&gt;<=
/span>:<br><blockquote class=3D"gmail_quote" style=3D"margin:0 0 0 .8ex;bor=
der-left:1px #ccc solid;padding-left:1ex">Hello

I am reading a csv file with flink 1.1.2 the file loads and runs but printi=
=3D ng shows nothing ?

<code>
      TupleCsvInputFormat oilDataIn;

      TupleTypeInfo&lt;Tuple9&lt;String,<wbr>String,String,
                      String,String,String,
                      String,String,String&gt;&gt; oildataTypes;

      BasicTypeInfo[] types =3D3D {BasicTypeInfo.STRING_TYPE_<wbr>INFO,Basi=
cTypeIn=3D
fo.STRING_TYPE_INFO,<wbr>BasicTypeInfo.STRING_TYPE_<wbr>INFO,
              BasicTypeInfo.STRING_TYPE_<wbr>INFO,BasicTypeInfo.STRING_<wbr=
>TYPE_INFO=3D
,BasicTypeInfo.STRING_TYPE_<wbr>INFO,
              BasicTypeInfo.STRING_TYPE_<wbr>INFO,BasicTypeInfo.STRING_<wbr=
>TYPE_INFO=3D
,BasicTypeInfo.STRING_TYPE_<wbr>INFO};

      oildataTypes =3D3D new TupleTypeInfo&lt;&gt;(types);
      oilDataIn =3D3D new TupleCsvInputFormat&lt;&gt;(oilPath,<wbr>&quot;\n=
&quot;,&quot;,&quot;,oildataTypes=3D
);


      oilDataStream =3D3D env.createInput(oilDataIn,new TupleTypeInfo(Tuple=
9.=3D class, types));
      oilDataStream.print();


env.execute(&quot;Flink Java API Skeleton&quot;);
</code>


The code runs ok I just wanted to view the datastream what I am doing wrong=
=3D  ?

Thanks


=09
=09
=09
<br><hr width=3D"300" align=3D"left">
View this message in context: <a href=3D"http://apache-flink-user-mailing-l=
ist-archive.2336050.n4.nabble.com/Csv-data-stream-tp9375.html" target=3D"_b=
lank">Csv data stream</a><br>
Sent from the <a href=3D"http://apache-flink-user-mailing-list-archive.2336=
050.n4.nabble.com/" target=3D"_blank">Apache Flink User Mailing List archiv=
e. mailing list archive</a> at Nabble.com.<br></blockquote></div><br></div>

--047d7b6dc5d02e3a48053e382e35--