Hi,
one question - it seems that "barriers" are perfectly supported by Flink,
but not yet supported in Flink SQL.
When I e.g. do a UNION of two views derived from one source table fed by
Kafka, I get thousands of intermediate results which are incorrect (the
example I am using is this one:
Hi,
I am stumbling on the next Flink SQL problem - but I am sure you can help
me :)
I have an extremely simple table called "bla" which just has one column of
type double. Now I want to sink that table into a Kafka topic. This is how
I do it:
CREATE TABLE bla_sink (
total DOUBLE,
PRIMARY KEY
Hi,
I am trying to run FlinkSQL (through sql-client.sh) and read messages from
Kafka topics.
I downloaded 1.17.1 and extracted it. For the Kafka connectivity, I've
added flink-sql-connector-kafka-1.1.7.jar, flink-connector-kafka-1.1.7.jar
and kafka-clients-2.8.1.jar and now start the
