Re: How to run table api in 1.1-SNAPSHOT

Hi Cody, could it be you're getting this error because you've named a SQL table column "count"? Can you try renaming it to "myCount" or something else? I think the parser recognizes the aggregate function instead :) Cheers, -V. On Jun 2, 2016 1:56 PM, "Cody Innowhere" wrote: > Hi guys, > I'm tr

[jira] [Created] (FLINK-4025) Add possiblity for the RMQ Streaming Source to customize the queue

Dominik Bruhn created FLINK-4025: Summary: Add possiblity for the RMQ Streaming Source to customize the queue Key: FLINK-4025 URL: https://issues.apache.org/jira/browse/FLINK-4025 Project: Flink

[jira] [Created] (FLINK-4024) FileSourceFunction not adjusted to new IF lifecycle

Chesnay Schepler created FLINK-4024: --- Summary: FileSourceFunction not adjusted to new IF lifecycle Key: FLINK-4024 URL: https://issues.apache.org/jira/browse/FLINK-4024 Project: Flink Issue

[jira] [Created] (FLINK-4023) Move Kafka consumer partition discovery from constructor to open()

Michal Harish created FLINK-4023: Summary: Move Kafka consumer partition discovery from constructor to open() Key: FLINK-4023 URL: https://issues.apache.org/jira/browse/FLINK-4023 Project: Flink

[jira] [Created] (FLINK-4022) Partition discovery / regex topic subscription for the Kafka consumer

Tzu-Li (Gordon) Tai created FLINK-4022: -- Summary: Partition discovery / regex topic subscription for the Kafka consumer Key: FLINK-4022 URL: https://issues.apache.org/jira/browse/FLINK-4022 Proje