Re: Bug while using Table API

Good to know :) On 12 May 2016 at 11:16, Simone Robutti wrote: > Ok, I tested it and it works on the same example. :) > > 2016-05-11 12:25 GMT+02:00 Vasiliki Kalavri : > >> Hi Simone, >> >> Fabian has pushed a fix for the streaming

Re: Bug while using Table API

Ok, I tested it and it works on the same example. :) 2016-05-11 12:25 GMT+02:00 Vasiliki Kalavri : > 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

Re: Bug while using Table API

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]:

Re: Bug while using Table API

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" wrote: > Here is the code: > > package org.example > > import org.apache.flink.api.scala._ > import

Re: Bug while using Table API

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 =

Re: Bug while using Table API

Hi Simone, I tried reproducing your problem with no luck. I ran the WordCountTable example using sbt quickstart with Flink 1.1-SNAPSHOT and Scala 2.10 and it worked fine. Can you maybe post the code you tried? Thanks, -Vasia. On 4 May 2016 at 11:20, Simone Robutti