Apache Flink 1.2 was announced and features dynamic rescaling, security, queryable state, and more. The release resolved 650 issues, maintains compatibility with all public APIs and ships with Apache Kafka 0.10 and Apache Mesos support. Flink’s dynamic rescaling allows one to change…
Apache Flink 1.2 was announced and features dynamic rescaling, security, queryable state, and more. The release resolved 650 issues, maintains compatibility with all public APIs and ships with Apache Kafka 0.10 and Apache Mesos support.
Flink’s dynamic rescaling allows one to change the parallelism of a streaming job or of an operator within the job. This feature restores the job from a savepoint using a different parallelism and improves the operational management of streaming pipelines by scaling up and down accordingly, minimizing the downtime to a few seconds. Currently it’s supported for some operators like Kafka consumers, Window operations and custom user state.
On security, authentication support was added against external services using Kerberos.
