Good to know :) On 12 May 2016 at 11:16, Simone Robutti <simone.robu...@radicalbit.io> wrote:
> 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) >>>> >>>> >>>> >> >
