Hi Matyas, According to the release schedule defined in [1], it seems that the feature freeze of v1.2 may occur at the beginning of September, is this correct? If this is the case, I think it should be reasonable to make it in v1.2 for Python support.
Regards, Dian [1] https://cwiki.apache.org/confluence/display/FLINK/Release+Schedule+and+Planning On Tue, Jul 5, 2022 at 2:10 PM Őrhidi Mátyás <matyas.orh...@gmail.com> wrote: > Both sql and py support is requested frequently. I guess we should aim to > support both in v1.2. > > Matyas > > On Tue, Jul 5, 2022 at 6:26 AM Gyula Fóra <gyula.f...@gmail.com> wrote: > >> Thank you for the info and help Dian :) >> >> Gyula >> >> On Tue, 5 Jul 2022 at 05:14, Yang Wang <danrtsey...@gmail.com> wrote: >> >> > Thanks Dian for the confirmation and nice help. >> > >> > Best, >> > Yang >> > >> > Dian Fu <dian0511...@gmail.com> 于2022年7月5日周二 09:27写道： >> > >> > > @Yang, Yes, you are right. Python jobs could be seen as special JAR >> jobs >> > > whose main class is always >> `org.apache.flink.client.python.PythonDriver`. >> > > What we could do in Flink K8s operator is to make it more convenient >> and >> > > handle properly for the different kinds of dependencies[1]. >> > > >> > > @Gyula, I can help on this. I will find some time to investigate this >> in >> > > the following days and will let you know when there is any progress. >> > > >> > > Regards, >> > > Dian >> > > >> > > [1] >> > > >> > >> https://nightlies.apache.org/flink/flink-docs-master/docs/dev/python/dependency_management/ >> > > >> > > On Mon, Jul 4, 2022 at 11:52 AM Yang Wang <danrtsey...@gmail.com> >> wrote: >> > > >> > >> AFAIK, the python job could be considered as a special case of jar >> job. >> > >> The user jar is flink-python-*.jar and is located in the opt >> directory. >> > >> The python script is just the argument of this user jar. So I believe >> > the >> > >> users already could submit python jobs via Flink Kubernetes operator. >> > >> However, they need some manual operations, including specify the user >> > >> jar, download python script via init container, etc. >> > >> >> > >> What we could do in the Flink kubernetes operator is to make the >> > >> submission more convenient by introducing a new field(e.g. pyScript). >> > >> >> > >> cc @Dian Fu <dian0511...@gmail.com> @biaoge...@gmail.com >> > >> <biaoge...@gmail.com> WDYT? >> > >> >> > >> Best, >> > >> Yang >> > >> >> > >> Gyula Fóra <gyf...@apache.org> 于2022年7月4日周一 00:12写道： >> > >> >> > >>> Hi Devs! >> > >>> >> > >>> Would anyone with a good understanding of the Python execution >> layer be >> > >>> interested in working on adding Python job support for the Flink >> > >>> Kubernetes >> > >>> Operator? >> > >>> >> > >>> This is a feature request that comes up often ( >> > >>> https://issues.apache.org/jira/browse/FLINK-28364) and it would be >> a >> > >>> great >> > >>> way to fill some missing feature gaps on the operator :) >> > >>> >> > >>> I am of course happy to help or work together with someone on this >> but >> > I >> > >>> have zero experience with the Python API at this stage and don't >> want >> > to >> > >>> miss some obvious requirements. >> > >>> >> > >>> Cheers, >> > >>> Gyula >> > >>> >> > >> >> > >> >
