Apply for Contributor Permission

Hi guys: Could somebody give me contributor permissions? my jira username is : zhongwei. Thanks.

Re: [VOTE] Release Apache Flink 1.6.4, release candidate #1

+1 (non-binding) - compiled from source - started standalone cluster and tried a WordCount example. Best, Wei > 在 2019年2月20日，上午5:59，Fabian Hueske 写道： > > +1 (binding) > > * checked commit diff since Flink 1.6.3, did not find any added non-AL2 > dependencies > * checked signatures and

Re: [ANNOUNCE] Apache Flink 1.6.4 released

Thanks a lot for the great release Jincheng. Great work! > 在 2019年2月28日，上午8:22，jincheng sun 写道： > > Sorry Chesnay, we have discussed when will remove 1.6.3 files, when we > added the 1.6.4 files. Just like Robert mentioned above! > Anyway thanks for your reminder @Chesnay Schepler ! > And

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations Jincheng! Best, Wei > 在 2019年6月25日，15:18，JingsongLee 写道： > > Jincheng, Congratulations! > > Best, JingsongLee > > > -- > From:Dawid Wysakowicz > Send Time:2019年6月25日(星期二) 14:21 > To:dev > Subject:Re:

Re: [ANNOUNCE] Jincheng Sun is now part of the Flink PMC

Congratulations Jincheng! Best, Wei > 在 2019年6月25日，15:18，JingsongLee 写道： > > Jincheng, Congratulations! > > Best, JingsongLee > > > -- > From:Dawid Wysakowicz > Send Time:2019年6月25日(星期二) 14:21 > To:dev > Subject:Re:

Re: [VOTE] FLIP-58: Flink Python User-Defined Function for Table API

Hi Dian, +1 non-binding Thanks for driving this! Best, Wei > 在 2019年8月29日，09:25，Hequn Cheng 写道： > > Hi Dian, > > +1 > Thanks a lot for driving this. > > Best, Hequn > > On Wed, Aug 28, 2019 at 2:01 PM jincheng sun > wrote: > >> Hi Dian, >> >> +1, Thanks for your great job! >> >> Best,

Re: [ANNOUNCE] Hequn becomes a Flink committer

Congratulations, Hequn! Best, Wei Zhong > 在 2019年8月7日，17:15，Zili Chen 写道： > > Congrats Hequn! > > Best, > tison. > > > Jeff Zhang mailto:zjf...@gmail.com>> 于2019年8月7日周三 下午5:14写道： > Congrats Hequn! > > Paul Lam mailto:paullin3...@gmail.com>>

[DISCUSS] Flink Python UDF Environment and Dependency Management

Hi everyone, In FLIP-58 [1] we have a plan to support Python UDF. As a critical part of python UDF, the environment and dependency management of users' python code has not been fully discussed. I'd like to start a discussion on "Flink Python UDF Environment and Dependency Management". Here is

Re: [ANNOUNCE] Jark Wu is now part of the Flink PMC

Congratulations Jark！ Best, Wei > 在 2019年11月8日，19:36，Zhijiang 写道： > > Congratulations Jark! > > Best, > Zhijiang > > > -- > From:bupt_ljy > Send Time:2019 Nov. 8 (Fri.) 19:21 > To:dev ; dev@flink.apache.org Yun Gao > >

[VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78)

Hi all, According to our previous discussion in [1], I'd like to bring up a vote to apply the adjustment [2] to the command-line option design of FLIP-78 [3]. The vote will be open for at least 72 hours unless there is an objection or not enough votes. Best, Wei [1]

Re: [DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78)

he PR. >>> >>> What do you think? >>> >>> Best, >>> Jincheng >>> >>> Aljoscha Krettek 于2019年12月4日周三 下午5:11写道： >>> >>>> Perfect, thanks for the background info! I also found this section now, >>

Re: [VOTE] Release 1.8.3, release candidate #3

+1 (non-binding) - verified signatures and checksums - built from sources with Scala 2.11 and Scala 2.12 - ran examples on a yarn cluster in attached mode and detached mode > 在 2019年12月11日，10:20，Hequn Cheng 写道： > > +1 (non-binding) > > - check release note > - check signatures and hashes > -

Re: [ANNOUNCE] Feature freeze for Apache Flink 1.10.0 release

