Please take a look at the table api/SQL doc [1] below on how to register a
table/tablesource. Thanks.
[1]
https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/table/common.html#register-a-table
On Thu, May 31, 2018 at 6:22 AM, Radhya Sahal
wrote:
> Hi,
>
> Could you help me which is
Hi,
Could you help me which is the integrated versions of Java/Kafka/ Flink
which can work without errors.
I have a problem when I read streamed data from KafkaTableSource to table.
I use this command
tableEnv.registerDataStream("sensors", myKafkaTableSource)
But, there it doesn't run (i.
