Re: FlinkSQL Sinks

2021-09-15 Thread JING ZHANG
Hi, I agree with Martijn. Besides, there is an example in SQL client documentation[1] which contain an external sink instead of print sink. > Flink SQL> CREATE TABLE pageviews (> user_id BIGINT,> page_id BIGINT,> > viewtime TIMESTAMP,> proctime AS PROCTIME()> ) WITH (> 'connector' = >

Re: FlinkSQL Sinks

2021-09-15 Thread Martijn Visser
Hi, You can do this directly via the SQL client by defining (for example Kafka) as a TABLE [1] and using an INSERT INTO [2]. Best regards, Martijn [1] https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/connectors/table/kafka/ [2] https://ci.apache.org/projects/flink/flink-docs-re

FlinkSQL Sinks

2021-09-15 Thread Pedro Silva
Hello, Is it possible to configure a sink for sql client queries other than the terminal/stdout? Looking at the SQL Client Configuration , it seems that the output of the client is always to