Hi Yu & Gary, Great work! Looking forward to the 1.10 release. :) Best, Wei > 在 2019年12月11日，14:20，Dian Fu 写道： > > Hi Yu & Gary, > > Thanks for your great work. Looking forward to the 1.10 release. > > Regards, > Dian > >> 在 2019年12月11日，上午10:29，Danny Chan 写道： >> >> Hi Yu & Gary, >> >>

Re: [ANNOUNCE] Apache Flink 1.8.3 released

Thanks Hequn for being the release manager. Great work! Best, Wei > 在 2019年12月12日，15:27，Jingsong Li 写道： > > Thanks Hequn for your driving, 1.8.3 fixed a lot of issues and it is very > useful to users. > Great work! > > Best, > Jingsong Lee > > On Thu, Dec 12, 2019 at 3:25 PM jincheng sun

Re: [VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78)

>>>> Regards, >>>> Dian >>>> >>>>> 在 2019年12月5日，上午11:11，Jark Wu 写道： >>>>> >>>>> +1 (binding) >>>>> >>>>> Best, >>>>> Jark >>>>> >>>>>

[RESULT][VOTE] Improve the Pyflink command line options (Adjustment to FLIP-78)

Hi all, The voting time for "Improve the Pyflink command line options (Adjustment to FLIP-78)" has passed. I'm closing the vote now. There were 5 +1 votes, 4 of which are binding: - Jark (binding) - Jincheng (binding) - Hequn (binding) - Aljoscha (binding) - Dian (non-binding) There were no

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

>>>>>> not the best for performance as it will introduce an additional >>>>> network >>>>>>>> transmission, as in process mode TaskManager and python worker share >>>>>> the >>>>>>&g

[RESULT][VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

has been accepted. Thanks everyone for joining the discussion and giving feedback! Best, Wei > 在 2019年10月28日，15:06，Wei Zhong 写道： > > Thanks everyone for the votes! > I’ll summarize the voting result in a separate email. > > Best, > Wei > >> 在 2019年10月28日，11:38，j

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

> >>>> Hi Wei, >>>> >>>> +1 (non-binding). Thanks for driving this. >>>> >>>> Thanks, >>>> Dian >>>> >>>>> 在 2019年10月14日，下午1:40，jincheng sun 写道： >>>>> >>>>> +1 >&g

Re: [VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

, >>>>> Jincheng >>>>> >>>>> Maximilian Michels 于2019年10月16日周三 下午4:23写道： >>>>> >>>>>> I'm also late to the party here :) When I saw the first draft, I >> was >>>>>> thinking ho

Re: [ANNOUNCE] Becket Qin joins the Flink PMC

Congratulations Becket! Best, Wei > 在 2019年10月29日，09:36，Paul Lam 写道： > > Congrats Becket! > > Best, > Paul Lam > >> 在 2019年10月29日，02:18，Xingcan Cui 写道： >> >> Congratulations, Becket! >> >> Best, >> Xingcan >> >>> On Oct 28, 2019, at 1:23 PM, Xuefu Z wrote: >>> >>> Congratulations,

[DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78)

Hi everyone, I wanted to bring up the discussion of improving the Pyflink command line options. A few command line options have been introduced in the FLIP-78 [1], i.e. "python-executable-path", "python-requirements","python-archive", etc. There are a few problems with these options, i.e. the

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

ssion, Wei. >> Overall the design doc looks good. I have left a few comments. >> >> BTW: Dependency Management is very important for Python UDFs, welcome >> anyone left your suggestions! >> >> Best, >> Jincheng >> >> Wei Zhong 于2

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

Hi Jincheng, As communicated in this email thread, I’m proposing to convert the design doc to a FLIP and bring up the VOTE. It would be great if you can grant me the write access to Confluence :). My Confluence ID is zhongwei. Thanks, Wei Zhong > 在 2019年10月12日，17:41，jincheng sun 写道： >

Re: [DISCUSS] Flink Python UDF Environment and Dependency Management

Thank you Jincheng. I have got the permission. > 在 2019年10月12日，18:09，jincheng sun 写道： > > Hi Wei Zhong, > > I have given you edit permission, could you please re-login and check it. :) > > Best, > Jincheng > > > Wei Zhong mailto:weizhong0...@gmail.com&g

[VOTE] FLIP-78: Flink Python UDF Environment and Dependency Management

Hi all, I would like to start the vote for FLIP-78[1] which is discussed and reached consensus in the discussion thread[2]. The vote will be open for at least 72 hours. I'll try to close it by 2019-10-16 18:00 UTC, unless there is an objection or not enough votes. Thanks, Wei [1]

