[jira] [Created] (FLINK-7970) SlotPool support batch allocating slots

shuai.xu created FLINK-7970: --- Summary: SlotPool support batch allocating slots Key: FLINK-7970 URL: https://issues.apache.org/jira/browse/FLINK-7970 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7969) Resource manager support batch request slots

shuai.xu created FLINK-7969: --- Summary: Resource manager support batch request slots Key: FLINK-7969 URL: https://issues.apache.org/jira/browse/FLINK-7969 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New committer: Haohui Mai

Thanks very much. I feel very happy and look forward to continuing the contributing to Flink. ~Haohui On Thu, Nov 2, 2017 at 1:21 PM Greg Hogan wrote: > Welcome, Haohui! > > > > On Nov 1, 2017, at 4:14 AM, Fabian Hueske wrote: > > > > Hi everybody, > >

Re: [ANNOUNCE] New committer: Haohui Mai

Welcome, Haohui! > On Nov 1, 2017, at 4:14 AM, Fabian Hueske wrote: > > Hi everybody, > > On behalf of the PMC I am delighted to announce Haohui Mai as a new Flink > committer! > > Haohui has been an active member of our community for several months. > Among other things,

[jira] [Created] (FLINK-7968) Deduplicate serializer classes between runtime and queryable state

Stephan Ewen created FLINK-7968: --- Summary: Deduplicate serializer classes between runtime and queryable state Key: FLINK-7968 URL: https://issues.apache.org/jira/browse/FLINK-7968 Project: Flink

Re: [ANNOUNCE] Flink 1.4 feature-freeze date and release burn-down

Hi, Yes, we're actually a bit late. There is one last critical thing that I would like to fix before cutting the branch: https://issues.apache.org/jira/browse/FLINK-7420 . And a scheduling bug that Till already fixed and is about to be merged.

Re: [ANNOUNCE] Flink 1.4 feature-freeze date and release burn-down

Hi Aljoscha, Thank you for taking on the releasing branch work! I'm wondering what's the status of it? And when will we open master branch for PRs of 1.5 features? Thanks! Bowen On Thu, Oct 19, 2017 at 2:17 AM, Aljoscha Krettek wrote: > Hi Everyone, > > It seems

[jira] [Created] (FLINK-7966) Create flink-connector-kafka-1.0 submodule

Ted Yu created FLINK-7966: - Summary: Create flink-connector-kafka-1.0 submodule Key: FLINK-7966 URL: https://issues.apache.org/jira/browse/FLINK-7966 Project: Flink Issue Type: Improvement

Re: [ANNOUNCE] New committer: Haohui Mai

Congratulations! > On Nov 2, 2017, at 9:12 AM, Matthias J. Sax wrote: > > -BEGIN PGP SIGNED MESSAGE- > Hash: SHA512 > > Congrats! > > On 11/1/17 9:40 PM, Dawid Wysakowicz wrote: >> Congratulations! >> >> 01.11.2017 7:45 PM "Stephan Ewen"

[jira] [Created] (FLINK-7965) Docker-Flink: TaskManagers can't find JobManager when in different nodes in Docker Swarm

Thalita Vergilio created FLINK-7965: --- Summary: Docker-Flink: TaskManagers can't find JobManager when in different nodes in Docker Swarm Key: FLINK-7965 URL: https://issues.apache.org/jira/browse/FLINK-7965

[jira] [Created] (FLINK-7964) Add Apache Kafka 1.0.0 connector

Hai Zhou UTC+8 created FLINK-7964: - Summary: Add Apache Kafka 1.0.0 connector Key: FLINK-7964 URL: https://issues.apache.org/jira/browse/FLINK-7964 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-7963) Add ability to call trigger savepoint on flink cluster shutdown

Rinat Sharipov created FLINK-7963: - Summary: Add ability to call trigger savepoint on flink cluster shutdown Key: FLINK-7963 URL: https://issues.apache.org/jira/browse/FLINK-7963 Project: Flink

Re: [ANNOUNCE] New committer: Haohui Mai

-BEGIN PGP SIGNED MESSAGE- Hash: SHA512 Congrats! On 11/1/17 9:40 PM, Dawid Wysakowicz wrote: > Congratulations! > > 01.11.2017 7:45 PM "Stephan Ewen" napisał(a): > >> Congrats and welcome! >> >> On Wed, Nov 1, 2017 at 6:47 PM, Chen Qin >>

Re: Get Window Time

@Kostas, could you maybe have a look? The title says "window" but it's actually about CEP. > On 2. Nov 2017, at 07:33, Erdem erdfem wrote: > > FlinkKafkaConsumer010 myConsumer = new > FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(), >

Re: Get Window Time

FlinkKafkaConsumer010 myConsumer = new FlinkKafkaConsumer010<>("demo", new JSONDeserializationSchema(), properties); DataStream dataStream = env.addSource(myConsumer); dataStream.windowAll(SlidingEventTimeWindows.of(Time.hours(1), Time.minutes(1)))