Re: [DISCUSS] Flink 1.6 features

2018-06-16 Thread Elias Levy
One more, since it we have to deal with it often: - Idling sources (Kafka in particular) and proper watermark propagation: FLINK-5018 / FLINK-5479 On Fri, Jun 8, 2018 at 2:58 PM, Elias Levy wrote: > Since wishes are free: > > - Standalone cluster job isolation: https://issues. > apache.org/jira

Re: v1.5 cancel job rest API

2018-06-16 Thread Dawid Wysakowicz
Hi Jake, Are you using legacy mode? Or do you use the new default mode? If you use the new mode the API was restructured and you should use the new API (cancel is PATCH to /jobs/:jobid). By the way we have CI/CD for these. Best, Dawid On 16/06/18 21:47, Jake Croft wrote: > This did not work, re

v1.5 cancel job rest API

2018-06-16 Thread Jake Croft
This did not work, returns 404: Cancel Job DELETE request to /jobs/:jobid/cancel. Apache Flink 1.5 Documentation: Monitoring REST API

[jira] [Created] (FLINK-9603) Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException)

2018-06-16 Thread Rinat Sharipov (JIRA)
Rinat Sharipov created FLINK-9603: - Summary: Incorrect indexing of part files, when part suffix is specified (FileAlreadyExistsException) Key: FLINK-9603 URL: https://issues.apache.org/jira/browse/FLINK-9603

[jira] [Created] (FLINK-9602) Extend CommonOption section

2018-06-16 Thread Chesnay Schepler (JIRA)
Chesnay Schepler created FLINK-9602: --- Summary: Extend CommonOption section Key: FLINK-9602 URL: https://issues.apache.org/jira/browse/FLINK-9602 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-9601) Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY

2018-06-16 Thread Sihua Zhou (JIRA)
Sihua Zhou created FLINK-9601: - Summary: Snapshot of CopyOnWriteStateTable will failed, when the amount of record is more than MAXIMUM_CAPACITY Key: FLINK-9601 URL: https://issues.apache.org/jira/browse/FLINK-9601

Re: [TABLE][SQL] Unify UniqueKeyExtractor and DataStreamRetractionRules

2018-06-16 Thread Hequn Cheng
Hi Piotr :-) I think it is better to make rules orthogonal. Each rule focuses on an independent optimization. The rest we need to do is to pass our rules to HEP planner or VOLCANO planner to get a final plan. On Wed, Jun 13, 2018 at 5:48 PM, Piotr Nowojski wrote: > Hi, > > Maybe this boils dow