Re: Cancel flink job occur exception.

2018-09-08 Thread Gary Yao
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

[jira] [Created] (FLINK-10308) remove docker folder

2018-09-08 Thread Nicos Maris (JIRA)
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

[jira] [Created] (FLINK-10307) instruct users to email us with proper code snippets

2018-09-08 Thread Nicos Maris (JIRA)
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

Elasticsearch InputFormat

2018-09-08 Thread Michael Gendelman
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

[jira] [Created] (FLINK-10306) Support the display of log file from any position on webUI

2018-09-08 Thread Jiayi Liao (JIRA)
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