Hi Devin,
If I understand you correctly, you are submitting a job in the YARN per-job
cluster mode. You are then invoking the "cancel with savepoint" command but
the client is not able to poll for the savepoint location before the cluster
shuts down.
I think your analysis is correct. As far as I
Nicos Maris created FLINK-10308:
---
Summary: remove docker folder
Key: FLINK-10308
URL: https://issues.apache.org/jira/browse/FLINK-10308
Project: Flink
Issue Type: Task
Components: Doc
Nicos Maris created FLINK-10307:
---
Summary: instruct users to email us with proper code snippets
Key: FLINK-10307
URL: https://issues.apache.org/jira/browse/FLINK-10307
Project: Flink
Issue Type
Hi all,
I have a workload where I need to read and transform large amounts of data
from Elasticsearch. I'm currently using Flink only for streaming but I
though that it can also be a good fit for this kind of batch job.
However, I did not find a way to load data from Elasticsearch in parallel
to F
Jiayi Liao created FLINK-10306:
--
Summary: Support the display of log file from any position on webUI
Key: FLINK-10306
URL: https://issues.apache.org/jira/browse/FLINK-10306
Project: Flink
Issue