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) >> >> >>
