[jira] [Created] (FLINK-10508) Port JobManagerITCase to new code base

2018-10-07 Thread tison (JIRA)
tison created FLINK-10508: - Summary: Port JobManagerITCase to new code base Key: FLINK-10508 URL: https://issues.apache.org/jira/browse/FLINK-10508 Project: Flink Issue Type: Sub-task Compo

Re: Enrich testing doc with more unit test examples using AbstractStreamOperator

2018-10-07 Thread Tony Wei
Hi all, Does anyone want to share something about how to provide more better testing tools or good documentations? @Till, @Aljoscha Do you have further suggestions about the improvements of testing tools and what is the next step we can do? Best, Tony Wei Tony Wei 於 2018年9月29日 週六 上午12:20寫道:

Sharing state between subtasks

2018-10-07 Thread Thomas Weise
I'm looking to implement a state sharing mechanism between subtasks (of one or multiple tasks). Our use case is to align watermarks between subtasks of one or multiple sources to prevent some data fetchers to race ahead of others and cause massive state buffering in Flink. Each subtask would share

[jira] [Created] (FLINK-10507) Set target parallelism to maximum when using the standalone job cluster mode

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10507: - Summary: Set target parallelism to maximum when using the standalone job cluster mode Key: FLINK-10507 URL: https://issues.apache.org/jira/browse/FLINK-10507 Projec

[jira] [Created] (FLINK-10506) Introduce minimum, target and maximum parallelism to JobGraph

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10506: - Summary: Introduce minimum, target and maximum parallelism to JobGraph Key: FLINK-10506 URL: https://issues.apache.org/jira/browse/FLINK-10506 Project: Flink

[jira] [Created] (FLINK-10505) Treat fail signal as scheduling event

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10505: - Summary: Treat fail signal as scheduling event Key: FLINK-10505 URL: https://issues.apache.org/jira/browse/FLINK-10505 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10504) Decide actual parallelism based on available resources

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10504: - Summary: Decide actual parallelism based on available resources Key: FLINK-10504 URL: https://issues.apache.org/jira/browse/FLINK-10504 Project: Flink Issu

[jira] [Created] (FLINK-10503) Periodically check for new resources

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10503: - Summary: Periodically check for new resources Key: FLINK-10503 URL: https://issues.apache.org/jira/browse/FLINK-10503 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10502) Wait for resource stabilization

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10502: - Summary: Wait for resource stabilization Key: FLINK-10502 URL: https://issues.apache.org/jira/browse/FLINK-10502 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10501) Obtain resource overview of cluster

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10501: - Summary: Obtain resource overview of cluster Key: FLINK-10501 URL: https://issues.apache.org/jira/browse/FLINK-10501 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-10500) Let ExecutionGraphDriver react to fail signal

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10500: - Summary: Let ExecutionGraphDriver react to fail signal Key: FLINK-10500 URL: https://issues.apache.org/jira/browse/FLINK-10500 Project: Flink Issue Type: S

[jira] [Created] (FLINK-10499) Introduce declarative resource management switch

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10499: - Summary: Introduce declarative resource management switch Key: FLINK-10499 URL: https://issues.apache.org/jira/browse/FLINK-10499 Project: Flink Issue Type

[jira] [Created] (FLINK-10498) Decouple ExecutionGraph from JobMaster

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10498: - Summary: Decouple ExecutionGraph from JobMaster Key: FLINK-10498 URL: https://issues.apache.org/jira/browse/FLINK-10498 Project: Flink Issue Type: Sub-task

MapState support for operator state

2018-10-07 Thread Dániel Berecz
Hi everyone, I would like to ask if there is any conceptual problem with having MapState available for operator states, or is it just a lack of implementation? Best regards, Daniel Berecz

[ANNOUNCE] Feature freeze for Flink 1.7: 22nd of October

2018-10-07 Thread Till Rohrmann
Dear community, as discussed in this thread [1], we will freeze the feature development for Flink 1.7 on the 22nd of October 0:01 CET. Please try to finish your feature work until then. If this is not possible, then don't worry because it will then be released with Flink 1.8+. [1] http://apache-

[jira] [Created] (FLINK-10497) More fine grained control over access to REST endpoints

2018-10-07 Thread Till Rohrmann (JIRA)
Till Rohrmann created FLINK-10497: - Summary: More fine grained control over access to REST endpoints Key: FLINK-10497 URL: https://issues.apache.org/jira/browse/FLINK-10497 Project: Flink Iss