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: <CACDjLVj9e5yX3fqO6mhXb6Jw2M+pxdCJJrz_uCha3j=SHKr5DQ@mail.gmail.com>
References: <CACDjLVg5EAjXpwS1MNi3mcBLn7-7HurFZY70D2k7TVPSAPcEKg@mail.gmail.com>
	<CAJZ2dcUp2dmxqmOCVVYqc0PVwJ-ve4TBVJwLiWT+XjyG+ParDw@mail.gmail.com>
	<CACDjLVj9e5yX3fqO6mhXb6Jw2M+pxdCJJrz_uCha3j=SHKr5DQ@mail.gmail.com>
Date: Wed, 4 May 2016 17:33:24 +0200
Message-ID: <CAJZ2dcXOoRgYeXAY5+47v7fc=8vHzB1NURuBV_ioXkHQy96KNQ@mail.gmail.com>
Subject: Re: Bug while using Table API
From: Vasiliki Kalavri <vasilikikalavri@gmail.com>
To: user@flink.apache.org
Content-Type: multipart/alternative; boundary=001a11c25af84ed6dd053205f2c3
archived-at: Wed, 04 May 2016 15:49:21 -0000

--001a11c25af84ed6dd053205f2c3
Content-Type: text/plain; charset=UTF-8

Thanks Simone! I've managed to reproduce the error. I'll try to figure out
what's wrong and I'll keep you updated.

-Vasia.
On May 4, 2016 3:25 PM, "Simone Robutti" <simone.robutti@radicalbit.io>
wrote:

> Here is the code:
>
> package org.example
>
> import org.apache.flink.api.scala._
> import org.apache.flink.api.table.TableEnvironment
>
> object Job {
>   def main(args: Array[String]) {
>     // set up the execution environment
>     val env = ExecutionEnvironment.getExecutionEnvironment
>     val tEnv = TableEnvironment.getTableEnvironment(env)
>
>
>     val input = env.fromElements(WC("hello", 1), WC("hello", 1),
> WC("ciao", 1))
>     val expr = tEnv.fromDataSet(input)
>     val result = expr
>       .groupBy("word")
>       .select("word , count.sum as count")
>     tEnv.toDataSet[WC](result).print()
>
>     env.execute("Flink Scala API Skeleton")
>   }
> }
>
> case class WC(word:String,count:Int)
>
>
>

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

<p dir=3D"ltr">Thanks Simone! I&#39;ve managed to reproduce the error. I=
9;ll try to figure out what&#39;s wrong and I&#39;ll keep you updated.</p>
<p dir=3D"ltr">-Vasia.</p>
<div class=3D"gmail_quote">On May 4, 2016 3:25 PM, &quot;Simone Robutti&quo=
t; &lt;<a href=3D"mailto:simone.robutti@radicalbit.io">simone.robutti@radic=
albit.io</a>&gt; wrote:<br type=3D"attribution"><blockquote class=3D"gmail_=
quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1=
ex"><div dir=3D"ltr"><div>Here is the code:</div><div><br></div><div>packag=
e org.example</div><div><br></div><div>import org.apache.flink.api.scala._<=
/div><div>import org.apache.flink.api.table.TableEnvironment</div><div><br>=
</div><div>object Job {</div><div>=C2=A0 def main(args: Array[String]) {</d=
iv><div>=C2=A0 =C2=A0 // set up the execution environment</div><div>=C2=A0 =
=C2=A0 val env =3D ExecutionEnvironment.getExecutionEnvironment</div><div>=
=C2=A0 =C2=A0 val tEnv =3D TableEnvironment.getTableEnvironment(env)</div><=
div><br></div><div><br></div><div>=C2=A0 =C2=A0 val input =3D env.fromEleme=
nts(WC(&quot;hello&quot;, 1), WC(&quot;hello&quot;, 1), WC(&quot;ciao&quot;=
, 1))</div><div>=C2=A0 =C2=A0 val expr =3D tEnv.fromDataSet(input)</div><di=
v>=C2=A0 =C2=A0 val result =3D expr</div><div>=C2=A0 =C2=A0 =C2=A0 .groupBy=
(&quot;word&quot;)</div><div>=C2=A0 =C2=A0 =C2=A0 .select(&quot;word , coun=
t.sum as count&quot;)</div><div>=C2=A0 =C2=A0 tEnv.toDataSet[WC](result).pr=
int()</div><div><br></div><div>=C2=A0 =C2=A0 env.execute(&quot;Flink Scala =
API Skeleton&quot;)</div><div>=C2=A0 }</div><div>}</div><div><br></div><div=
>case class WC(word:String,count:Int)</div><div><br></div><div><br></div></=
div>
</blockquote></div>

--001a11c25af84ed6dd053205f2c3--