Hi, Zander Thank you for bringing this topic up.
Could you give more input about the following improvement? Do you have some specific scenario that needs this improvement? Replace beam local execution Evaluate alternatives for the local execution engine. Best, Guowei On Sat, Jun 28, 2025 at 5:24 AM Alexander Matheson <a.w.mathe...@gmail.com> wrote: > Hi devs, > > I would like to start a discussion about a new FLIP for a rather large > umbrella of work concerning PyFlink that Dian Fu, Xingbo Huang, myself and > others have been coordinating around. > > As PyFlink continues to grow in adoption (downloads are up 10x YoY on > PyPI!!!) it is overdue for additional investment to bring it inline with > the expectations of the Python community. Given the increase in AI > workloads shifting to real-time, these improvements will also help to > support the net-new Flink users coming from that space. > > The Project is called The Zen of Flink as an ode to the driving principles > of Python called the Zen of Python and is broadly about making Flink more > Pythonic. The work falls into six categories across API design, > documentation, debuggability, local development, integration with the > ecosystem and general usability. Not all of the work is concretely scoped > yet and is not planned to be as more improvements will arise as we work on > this effort. > > The details of the FLIP can be found in the google doc linked below. > > > https://docs.google.com/document/d/18_u1XA9C_zdY_fu1OtQDwYyIk_TwjUfzAUOzhGxbN6w/edit?usp=sharing > > Looking forward to the discussion. > > Best, > > Zander >
