Hi,
*> Could you give an example that the query has a unique key?*
Consider the following sql:
SELECT a, SUM(b) as d
> FROM Orders
> GROUP BY a
The result table contains unique key of a. A document about Streaming
Concepts[1] may be helpful for you.
*> What is the mechanism flink infer which
Hi Fabian,
Could you give an example that the query has a unique key?
What is the mechanism flink infer which field is the unique key(s)?
Thanks a lot!
Best, Henry
> 在 2018年8月11日，上午5:21，Fabian Hueske 写道：
>
> Hi Henry,
>
> The problem is that the table that results from
Hi Henry,
The problem is that the table that results from the query does not have a
unique key.
You can only use an upsert sink if the table has a (composite) unique key.
Since this is not the case, you cannot use upsert sink.
However, you can implement a StreamRetractionTableSink which allows to
Hi All,
I am using flink 1.6 to generate some realtime programs. I want to
write the output to table sink, the code is as below. At first I use append
table sink, which error message tells me that I should use upsert table sink,
so I write one. But still another error “Caused by:
org.ap
