Hi Rinat,
Savepoint need to be triggered when you want to create point in time which you
want to use in future to revert back your state, also you could cancel job with
savepoint which makes sure that you won’t lose any data during canceling job.
About your question that flink delete metadata f
Hi Papadopoulos,
Unfortunately no, there is no DELETE or MODIFY queries, you should create new
table as a result of query which will filter records from existing one
From: Papadopoulos, Konstantinos
Sent: Tuesday, May 28, 2019 5:25 PM
To: user@flink.apache.org
Subject: Flink SQL: Execute DELETE
Hi there,
I faced with issue in adding file to distributed cache in Flink.
My setup:
- Java 1.8
- Flink 1.8
- OS: Windows, Linux
Test scenario:
1. Create simple stream environment
2. Add to distributed cache local file
3. Add simple source functio
