Ok, I tested it and it works on the same example. :) 2016-05-11 12:25 GMT+02:00 Vasiliki Kalavri <vasilikikala...@gmail.com>:
> Hi Simone, > > Fabian has pushed a fix for the streaming TableSources that removed the > Calcite Stream rules [1]. > The reported error does not appear anymore with the current master. Could > you please also give it a try and verify that it works for you? > > Thanks, > -Vasia. > > [1]: > https://github.com/apache/flink/commit/7ed07933d2dd3cf41948287dc8fd79dbef902311 > > On 4 May 2016 at 17:33, Vasiliki Kalavri <vasilikikala...@gmail.com> > wrote: > >> 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.robu...@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) >>> >>> >>> >
