Re: [DISCUSS] FLIP-5 Only send data to each taskmanager once for broadcasts

Hi Stephan, thanks for the great ideas. First I have some questions: 1.1) Does every task generate an intermediate result partition for every target task or is that already implemented in a way so that there are only as many intermediate result partitions per task manager as target tasks? (Exampl

[VOTE] Release Apache Flink 1.1.0 (RC1)

Dear Flink community, Please vote on releasing the following candidate as Apache Flink version 1.1.0. I've CC'd u...@flink.apache.org as users are encouraged to help testing Flink 1.1.0 for their specific use cases. Please feel free to report issues and successful tests on dev@flink.apache.org.

[jira] [Created] (FLINK-4268) Add a parsers for BigDecimals/BigInteger

Timo Walther created FLINK-4268: --- Summary: Add a parsers for BigDecimals/BigInteger Key: FLINK-4268 URL: https://issues.apache.org/jira/browse/FLINK-4268 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4269) Decrease log level in RuntimeMonitorHandler

Ufuk Celebi created FLINK-4269: -- Summary: Decrease log level in RuntimeMonitorHandler Key: FLINK-4269 URL: https://issues.apache.org/jira/browse/FLINK-4269 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4270) 'as' in front of join does not work

Timo Walther created FLINK-4270: --- Summary: 'as' in front of join does not work Key: FLINK-4270 URL: https://issues.apache.org/jira/browse/FLINK-4270 Project: Flink Issue Type: Bug Com

[jira] [Created] (FLINK-4271) There is no way to set parallelism of operators such as map and window produced by

Wenlong Lyu created FLINK-4271: -- Summary: There is no way to set parallelism of operators such as map and window produced by Key: FLINK-4271 URL: https://issues.apache.org/jira/browse/FLINK-4271 Project