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
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.
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
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
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
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