[Discuss] adding a new command line argument -sd/--savepointdirectory

Hi guys, I want to start on discussion on FLINK-7566 if there's only one checkpointing metadata file in , `flink run -s ` should resume from that metadata file. We need a way to programmatically start a Flink job from a checkpoint without having

[jira] [Created] (FLINK-7566) if there's only one checkpointing metadata file in , `flink run -s ` should resume from that metadata file

Bowen Li created FLINK-7566: --- Summary: if there's only one checkpointing metadata file in , `flink run -s ` should resume from that metadata file Key: FLINK-7566 URL: https://issues.apache.org/jira/browse/FLINK-7566

[jira] [Created] (FLINK-7565) Add support for HTTP 1.1 (Chunked transfer encoding) to Flink web UI

Robert Metzger created FLINK-7565: - Summary: Add support for HTTP 1.1 (Chunked transfer encoding) to Flink web UI Key: FLINK-7565 URL: https://issues.apache.org/jira/browse/FLINK-7565 Project: Flink

Re: [DISCUSS] Flink 1.4 and time based release

+1 for that, as long we will be consistent with it :) > On Aug 31, 2017, at 12:22 PM, Aljoscha Krettek wrote: > > +1 On using "Fix Version" for that. I always try to use that already for > things that need fixing in the next release. Also "Blocker" is a thing there. > >> On 30. Aug 2017, at 20

[jira] [Created] (FLINK-7564) Fix Watermark semantics in Table API

Aljoscha Krettek created FLINK-7564: --- Summary: Fix Watermark semantics in Table API Key: FLINK-7564 URL: https://issues.apache.org/jira/browse/FLINK-7564 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-7563) Fix watermark semantics in CEP operators

Aljoscha Krettek created FLINK-7563: --- Summary: Fix watermark semantics in CEP operators Key: FLINK-7563 URL: https://issues.apache.org/jira/browse/FLINK-7563 Project: Flink Issue Type: Bug

Re: [DISCUSS] Watermark boundary condition

Hi, Excellent, thanks for pointing this out! The definition in Watermark.java, which is used by HeapInternalTimerService.java, WindowOperator.isWindowLate() and WindowOperator.isElementLate() and is also documented in [1] is the definitive (ha!) definition. I created Jira issues for fixing the

Re: [DISCUSS] Flink 1.4 and time based release

+1 On using "Fix Version" for that. I always try to use that already for things that need fixing in the next release. Also "Blocker" is a thing there. > On 30. Aug 2017, at 20:29, Eron Wright wrote: > > I definitely think the conversation must happen in the context of the > expected feature-set