+1 (binding)
Thanks,
Hequn
On Fri, Jan 12, 2024 at 2:19 PM godfrey he wrote:
> +1 (binding)
>
> Thanks,
> Godfrey
>
> Zhu Zhu 于2024年1月12日周五 14:10写道：
> >
> > +1 (binding)
> >
> > Thanks,
> > Zhu
> >
> > Hangxiang Yu 于2024年1月11日周四 14:26写道：
> >
> > > +1 (non-binding)
> > >
> > > On Thu, Jan 11,
+1 (binding)
Best,
Hequn
On Thu, Sep 10, 2020 at 10:03 AM Dian Fu wrote:
> +1(binding)
>
> Regards,
> Dian
>
> > 在 2020年9月8日，上午7:43，jincheng sun 写道：
> >
> > +1(binding)
> >
> > Best,
> > Jincheng
> >
> > Xingbo Huang 于2020年9月7日周一 下午5:45写道：
> >
> >> Hi,
> >>
> >> +1 (non-binding)
> >>
> >> Bes
+1 (binding)
On Tue, Sep 8, 2020 at 7:43 AM jincheng sun
wrote:
> +1(binding)
>
> Best,
> Jincheng
>
>
> Shuiqiang Chen 于2020年9月7日周一 下午3:50写道：
>
> > +1 (non-binding)
> >
> > > 在 2020年9月7日，下午2:38，Wei Zhong 写道：
> > >
> > > +1 (non-binding)
> > >
> > >> 在 2020年9月7日，10:00，Dian Fu 写道：
> > >>
> >
Hequn Cheng created FLINK-18997:
---
Summary: Rename type_info to result_type to make it more clear
Key: FLINK-18997
URL: https://issues.apache.org/jira/browse/FLINK-18997
Project: Flink
Issue
Hequn Cheng created FLINK-18985:
---
Summary: Update the Sphinx doc for Python DataStream API.
Key: FLINK-18985
URL: https://issues.apache.org/jira/browse/FLINK-18985
Project: Flink
Issue Type
Hequn Cheng created FLINK-18984:
---
Summary: Add tutorial documentation for Python DataStream API
Key: FLINK-18984
URL: https://issues.apache.org/jira/browse/FLINK-18984
Project: Flink
Issue
Hequn Cheng created FLINK-18966:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18966
URL: https://issues.apache.org/jira/browse/FLINK-18966
Project: Flink
Hequn Cheng created FLINK-18954:
---
Summary: Add documentation for Metrics in Python DataStream API.
Key: FLINK-18954
URL: https://issues.apache.org/jira/browse/FLINK-18954
Project: Flink
Issue
Hequn Cheng created FLINK-18953:
---
Summary: Add documentation for DataTypes in Python DataStream API
Key: FLINK-18953
URL: https://issues.apache.org/jira/browse/FLINK-18953
Project: Flink
Issue
Hequn Cheng created FLINK-18952:
---
Summary: Add 10 minutes to DataStream API documentation
Key: FLINK-18952
URL: https://issues.apache.org/jira/browse/FLINK-18952
Project: Flink
Issue Type: Sub
Hequn Cheng created FLINK-18949:
---
Summary: Support Streaming File Sink for Python DataStream API
Key: FLINK-18949
URL: https://issues.apache.org/jira/browse/FLINK-18949
Project: Flink
Issue
Hequn Cheng created FLINK-18948:
---
Summary: Add end to end test for Python DataStream API
Key: FLINK-18948
URL: https://issues.apache.org/jira/browse/FLINK-18948
Project: Flink
Issue Type: Sub
Hequn Cheng created FLINK-18947:
---
Summary: Support partitionCustom() operation for Python DataStream
API
Key: FLINK-18947
URL: https://issues.apache.org/jira/browse/FLINK-18947
Project: Flink
Hequn Cheng created FLINK-18945:
---
Summary: Support key_by() on ConnectedStreams for Python
DataStream API
Key: FLINK-18945
URL: https://issues.apache.org/jira/browse/FLINK-18945
Project: Flink
Hequn Cheng created FLINK-18943:
---
Summary: Support connect() operation for Python DataStream API
Key: FLINK-18943
URL: https://issues.apache.org/jira/browse/FLINK-18943
Project: Flink
Issue
+1 (binding)
Best,
Hequn
On Wed, Aug 12, 2020 at 10:12 AM Wei Zhong wrote:
> +1 (non-binding)
>
> Best,
> Wei
>
> > 在 2020年8月11日，22:41，Seth Wiesman 写道：
> >
> > +1 (binding)
> >
> > On Sun, Aug 9, 2020 at 8:15 PM jincheng sun
> > wrote:
> >
> >> Hi Seth,
> >>
> >> Thank you for joining the di
Hequn Cheng created FLINK-18883:
---
Summary: Support reduce() operation for Python KeyedStream.
Key: FLINK-18883
URL: https://issues.apache.org/jira/browse/FLINK-18883
Project: Flink
Issue Type
Hequn Cheng created FLINK-18817:
---
Summary: 'Kerberized YARN per-job on Docker test' failed
Key: FLINK-18817
URL: https://issues.apache.org/jira/browse/FLINK-18817
Project: Flink
Hi Jincheng,
Thanks a lot for raising the discussion. +1 for the FLIP.
I think this will bring big benefits for the PyFlink users. Currently, the
Python TableAPI document is hidden deeply under the TableAPI&SQL tab which
makes it quite unreadable. Also, the PyFlink documentation is mixed with
Jav
Hequn Cheng created FLINK-18766:
---
Summary: Support add_sink() for Python DataStream API
Key: FLINK-18766
URL: https://issues.apache.org/jira/browse/FLINK-18766
Project: Flink
Issue Type: Sub
Hequn Cheng created FLINK-18765:
---
Summary: Support map() and flat_map() for Python DataStream API
Key: FLINK-18765
URL: https://issues.apache.org/jira/browse/FLINK-18765
Project: Flink
Issue
Hequn Cheng created FLINK-18764:
---
Summary: Support from_collection for Python DataStream API
Key: FLINK-18764
URL: https://issues.apache.org/jira/browse/FLINK-18764
Project: Flink
Issue Type
Hequn Cheng created FLINK-18763:
---
Summary: Support basic TypeInformation for Python DataStream API
Key: FLINK-18763
URL: https://issues.apache.org/jira/browse/FLINK-18763
Project: Flink
Issue
Hequn Cheng created FLINK-18761:
---
Summary: Support Python DataStream API (Stateless part)
Key: FLINK-18761
URL: https://issues.apache.org/jira/browse/FLINK-18761
Project: Flink
Issue Type: New
+1 (binding)
Best,
Hequn
On Tue, Jul 28, 2020 at 2:58 PM Aljoscha Krettek
wrote:
> +1 (binding)
>
> Aljoscha
>
> On 28.07.20 04:12, Dian Fu wrote:
> > Thanks for driving this Shuiqiang.
> >
> > +1
> >
> > Regards,
> > Dian
> >
> >> 在 2020年7月27日，下午3:33，jincheng sun 写道：
> >>
> >> +1(binding)
> >
> >>
> >>> Hi Aljoscha, Thank you for your response. I'll keep these two helper
> >>> methods in the Python DataStream implementation.
> >>>
> >>> And thank you all for joining in the discussion. It seems that we have
> >>&g
uot;print".
>
> I think we can now proceed to a vote! Nice work, overall!
>
> Best,
> Aljoscha
>
> On 16.07.20 17:16, Hequn Cheng wrote:
> > Hi,
> >
> > Thanks a lot for your discussions.
> > I think Aljoscha makes good suggestions here! Those
Thanks Dian for the great work and thanks to everyone who makes this
release possible!
Best, Hequn
On Wed, Jul 22, 2020 at 4:40 PM Jark Wu wrote:
> Congratulations! Thanks Dian for the great work and to be the release
> manager!
>
> Best,
> Jark
>
> On Wed, 22 Jul 2020 at 15:45, Yangze Guo wro
Hequn Cheng created FLINK-18655:
---
Summary: Set failOnUnableToExtractRepoInfo to false for
git-commit-id-plugin in module flink-runtime
Key: FLINK-18655
URL: https://issues.apache.org/jira/browse/FLINK-18655
the proposal!
> > >
> > > Best,
> > > Jincheng
> > >
> > >
> > > Xingbo Huang 于2020年7月9日周四 上午10:41写道：
> > >
> > > > Hi Shuiqiang,
> > > >
> > > > Thanks a lot for driving this discussion.
> > > &
+1 for a quick bug fix release and Dian as the release manager.
Best,
Hequn
On Thu, Jul 9, 2020 at 9:22 PM Dian Fu wrote:
> Hi Jark,
>
> Thanks for offering the help. It would definitely be helpful.
>
> Regards,
> Dian
>
> > 在 2020年7月9日，下午8:54，Benchao Li 写道：
> >
> > +1 for a quick bug fix rel
+1 for adding the Python DataStream API and starting with the stateless
part.
There are already some users that expressed their wish to have the Python
DataStream APIs. Once we have the APIs in PyFlink, we can cover more use
cases for our users.
Best, Hequn
On Wed, Jul 8, 2020 at 11:45 AM Shuiqia
Hequn Cheng created FLINK-18151:
---
Summary: Resolve CWE22 problems in pyflink_gateway_server.py
Key: FLINK-18151
URL: https://issues.apache.org/jira/browse/FLINK-18151
Project: Flink
Issue
Congratulations Xintong!
Best, Hequn
On Fri, Jun 5, 2020 at 2:03 PM Marta Paes Moreira
wrote:
> Congratulations, Tony! Great job!
>
> On Fri, Jun 5, 2020 at 8:00 AM Yang Wang wrote:
>
> > Congratulations, Xintong.
> > Well deserved.
> >
> > Best,
> > Yang
> >
> > Weihua Hu 于2020年6月5日周五 下午1:57
Hequn Cheng created FLINK-18143:
---
Summary: Fix Python meter metric not correct problem
Key: FLINK-18143
URL: https://issues.apache.org/jira/browse/FLINK-18143
Project: Flink
Issue Type: Bug
updated version.
>
> Gordon
>
> [1]
>
> https://gitbox.apache.org/repos/asf?p=flink-statefun.git;a=tag;h=c08c9850147d818fc8fed877a01ff87021f3cf21
> [2] https://github.com/apache/flink-statefun/tree/release-2.1.0-rc1
>
> On Thu, Jun 4, 2020 at 12:10 PM Hequn Cheng wrote:
>
It seems the release tag is not correct? The version in the poms should
be 2.1.0 instead of 2.1-SNAPSHOT.
Best,
Hequn
On Thu, Jun 4, 2020 at 10:33 AM Congxian Qiu wrote:
> +1 (non-binding)
>
> maybe there is something that needs to be updated in README.md(currently
> the official docs link po
+1 (binding)
1. Go through all the commits from 11.0.
2. website PR looks good
3. Built from source archive successfully.
4. Signatures and hash are correct.
Best,
Hequn
On Fri, May 29, 2020 at 4:08 PM Chesnay Schepler wrote:
> +1 (binding)
>
> On 28/05/2020 18:49, Yu Li wrote:
> > +1 (non-bin
gt; such an important thing, so I wouldn't block the release on it.
>
> On 29/05/2020 09:11, Hequn Cheng wrote:
> > Sorry about my late check.
> > I found one blocker just now that the year in the root NOTICE file should
> > be updated. I have created a jira(FLINK-18031) for it
Sorry about my late check.
I found one blocker just now that the year in the root NOTICE file should
be updated. I have created a jira(FLINK-18031) for it.
Best,
Hequn
On Fri, May 29, 2020 at 12:47 AM Yu Li wrote:
> +1 (non-binding)
>
> Checked issues listed in release notes: ok (*)
> - Add sh
Hequn Cheng created FLINK-18031:
---
Summary: Update the copyright year in the NOTICE file in
flink-shaded repo
Key: FLINK-18031
URL: https://issues.apache.org/jira/browse/FLINK-18031
Project: Flink
Hequn Cheng created FLINK-17962:
---
Summary: Add document for how to define Python UDF with DDL
Key: FLINK-17962
URL: https://issues.apache.org/jira/browse/FLINK-17962
Project: Flink
Issue Type
Hequn Cheng created FLINK-17960:
---
Summary: Improve commands in the "Common Questions" document for
PyFlink
Key: FLINK-17960
URL: https://issues.apache.org/jira/browse/FLINK-17960
Proj
Hequn Cheng created FLINK-17959:
---
Summary: Exception: "CANCELLED: call already cancelled" is thrown
when run python udf
Key: FLINK-17959
URL: https://issues.apache.org/jira/browse/FLINK-17959
+1
It would be nice to have these fixes!
Best,
Hequn
On Mon, May 25, 2020 at 5:00 PM Zhijiang
wrote:
> Thanks for driving this, Chesnay!
> +1 on my side.
>
> Best,
> Zhijiang
> --
> From:Till Rohrmann
> Send Time:2020年5月25日(星期一) 1
Hequn Cheng created FLINK-17710:
---
Summary: StreamSqlTests.test_execute_sql test is not stable
Key: FLINK-17710
URL: https://issues.apache.org/jira/browse/FLINK-17710
Project: Flink
Issue Type
+1 (binding)
- Go through all commits from 1.10.0 to 1.10.1 and spot no new license
problems.
- Built from source archive successfully.
- Travis e2e tests have passed.
- Signatures and hash are correct.
- Run SocketWindowWordCount on the local cluster and check web ui & logs.
- Install Python pack
+1, thanks a lot for driving this.
Best, Hequn
On Tue, May 5, 2020 at 11:56 AM Dian Fu wrote:
> +1
>
> Regards,
> Dian
>
> > 在 2020年5月5日，上午9:58，Yangze Guo 写道：
> >
> > +1
> >
> > Best,
> > Yangze Guo
> >
> > On Tue, May 5, 2020 at 6:14 AM Thomas Weise wrote:
> >>
> >> +1
> >>
> >>
> >> On Mon,
Thanks a lot for managing the release!
+1 (binding)
- Go through all new commits for 1.10.1 and spot no new license problems.
- Built from source archive successfully.
- Signatures and hash are correct.
- Run SocketWindowWordCount on the local cluster.
- Install Python package and run Python Word
@Dian, thanks a lot for the release and for being the release manager.
Also thanks to everyone who made this release possible!
Best,
Hequn
On Sat, Apr 25, 2020 at 7:57 PM Dian Fu wrote:
> Hi everyone,
>
> The Apache Flink community is very happy to announce the release of Apache
> Flink 1.9.3,
Welcome, Etienne :)
Best,
Hequn
On Fri, Apr 24, 2020 at 10:04 PM Etienne Chauchot
wrote:
> Hi Till,
>
> Looking forward too ...
>
> Thanks
>
> Etienne
>
> On 24/04/2020 15:09, Till Rohrmann wrote:
> > Hi Etienne,
> >
> > welcome to the Flink community. Looking forward to working with you on
> >
Hequn Cheng created FLINK-17318:
---
Summary: The comment is not right in
`org.apache.flink.table.planner.delegation.PlannerBase`
Key: FLINK-17318
URL: https://issues.apache.org/jira/browse/FLINK-17318
Many thanks for your support. Thank you!
Best,
Hequn
On Sat, Apr 18, 2020 at 1:27 AM Jacky Bai wrote:
> Congratulations！Hequn Chen.I hope to make so many contributions to Flink
> like you.
>
> Best
> Bai Xu
>
> Congxian Qiu 于2020年4月17日周五 下午10:47写道：
>
> > Congratulations, Hequn!
> >
> > Best,
>
Hequn Cheng created FLINK-17215:
---
Summary: Clean the build document for Pyflink
Key: FLINK-17215
URL: https://issues.apache.org/jira/browse/FLINK-17215
Project: Flink
Issue Type: Improvement
lt;
> >>>>>>>>>>>>>>>>> azagrebin.apa...@gmail.com>
> >>>>>>>>>>>>>>>>>> wrote:
> >>>>>>>>>>>>>>>>>>
> >>>>>>>>&g
+1 for the release and for Dian being the RM.
Thanks Jincheng for your continuous efforts on helping the releasing.
Best,
Hequn
On Wed, Apr 15, 2020 at 3:45 PM Till Rohrmann wrote:
> Hi Dian,
>
> creating a new 1.9 bug fix release is a very good idea. +1 for creating it
> soon. Also thanks for
+1 (binding)
Best,
Hequn
On Mon, Apr 13, 2020 at 1:50 PM jincheng sun
wrote:
> +1(binding)
>
> Best,
> Jincheng
>
>
>
> Dian Fu 于2020年4月8日周三 上午9:59写道：
>
> > +1 (binding)
> >
> > > 在 2020年4月8日，上午9:53，Xingbo Huang 写道：
> > >
> > > Hi all,
> > > I would like to start the vote for FLIP-121[1], whi
+1 (binding)
Best,
Hequn
On Mon, Apr 13, 2020 at 1:28 PM Jeff Zhang wrote:
> +1
>
>
> jincheng sun 于2020年4月13日周一 下午1:24写道：
>
> > +1(binding)
> >
> > Best,
> > Jincheng
> >
> >
> >
> > Xingbo Huang 于2020年4月9日周四 下午8:27写道：
> >
> > > Hi Dian,
> > >
> > > +1 (non-binding)
> > > Thanks a lot for dr
It’s much more convenient now. Thanks you!
> On Apr 9, 2020, at 8:01 PM, Aljoscha Krettek wrote:
>
> That is very nice! Thanks for taking care of this ~3q
>
> On 09.04.20 11:08, Dian Fu wrote:
>> Cool! Thanks Yun for this effort. Very useful feature.
>> Regards,
>> Dian
>>> 在 2020年4月9日，下午4:32，Y
Thanks a lot for the release and your great job, Gordon!
Also thanks to everyone who made this release possible!
Best,
Hequn
On Tue, Apr 7, 2020 at 8:58 PM Tzu-Li (Gordon) Tai
wrote:
> The Apache Flink community is very happy to announce the release of Apache
> Flink Stateful Functions 2.0.0.
>
Hi,
+1 on integrating with Azure, it is consistent with the long term goal and
we are also going to switch from Travis to Azure.
The performance improvement is very impressive. Looking forward to the vote.
Best, Hequn
On Tue, Apr 7, 2020 at 9:10 PM Xingbo Huang wrote:
> Hi everyone,
>
> Thanks
Congratulations Seth!
Best, Hequn
On Tue, Apr 7, 2020 at 4:11 PM Fabian Hueske wrote:
> Congrats Seth! Well deserved :-)
>
> Cheers, Fabian
>
> Am Di., 7. Apr. 2020 um 10:09 Uhr schrieb Yangze Guo :
>
> > Congratulations Seth!
> >
> > Best,
> > Yangze Guo
> >
> > On Tue, Apr 7, 2020 at 4:07 PM
Thanks a lot for the new RC!
+1 (non-binding)
- Signatures and hash are correct.
- The source distribution contains no binaries.
- The source distribution is building properly with `-Prun-e2e-tests`
(JDK8).
- All POM files / README / Python SDK setup.py point to the same version.
- Verify license
+1 (binding)
Best,
Hequn
On Fri, Apr 3, 2020 at 10:20 AM jincheng sun
wrote:
> +1(binding)
>
> Best,
> Jincheng
>
>
>
> Xingbo Huang 于2020年4月1日周三 下午5:36写道：
>
> > Hi Wei,
> >
> > +1 (non-binding)
> > Thanks a lot for driving this.
> >
> > Best,
> > Xingbo
> >
> > Wei Zhong 于2020年3月31日周二 上午10:
Congratulations to all of you!
Best, Hequn
On Wed, Apr 1, 2020 at 5:07 PM Jiayi Liao wrote:
> Congratulations to you all!
>
> On Wed, Apr 1, 2020 at 5:05 PM Arvid Heise wrote:
>
> > Congratulations!
> >
> > On Wed, Apr 1, 2020 at 11:03 AM Dian Fu wrote:
> >
> > > Congratulations to you all.
>
Hi Wei,
Thanks a lot for the proposal! +1 for the VOTE.
Best,
Hequn
On Mon, Mar 30, 2020 at 3:31 PM Dian Fu wrote:
> Thanks Wei for this work! +1 to bring up the VOTE thread.
>
> > 在 2020年3月30日，下午2:43，jincheng sun 写道：
> >
> > Hi Wei,
> >
> > +1, Thanks for this discussion which is crucial f
>
> On Sun, Mar 29, 2020 at 6:30 PM Igal Shilman wrote:
>
>> Hi @Hequn Cheng , and @Tzu-Li (Gordon) Tai
>>
>> Indeed the names are generated automatically and are following a
>> convention.
>>
>> Cheers,
>> Igal.
>>
>> On Sun, Mar 29,
Hequn Cheng created FLINK-16854:
---
Summary: Correct dependency versions in the NOTICE file of module
statefun-ridesharing-example-simulator
Key: FLINK-16854
URL: https://issues.apache.org/jira/browse/FLINK-16854
Hequn Cheng created FLINK-16853:
---
Summary: Update the version of protobuf-java from 3.8.0 to 3.7.1
in the NOTICE file of module statefun-flink-distribution
Key: FLINK-16853
URL: https://issues.apache.org/jira
Hi Gordon,
Thanks a lot for the new RC. I found some new blockers about licenses:
- Module statefun-flink-distribution
com.google.protobuf:protobuf-java:3.8.0 (The version should be 3.7.1)
- Module statefun-ridesharing-example-simulator
com.google.code.findbugs:jsr305:3.0.2:compile (Remove compi
her dependencies that are not ASLv2.
> >> That would indeed make this problem a blocker.
> >>
> >> I'll do a thorough check again on the Maven artifacts that do bundle
> >> dependencies, before creating a new RC. AFAIK, there should be no more
> >> other
Hi Leping,
Welcome to the community!
You no longer need contributor permissions. You can simply create a JIRA
ticket and ask to be assigned to work on it. For some reasons[1], only
committers can assign a
Jira ticket now. You can also take a look at the Flink's contribution
guidelines [2] for mor
Thanks Gordon for the release and the nice release checking guide!
It seems the NOTICE file is missing in the
`statefun-ridesharing-example-simulator` module while it bundles
dependencies like
`org.springframework.boot:spring-boot-loader:2.1.6.RELEASE`.
Best,
Hequn
On Fri, Mar 27, 2020 at 3:35 P
+1 for a separate repository.
The dedicated `flink-docker` repo works fine now. We can do it similarly.
Best,
Hequn
On Fri, Mar 27, 2020 at 1:16 AM Till Rohrmann wrote:
> +1 for a separate repository.
>
> Cheers,
> Till
>
> On Thu, Mar 26, 2020 at 5:13 PM Ufuk Celebi wrote:
>
> > +1.
> >
> > T
Hequn Cheng created FLINK-16786:
---
Summary: Fix pyarrow version incompatible problem
Key: FLINK-16786
URL: https://issues.apache.org/jira/browse/FLINK-16786
Project: Flink
Issue Type: Bug
Hequn Cheng created FLINK-16766:
---
Summary: Support create StreamTableEnvironment without passing
StreamExecutionEnvironment
Key: FLINK-16766
URL: https://issues.apache.org/jira/browse/FLINK-16766
Hequn Cheng created FLINK-16765:
---
Summary: Replace all BatchTableEnvironment to
StreamTableEnvironment in the document of PyFlink
Key: FLINK-16765
URL: https://issues.apache.org/jira/browse/FLINK-16765
Hequn Cheng created FLINK-16763:
---
Summary: Should not use BatchTableEnvironment for Python UDF in
the document of flink-1.10
Key: FLINK-16763
URL: https://issues.apache.org/jira/browse/FLINK-16763
Hequn Cheng created FLINK-16761:
---
Summary: Return JobExecutionResult for Python ExecutionEnvironment
and TableEnvironment
Key: FLINK-16761
URL: https://issues.apache.org/jira/browse/FLINK-16761
Project
Hequn Cheng created FLINK-16674:
---
Summary: Add documentation about how to use user-defined metrics
for Python UDF
Key: FLINK-16674
URL: https://issues.apache.org/jira/browse/FLINK-16674
Project: Flink
Hequn Cheng created FLINK-16673:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDTF
Key: FLINK-16673
URL: https://issues.apache.org/jira/browse/FLINK-16673
Project: Flink
Hequn Cheng created FLINK-16672:
---
Summary: Support Counter, Gauge, Meter, Distribution metric type
for Python UDF
Key: FLINK-16672
URL: https://issues.apache.org/jira/browse/FLINK-16672
Project: Flink
Hequn Cheng created FLINK-16671:
---
Summary: Support define scopes and variables on Python metric group
Key: FLINK-16671
URL: https://issues.apache.org/jira/browse/FLINK-16671
Project: Flink
Hequn Cheng created FLINK-16670:
---
Summary: Support User-Defined Metrics in Python UDF
Key: FLINK-16670
URL: https://issues.apache.org/jira/browse/FLINK-16670
Project: Flink
Issue Type: New
Thanks all for the votes.
So far, we have
- 3 binding +1 votes (Jincheng, Dian, and Hequn)
- 1 non-binding +1 votes (Wei)
- 0 -1 votes
I will move the FLIP to accepted!
Best, Hequn
On Thu, Mar 19, 2020 at 2:07 PM Hequn Cheng wrote:
> +1 (binding)
>
> Best, Hequn
>
>
t; wrote:
> >
> >> +1
> >>
> >> Best,
> >> Jincheng
> >>
> >>
> >>
> >> Hequn Cheng 于2020年3月16日周一 上午10:01写道：
> >>
> >>> Hi everyone,
> >>>
> >>> I'd like to start the vote of FLIP-112[1] w
+1 (binding)
Best,
Hequn
> On Mar 17, 2020, at 5:03 PM, Benchao Li wrote:
>
> +1 (non-binding)
>
> BTW it's in the same thread in my gmail too.
>
>
>
> Kurt Young 于2020年3月17日周二 上午11:47写道：
>
>> Looks like I hit the gmail's bug again...
>>
>> Best,
>> Kurt
>>
>>
>> On Tue, Mar 17, 2020 a
Hi everyone,
I'd like to start the vote of FLIP-112[1] which is discussed and reached
consensus in the discussion thread[2].
The vote will be open for at least 72 hours. Unless there is an objection,
I will try to close it by March 19, 2020 03:00 UTC if we have received
sufficient votes.
Thanks,
nitoring the running state of Python UDF.
>
> Best,
> Jincheng
>
>
> Hequn Cheng 于2020年3月12日周四 下午11:39写道：
>
> > @Dian Fu Thanks a lot for the advice. The FLIP
> > page has been updated.
> >
> > Best,
> > Hequn
> >
> > On Thu, Mar 12, 2020 at
Big +1 on this feature! It would be great to extend the usage of Python UDF
in SQL scenarios.
The design doc looks good from my side now. Thank you for the update.
Best,
Hequn
On Tue, Mar 10, 2020 at 3:50 PM Wei Zhong wrote:
> Hi Timo,
>
> Thanks for your reply.
>
> If we aim for the option 1,
n.
> >>
> >> +1 for this feature.
> >> I think this feature will be extremely convenient for PyFlink users.
> >>
> >> Best,
> >> Xingbo
> >>
> >> Hequn Cheng 于2020年3月9日周一 上午11:32写道：
> >>
> >>> Hi everyone,
> >
Good idea! +1 for dropping the BucketingSink.
Best,
Hequn
> On Mar 12, 2020, at 10:40 PM, Robert Metzger wrote:
>
> Hi all,
>
> I'm currently investigating a failing end to end test for the bucketing
> sink [1].
> The bucketing sink has been deprecated in the 1.9 release [2], because we
> have
Hequn Cheng created FLINK-16565:
---
Summary: Make Pipeline Json compitable between Java and Python if
all Pipelinestage are Java ones
Key: FLINK-16565
URL: https://issues.apache.org/jira/browse/FLINK-16565
Thanks Zhijiang and Piotr for kicking off the discussion and providing the
detailed list.
This would be very helpful for tracking the features.
BTW, as for PyFlink, it would be great if the feature list can also include
the following features:
- FLIP-112: Support User-Defined Metrics in Python UDF
Hi,
Thanks a lot for raising the discussion @Stephan.
+1 to increase the visibilities of the Stateful Functions.
Another option I'm think is adding a section(named Stateful Functions or
Flink Projects?)
under the "Latest Blog Posts". The advantage is we can add a picture and
some descriptions her
Hi Yu,
Thanks a lot for raising the discussion and volunteer as the release
manager!
I found there are some other issues[1] which are marked as a blocker:
- FLINK-16454 Update the copyright year in NOTICE files
- FLINK-16262 Class loader problem with
FlinkKafkaProducer.Semantic.EXACTLY_ONCE and u
Hi everyone,
FLIP-58 adds the support for Python UDFs, but user-defined metrics
have not been supported yet. With metrics, users can report and monitor
the UDF status to get a deeper understanding of the execution,
so in this FLIP, we want to support metrics for Python UDFs.
Previously, Jincheng
Hi,
Thank you all for the discussion!
On one hand, due to the network problem, the "Squash and merge" button is
very helpful. I’m also getting more and more rely on it as it is also very
convenient.
On the other hand, I think the concerns raised by Stephan are valid and we
should pay attention t
Hi Niels,
Thanks a lot for your contribution!
The rule has been changed now. As the contribution guide said, only
committers have the permission to assign somebody.
Feel free to ask committers to assign the jira to you with a comment under
the jira once all requirements for the ticket are met.
T
Hi,
+1 to make flink-streaming-java an API only module and solve it sooner
rather than later.
It would be more clear to only expose an SDK module for writing jobs.
Another benefit I can see is: the flink-streaming-java would be scala-free
if we reverse the dependencies and this would be really ni
1 - 100 of 394 matches
Mail list logo
