#x27;s the case I wonder
if we could make those changes into KafkaTableSource to make it more
generic.
On Wed, May 24, 2017 at 12:23 PM, enrico canzonieri
wrote:
> Hi Timo, thanks for your help!
>
> I tried to follow the examples in the tests but I still have the same
> issue.
>
octime" to
> your table schema definition.
>
> You can find some examples here:
> https://github.com/apache/flink/blob/master/flink-
> libraries/flink-table/src/test/scala/org/apache/flink/
> table/runtime/datastream/TimeAttributesITCase.scala
>
> If you have further ques
Hi,
I'm trying to window and groupBy a stream using the table api, but I get
ValidationException in the windowing function.
Here is the relevant code:
tableEnv.registerTableSource(schema.getName, src)
val table = tableEnv.scan(schema.getName)
val t = table.window(Tumble over 1.minutes on 'time as