Re: [DISCUSS] Improve the Pyflink command line options (Adjustment to FLIP-78)

; Side note: I don’t like that our options use camel-case, I think that’s very > non-standard. But that’s how it is now… > > Best, > Aljoscha > >> On 3. Dec 2019, at 10:14, jincheng sun wrote: >> >> Thanks for bringup this discussion Wei! >> I think this

Re: [VOTE] Release Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #1

Hi, Thanks for driving this, Jincheng. +1 (non-binding) - Verified signatures and checksums. - Verified README.md and setup.py. - Run `pip install apache-flink-1.9.2.tar.gz` in Python 2.7.15 and Python 3.7.5 successfully. - Start local pyflink shell in Python 2.7.15 and Python 3.7.5 via

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

part of > this flip already. Nevertheless this in theory can be also done later. > > Best, > Dawid > > On Mon, 2 Mar 2020, 14:58 Jark Wu, wrote: > >> Thanks for the explanation, Wei! >> >> On Mon, 2 Mar 2020 at 20:59, Wei Zhong wrote: >> >>

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

re >> implemented in Java. However some python developers are not familiar with >> Java/Scala, and it's very inconvenient for these users to use UDF in SQL. >> >> Wei Zhong 于2020年2月28日周五 下午6:58写道： >> >>> Thank for your reply Dan! >>> >

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

Thank for your reply Dan! By the way, this FLIP is closely related to the SQL API. @Jark Wu @Timo could you please take a look? Thanks, Wei > 在 2020年2月25日，16:25，zoudan 写道： > > +1 for supporting Python UDF in Java/Scala Table API. > This is a great feature and would be helpful for python

[DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

Hi everyone, I would like to start discussion about how to support Python UDF in SQL Function DDL. The SQL Function DDL(FLIP-79[1]) is a great feature which was introduced in the release of 1.10.0. However, it currently only supports creating Java/Scala UDF in the SQL Function DDL. Although

Re: [VOTE] FLIP-27 - Refactor Source Interface

+1 (non-binding), thanks for driving this! Best, Wei > 在 2020年2月4日，11:47，Danny Chan 写道： > > +1 (non-binding), thanks for the great work ! > > Best, > Danny Chan > 在 2020年2月4日 +0800 AM11:20，dev@flink.apache.org，写道： >> >> +1 (non-binding), thanks for driving. >> FLIP-27 is the basis of a lot

Re: [DISCUSS] Upload the Flink Python API 1.9.x to PyPI for user convenience.

Hi Jincheng, Thanks for bring up this discussion! +1 for this proposal. Building from source takes long time and requires a good network environment. Some users may not have such an environment. Uploading to PyPI will greatly improve the user experience. Best, Wei jincheng sun 于2020年2月4日周二

Re: [VOTE] Release Flink Python API(PyFlink) 1.9.2 to PyPI, release candidate #0

Hi, Thanks for driving this, Jincheng. +1 (non-binding) - Verified signatures and checksums. - `pip install apache-flink-1.9.2.tar.gz` successfully. - Start local pyflink shell via `pyflink-shell.sh local` and try the examples in the help message, run well and no exception. - Try a word count

Re: [ANNOUNCE] Dian Fu becomes a Flink committer

Congrats Dian Fu! Well deserved! Best, Wei > 在 2020年1月16日，18:10，Hequn Cheng 写道： > > Congratulations, Dian. > Well deserved! > > Best, Hequn > > On Thu, Jan 16, 2020 at 6:08 PM Leonard Xu > wrote: > Congratulations! Dian Fu > > Best, > Leonard > >> 在

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

aim for your proposed option 1. For fluent definition of functions > in Table API, we would still like to offer passing instances like > `t.select(call(new ScalarFunction() { ... }))` that would be registered as > temporary system functions. > > Regrds, > Timo > > > On

Re: [DISCUSS] FLIP-112: Support User-Defined Metrics for Python UDF

Hi Hequn, Thanks for driving this. +1 for the metrics support for Python UDF, which makes it much easier for users to monitor the execution of Python UDFs. Best, Wei > 在 2020年3月10日，15:32，Xingbo Huang 写道： > > Hi Hequn, > thanks for drafting the FLIP and kicking off the discussion. > > +1

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

Hi Dawid, I think defering the instantiation of temporary functions to compile time is quite a good idea but needs further discussion. As it is orthogonal with this FLIP, we could continue the discussion in a new thread later. What do you think? Best, Wei > 在 2020年3月5日，21:11，Wei Zhong

[DISCUSS] FLIP-114: Support Python UDF in SQL Client

Hi everyone, I would like to start discussion about how to support Python UDF in SQL Client. Flink Python UDF(FLIP-58[1]) has already been introduced in the release of 1.10.0 and the support for SQL DDL is introduced in FLIP-106[2]. SQL Client defines UDF via the environment file and has its

[VOTE] FLIP-106: Support Python UDF in SQL Function DDL

Hi all, I would like to start the vote for FLIP-106[1] which is discussed and reached consensus in the discussion thread[2]. The vote will be open for at least 72 hours. I'll try to close it by 2020-03-18 14:00 UTC, unless there is an objection or not enough votes. Best, Wei [1]

Re: [DISCUSS] FLIP-106: Support Python UDF in SQL Function DDL

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

Re: [DISCUSS] FLIP-120: Support conversion between PyFlink Table and Pandas DataFrame

Hi Dian, Thanks for driving this. Big +1 for supporting from/to pandas in PyFlink! Best, Wei > 在 2020年4月3日，13:46，jincheng sun 写道： > > +1, Thanks for bring up this discussion @Dian Fu > > Best, > Jincheng > > > Jeff Zhang 于2020年4月1日周三 下午1:27写道： > >> Thanks for the reply, Dian, that make

Re: [VOTE] FLIP-114: Support Python UDF in SQL Client

st, >> Hequn >> >> On Fri, Apr 3, 2020 at 10:20 AM jincheng sun >> wrote: >> >>> +1(binding) >>> >>> Best, >>> Jincheng >>> >>> >>> >>> Xingbo Huang 于2020年4月1日周三 下午5:36写道： >>> >>&

[RESULT][VOTE] FLIP-114: Support Python UDF in SQL Client

Hi all, The voting time for FLIP-114 has passed. I'm closing the vote now. There were 4 +1 votes, 3 of which are binding: - Jincheng (binding) - Hequn (binding) - Dian (binding) - Xingbo (non-binding) There were no disapproving votes. Thus, FLIP-114 has been accepted. Thanks everyone for

[VOTE] FLIP-114: Support Python UDF in SQL Client

Hi all, I would like to start the vote for FLIP-114[1] which is discussed and reached consensus in the discussion thread[2]. The vote will be open for at least 72 hours. I'll try to close it by 2020-04-03 03:00 UTC, unless there is an objection or not enough votes. Best, Wei [1]

Re: [DISCUSS] FLIP-114: Support Python UDF in SQL Client

how to start sql-client.sh with full python >> dependencies. >> >> Best, >> Godfrey >> >> Wei Zhong 于2020年3月9日周一 下午10:09写道： >> >>> Hi everyone, >>> >>> I would like to start discussion about how to support Python UDF in SQL >>

Re: [VOTE] Release 1.10.1, release candidate #3

+1 (non-binding) - checked signatures - the python package looks good - the python shell looks good - submitted a python job on local cluster Best, Wei > 在 2020年5月12日，11:42，Zhu Zhu 写道： > > +1 (non-binding) > > - checked release notes > - checked signatures > - built from source > - submitted

Re: [VOTE] FLIP-112: Support User-Defined Metrics for Python UDF

+1 (non-binding) Best, Wei > 在 2020年3月17日，19:15，Dian Fu 写道： > > +1 (binding) > > On Tue, Mar 17, 2020 at 10:35 AM jincheng sun > wrote: > >> +1 >> >> Best, >> Jincheng >> >> >> >> Hequn Cheng 于2020年3月16日周一 上午10:01写道： >> >>> Hi everyone, >>> >>> I'd like to start the vote of

[RESULT][VOTE] FLIP-106: Support Python UDF in SQL Function DDL

. Thanks everyone for joining the discussion and giving feedback! Best, Wei > 在 2020年3月19日，09:53，Wei Zhong 写道： > > Thanks everyone for the votes! > I’ll summarize the voting result in a separate email. > > Best, > Wei > >> 在 2020年3月18日，15:37，zoudan 写道： >> >

Re: [VOTE] FLIP-106: Support Python UDF in SQL Function DDL

Thanks everyone for the votes! I’ll summarize the voting result in a separate email. Best, Wei > 在 2020年3月18日，15:37，zoudan 写道： > > +1 (non-binding) > > Best, > Dan Zou >

Re: [VOTE] FLIP-106: Support Python UDF in SQL Function DDL

17, 2020 at 10:36 AM jincheng sun > wrote: > >> +1 >> >> Best, >> Jincheng >> >> >> >> Wei Zhong 于2020年3月13日周五 下午9:04写道： >> >>> Hi all, >>> >>> I would like to start the vote for FLIP-106[1] which is discuss

Re: [DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API

Hi everyone, Are there more comments about this FLIP? If not, I would like to bring up the VOTE. Best, Wei > 在 2020年9月1日，11:15，Wei Zhong 写道： > > Hi Timo, > > Thanks for your notification. I’ll remove it from the design doc. > > Best, > Wei > >> 在

Re: [DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API

t; > Regards, > Timo > > On 31.08.20 15:00, Wei Zhong wrote: >> Hi Jincheng & Xingbo, >> Thanks for your suggestions. >> I agree that we should keep the user interface uniform. I'll adjust the >> design to allow users to specify the result type and accumulat

Re: [VOTE] FLIP-139: General Python User-Defined Aggregate Function on Table API

; Regards, >> Dian >> >>> 在 2020年9月8日，上午7:43，jincheng sun 写道： >>> >>> +1(binding) >>> >>> Best, >>> Jincheng >>> >>> Xingbo Huang 于2020年9月7日周一 下午5:45写道： >>> >>>> Hi, >>>> >&g

[RESULT][VOTE] FLIP-139: General Python User-Defined Aggregate Function on Table API

Hi all, The voting time for FLIP-139 has passed. I'm closing the vote now. There were 4 +1 votes, 3 of which are binding: - Jincheng (binding) - Dian (binding) - Hequn (binding) - Xingbo (non-binding) There were no disapproving votes. Thus, FLIP-139 has been accepted. Thanks everyone for

Re: [VOTE] FLIP-137: Support Pandas UDAF in PyFlink

+1 (non-binding) > 在 2020年9月7日，10:00，Dian Fu 写道： > > +1 > >> 在 2020年9月4日，上午11:12，Xingbo Huang 写道： >> >> Hi all, >> I would like to start the vote for FLIP-137[1], which is discussed and >> reached a consensus in the discussion thread[2]. >> >> The vote will be open for at least 72h, unless

[VOTE] FLIP-139: General Python User-Defined Aggregate Function on Table API

Hi all, I would like to start the vote for FLIP-139[1] which is discussed and reached consensus in the discussion thread[2]. The vote will be open for at least 72 hours. I'll try to close it by 2020-09-10 07:00 UTC, unless there is an objection or not enough votes. Best, Wei [1]

Re: [DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API

e @udaf added by flip-137 be used in General Python >> UDAF? >> Would be gread if we can consider it combination with FLIP-137 for design. >> >> What do you think? >> >> Best, >> Jincheng >> >> Wei Zhong 于2020年8月26日周三 上午11:28写道： >> >>>

[DISCUSS] FLIP-139: General Python User-Defined Aggregate Function on Table API

Hi everyone, I would like to start discussion about how to support General Python User-Defined Aggregate Function on Table API. FLIP-58[1] has already introduced the stateless Python UDF and has already been supported in the previous releases. However the stateful Python UDF, i.e.

Re: [ANNOUNCE] New PMC member: Dian Fu

Congratulations Dian! > 在 2020年8月28日，14:29，Jingsong Li 写道： > > Congratulations , Dian! > > Best, Jingsong > > On Fri, Aug 28, 2020 at 11:06 AM Walter Peng > wrote: > congrats! > > Yun Tang wrote: > > Congratulations , Dian! > > > -- > Best, Jingsong Lee

Re: [ANNOUNCE] Apache Flink 1.11.1 released

Congratulations! Thanks Dian for the great work! Best, Wei > 在 2020年7月22日，15:09，Leonard Xu 写道： > > Congratulations! > > Thanks Dian Fu for the great work as release manager, and thanks everyone > involved! > > Best > Leonard Xu > >> 在 2020年7月22日，14:52，Dian Fu 写道： >> >> The Apache Flink

Re: [VOTE] FLIP-133: Rework PyFlink Documentation

+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 discussion and voting. Could you please have a >> look at the discussion thread. >> It would be great to

Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation

gt; >> improve the Python API doc. > >>> >> > >>> >> I have received many feedbacks from PyFlink beginners about > >>> >> the PyFlink doc, e.g. the materials are too few, the Python doc is > >>> mixed > >>> >&

Re: [DISCUSS] FLIP-130: Support for Python DataStream API (Stateless Part)

Hi Shuiqiang, Thanks for driving this. Big +1 for supporting DataStream API in PyFlink! Best, Wei > 在 2020年7月9日，10:29，Hequn Cheng 写道： > > +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

Re: flink 1.11 CREATE VIEW + LATERAL TABLE 语法校验问题

Hi XiaChang, I think this is a bug. Others have encountered similar problems before. I have create a JIRA for it: https://issues.apache.org/jira/browse/FLINK-18750 Best, Wei > 在 2020年7月29日，15:00，XiaChang <13628620...@163.com> 写道： > >

Re: [ANNOUNCE] Welcome Danny Cranmer as a new Apache Flink Committer

Congratulations Danny! Best, Wei > 在 2021年1月12日，19:09，hailongwang <18868816...@163.com> 写道： > > Congratulations Danny! > > Best, > Hailong在 2021-01-12 17:05:31，"Jark Wu" 写道： >> Congratulations Danny! >> >> Best, >> Jark >> >> On Tue, 12 Jan 2021 at 17:59, Yangze Guo wrote: >> >>>

Re: Urgent help on S3 CSV file reader DataStream Job

Hi Deep, (redirecting this to user mailing list as this is not a dev question) You can try to set the line delimiter and field delimiter of the RowCsvInputFormat to a non-printing character (assume there is no non-printing characters in the csv files). It will read all the content of a csv

Re: [ANNOUNCE] Apache Flink 1.12.0 released

Congratulations! Thanks Dian and Robert for the great work! Best, Wei > 在 2020年12月10日，20:26，Leonard Xu 写道： > > > Thanks Dian and Robert for the great work as release manager ! > And thanks everyone who makes the release possible ! > > > Best, > Leonard > >> 在 2020年12月10日，20:17，Robert

Re: [DISCUSS] Make SQL docs Blink only

+1 This is a very good proposal. The Python Table API documentation also contains some code that still uses the old planner. We may need to do the same for the Python Table API documentation in the future. Best, Wei > 在 2020年12月9日，12:35，Jark Wu 写道： > > +1 > > This is a very good idea. > >

Re: [VOTE] Release 1.12.0, release candidate #3

+1 (non-binding) - verified checksums and signatures - build Flink with Scala 2.11 - pip install pyflink on Windows python 3.7 - run a python job with udfs on Windows - pyflink shell works well on local mode and remote mode Best, Wei > 在 2020年12月4日，17:21，Yang Wang 写道： > > +1 (non-binding) >

Re: [DISCUSS] FLIP-153: Support state access in Python DataStream API

Hi Shuiqiang, Thanks for driving this. +1 for this feature, just a minor comment to the design doc. The interface of the `AppendingState` should be: class AppendingState(State, Generic[IN, OUT]): @abstractmethod def get(self) -> OUT: pass @abstractmethod def add(self,

Re: [DISCUSS] Enforce common opinionated coding style using Spotless

+1 for the coding style automation. Thanks for driving this! Best, Wei > 在 2020年12月17日，10:10，Xingbo Huang 写道： > > +1 asap. Spotless can greatly help us save the time of fixing checkstyle > errors. > > Best, > Xingbo > > Kostas Kloudas 于2020年12月17日周四 上午4:14写道： > >> +1 asap from my side as

Re: [ANNOUNCE] Apache Flink 1.12.1 released

Thanks Xintong for the great work! Best, Wei > 在 2021年1月19日，18:00，Guowei Ma 写道： > > Thanks Xintong's effort! > Best, > Guowei > > > On Tue, Jan 19, 2021 at 5:37 PM Yangze Guo > wrote: > Thanks Xintong for the great work! > > Best, > Yangze Guo > > On Tue, Jan

Re: [DISCUSS] FLIP-157 Migrate Flink Documentation from Jekyll to Hugo

+1 for migrating to Hugo. Currently we have developed many plugins based on Jekyll because the native features of Jekyll cannot meet our needs. It seems all of them can be supported via Hugo shortcodes and will become more concise. Best, Wei > 在 2021年1月14日，18:21，Aljoscha Krettek 写道： > > +1

Re: [VOTE] Release 1.12.1, release candidate #2

+1 (non-binding) - verified checksums and signatures - build Flink from source code - pip install PyFlink source distribution and run a python udf job on MacOS/Win10 - start a standalone cluster on MacOS and submit a python udf job - the documentation pages built from source look good Best, Wei

Re: [DISCUSS] FLIP-155: Introduce a few convenient operations in Table API

Hi Dian, Big +1 for making the Table API easier to use. Java users and Python users can both benefit from it. I think it would be better if we add some Python API examples. Best, Wei > 在 2021年1月4日，20:03，Dian Fu 写道： > > Hi all, > > I'd like to start a discussion about introducing a few

Re: [VOTE] Release 1.11.3, release candidate #2

+1 (non-binding) - verified checksums and signatures - pip install pyflink on Windows python 3.7 - run a python job with udfs on Windows Best, Wei > 在 2020年12月16日，15:51，Dian Fu 写道： > > +1 (binding) > > - Verified the checksum and signature > - Checked the pom changes since 1.11.2 for the

Re: [VOTE] FLIP-153: Support state access in Python DataStream API

+1 (non-binding) Best, Wei > 在 2021年1月6日，14:05，Xingbo Huang 写道： > > +1 (non-binding) > > Best, > Xingbo > > Dian Fu 于2021年1月6日周三 下午1:38写道： > >> +1 (binding) >> >>> 在 2021年1月6日，下午1:12，Shuiqiang Chen 写道： >>> >>> Hi devs, >>> >>> The discussion of the FLIP-153 [1] seems has reached a

Re: Re: [ANNOUNCE] New Apache Flink Committers - Wei Zhong and Xingbo Huang

iang 于2021年2月23日周二 上午10:59写道： > > > > > > > Congratulations Wei and Xingbo! > > > > > > > > > > > > Best, > > > > Zhijiang > > > > > > > > > > > > -----------

Re: [DISCUSS] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

Hi Xingbo, Thanks for creating this FLIP. Big +1 for it! I have some question about the Thread Mode: 1. It seems that we dynamically load an embedded Python and user dependencies in the TM process. Can they be uninstalled cleanly after the task finished? i.e. Can we use the Thread Mode in

Re: [VOTE] FLIP-206: Support PyFlink Runtime Execution in Thread Mode

+1(binding) Best, Wei > 2022年1月12日 下午5:58，Xingbo Huang 写道： > > Hi all, > > I would like to start the vote for FLIP-206[1], which was discussed and > reached a consensus in the discussion thread[2]. > > The vote will be open for at least 72h, unless there is an objection or not > enough

Re: [ANNOUNCE] Apache Flink 1.16.0 released

Congratulations! Thank you very much! Thanks Xingbo for managing the release. Best, Wei > 2022年10月28日 下午6:10，yuxia 写道： > > Congratulations! > > Best regards, > Yuxia > > - 原始邮件 - > 发件人: "Márton Balassi" > 收件人: "dev" > 发送时间: 星期五, 2022年 10 月 28日 下午 5:59:42 > 主题: Re: [ANNOUNCE]

Re: [ANNOUNCE] New Apache Flink PMC Members - Godfrey He, Xingbo Huang

Congratulations, Godfrey and Xingbo! Best, Wei > 2022年11月23日 下午3:29，Shuiqiang Chen 写道： > > Congratulations, Godfrey and Xingbo! > > Best, > Shuiqiang > > Runker Hanna 于2022年11月23日周三 15:28写道： > >> Congrats, Godfrey and Xingbo! >> >> Best, >> Runkang He >> >> Lincoln Lee 于2022年11月23日周三

Re: [ANNOUNCE] New Apache Flink Committer - Rui Fan

Congratulations, Rui! Best, Wei > 2023年2月21日 下午1:52，Shammon FY 写道： > > Congratulations, Rui! > > > Best, > Shammon > > On Tue, Feb 21, 2023 at 1:40 PM Sergey Nuyanzin wrote: > >> Congratulations, Rui! >> >> On Tue, Feb 21, 2023 at 4:53 AM Weihua Hu wrote: >> >>> Congratulations, Rui!

Re: [ANNOUNCE] New Apache Flink PMC Member - Fan Rui

Congratulations, Rui! Best, Wei > 2024年6月6日 09:16，Lincoln Lee 写道： > > Congratulations, Rui! > > Best, > Lincoln Lee > > > Lijie Wang 于2024年6月6日周四 09:11写道： > >> Congratulations, Rui! >> >> Best, >> Lijie >> >> Rodrigo Meneses 于2024年6月5日周三 21:35写道： >> >>> All the best >>> >>> On Wed,

[jira] [Created] (FLINK-12588) Add TableSchema for Python Table API

Wei Zhong created FLINK-12588: - Summary: Add TableSchema for Python Table API Key: FLINK-12588 URL: https://issues.apache.org/jira/browse/FLINK-12588 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-13077) CatalogPartitionAPICompletenessTests in pyflink failed because of lacking "getComment" method

Wei Zhong created FLINK-13077: - Summary: CatalogPartitionAPICompletenessTests in pyflink failed because of lacking "getComment" method Key: FLINK-13077 URL: https://issues.apache.org/jira/browse/F

[jira] [Created] (FLINK-13809) The log directory of Flink Python API is unwritable if it is installed via "sudo"

Wei Zhong created FLINK-13809: - Summary: The log directory of Flink Python API is unwritable if it is installed via "sudo" Key: FLINK-13809 URL: https://issues.apache.org/jira/browse/FLINK-13809

[jira] [Created] (FLINK-13578) Blink throws exception when using Types.INTERVAL_MILLIS in TableSource

Wei Zhong created FLINK-13578: - Summary: Blink throws exception when using Types.INTERVAL_MILLIS in TableSource Key: FLINK-13578 URL: https://issues.apache.org/jira/browse/FLINK-13578 Project: Flink

[jira] [Created] (FLINK-13594) Improve the 'from_element' method of flink python api to apply to blink planner

Wei Zhong created FLINK-13594: - Summary: Improve the 'from_element' method of flink python api to apply to blink planner Key: FLINK-13594 URL: https://issues.apache.org/jira/browse/FLINK-13594 Project

[jira] [Created] (FLINK-13368) Add Configuration for Python Table API to Align with Java

Wei Zhong created FLINK-13368: - Summary: Add Configuration for Python Table API to Align with Java Key: FLINK-13368 URL: https://issues.apache.org/jira/browse/FLINK-13368 Project: Flink Issue

[jira] [Created] (FLINK-14150) Unnecessary __pycache__ directories appears in pyflink.zip

Wei Zhong created FLINK-14150: - Summary: Unnecessary __pycache__ directories appears in pyflink.zip Key: FLINK-14150 URL: https://issues.apache.org/jira/browse/FLINK-14150 Project: Flink Issue

[jira] [Created] (FLINK-14198) Add type options to all flink python API doc

Wei Zhong created FLINK-14198: - Summary: Add type options to all flink python API doc Key: FLINK-14198 URL: https://issues.apache.org/jira/browse/FLINK-14198 Project: Flink Issue Type

[jira] [Created] (FLINK-14140) The Flink Logo Displayed in Flink Python Shell is Broken

Wei Zhong created FLINK-14140: - Summary: The Flink Logo Displayed in Flink Python Shell is Broken Key: FLINK-14140 URL: https://issues.apache.org/jira/browse/FLINK-14140 Project: Flink Issue

[jira] [Created] (FLINK-14604) Bump commons-cli to 1.4

Wei Zhong created FLINK-14604: - Summary: Bump commons-cli to 1.4 Key: FLINK-14604 URL: https://issues.apache.org/jira/browse/FLINK-14604 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-14591) Execute PlannerBase#mergeParameters every time of calling PlannerBase#translate method

Wei Zhong created FLINK-14591: - Summary: Execute PlannerBase#mergeParameters every time of calling PlannerBase#translate method Key: FLINK-14591 URL: https://issues.apache.org/jira/browse/FLINK-14591

[jira] [Created] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

Wei Zhong created FLINK-14590: - Summary: Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py" Key: FLINK-14590 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-15194) Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode

Wei Zhong created FLINK-15194: - Summary: Directories in distributed caches are not extracted in Yarn Per Job Cluster Mode Key: FLINK-15194 URL: https://issues.apache.org/jira/browse/FLINK-15194 Project

[jira] [Created] (FLINK-15244) FileUtils#deleteDirectoryQuietly will delete files in the symbolic link which point to a directory

Wei Zhong created FLINK-15244: - Summary: FileUtils#deleteDirectoryQuietly will delete files in the symbolic link which point to a directory Key: FLINK-15244 URL: https://issues.apache.org/jira/browse/FLINK-15244

  1   2   >