In case there is no key fields in the query (e.g. in case of simple SELECT * FROM source) we will be constantly updating a single row.
I think in this case we should work in "append" mode to allow e.g. ETL case when we want to move data from one e.g. Kafka to ES. [ Full content available at: https://github.com/apache/flink/pull/6611 ] This message was relayed via gitbox.apache.org for devnull@infra.apache.org