Thanks for the reply, @Max. I was not aware it was about dynamic scaling, which I think also asked for YARN support. I agree to list all related half merge JIRA for the ResourceManager.
Looking forward for the Apache Mesos integration design for sure =) - Henry On Thu, Jun 16, 2016 at 2:12 AM, Maximilian Michels <m...@apache.org> wrote: > Hi Robert, hi Henry, > > +1 for a 1.1.0 release soon! We have enough new features that justify > a major release. > > @Henry We have plans to extend the ResourceManager to interact with > the Scheduler which will be a prerequisite for dynamic scaling. I > think this is out of scope for 1.1.0. The upcoming Mesos integration > won't require additional refactoring of the ResourceManager. Instead, > we will create a new "Dispatcher" component that takes care of > bootstrapping the initial node with the JobManager/ResourceManager. > From there on, everything will be handled by the Mesos > ResourceManager. I recently discussed this with Eron (CC) who came up > with this design and he plans to publish it to the mailing list soon. > > How about listing relevant JIRA issues here? "Half Merged" is kind of > hard to get for people who are not involved in the different > components. > > The Cassandra adapter seems like a pretty important thing to have for > the next release. In addition, I would like to merge FLINK-3667 and > FLINK-3937. Robert is doing a review at the moment :) Those are a) > refactoring of the command-line and client classes b) adding > capability to resume cluster programmatically. > > Then we should also have a look at any other critical/major bugs listed in > JIRA. > > Cheers, > Max > > On Wed, Jun 15, 2016 at 10:50 PM, Henry Saputra <henry.sapu...@gmail.com> > wrote: > > Hi Robert, > > > > Thanks for staying the discussion. > > > > Do you know if there any open tasks for the Resource Manager left? > > > > That is probably needed for Mesos integration? > > > > - Henry > > > > On Wed, Jun 15, 2016 at 12:55 PM, Robert Metzger <rmetz...@apache.org> > > wrote: > > > >> Hi, > >> > >> Flink 1.0.0 was released early March, so three months have passed and I > >> think we should start discussing the scope of the next major release > >> (1.1.0). > >> > >> From a high level point of view, we've added the following new features: > >> in master: > >> - Table API Refactoring, SQL, StreamSQL > >> - The metrics system > >> - Kinesis Connector > >> - Persistent file sources for streaming > >> > >> Half merged: > >> - Resource manager refactoring > >> > >> Unmerged features: > >> - Cassandra connector > >> - Key groups ("rescaling from savepoints") > >> - Queryable state > >> > >> I'm pretty sure I forgot many other features / pull requests, please > post > >> them to this thread. I'll collect them and create a Wiki page out of it. > >> > >> Some immediate TODOs for us: > >> - Which of the unmerged features are we going to add to the release? > >> - Which blockers do we need to address before releasing? > >> - Are there any volunteers for the release manager? > >> > >> > >> Regards, > >> Robert > >> >