Re: Dynamic Scaling: State Sharding

yet when it will be available. Cheers, Till On Mon, Oct 5, 2020 at 8:47 AM Mazen Ezzeddine wrote: > So what is the state of dynamic scaling (non static, set by the user in the > code) for SLA gurantees now, is it already included in FLink, and is it > still necessaru to stop/restar

Re: Dynamic Scaling: State Sharding

So what is the state of dynamic scaling (non static, set by the user in the code) for SLA gurantees now, is it already included in FLink, and is it still necessaru to stop/restart the job for dynamic scaling. Thanks. -- Sent from: http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/

[jira] [Created] (FLINK-7077) Implement task release to support dynamic scaling

Till Rohrmann created FLINK-7077: Summary: Implement task release to support dynamic scaling Key: FLINK-7077 URL: https://issues.apache.org/jira/browse/FLINK-7077 Project: Flink Issue Type

Re: Dynamic Scaling

Hi Govind, In Flink 1.2 (feature complete, undergoing test) you will be able to scale your jobs/operators up and down at will, however you'll have to build a little tooling around it yourself and scale based on your own metrics. You should be able to integrate this with Docker Swarm or Amazon

Re: Dynamic Scaling

Hi All, It would great if someone can help me with my questions. Appreciate all the help. Thanks. > On Dec 23, 2016, at 12:11 PM, Govindarajan Srinivasaraghavan > wrote: > > Hi, > > We have a computation heavy streaming flink job which will be processing > around

Re: Dynamic Scaling: State Sharding

Sorry, my bad. Comments should work now. On Mon, Apr 4, 2016 at 3:51 PM, Aljoscha Krettek <aljos...@apache.org> wrote: > Comments are not enabled. > > On Mon, 4 Apr 2016 at 13:58 Till Rohrmann <trohrm...@apache.org> wrote: > > > Hi Flink community, > > >

Re: Dynamic Scaling: State Sharding

Comments are not enabled. On Mon, 4 Apr 2016 at 13:58 Till Rohrmann <trohrm...@apache.org> wrote: > Hi Flink community, > > I recently started working on dynamic scaling. As a first step we want to > introduce state sharding which is a requirement for partitioned state to be

Dynamic Scaling: State Sharding

Hi Flink community, I recently started working on dynamic scaling. As a first step we want to introduce state sharding which is a requirement for partitioned state to be re-distributable. The following design doc [1] explains the ideas behind it. Any feedback is highly appreciated :-) [1] https