[jira] [Created] (FLINK-31184) Failed to get python udf runner directory via running GET_RUNNER_DIR_SCRIPT

Wei Zhong created FLINK-31184: - Summary: Failed to get python udf runner directory via running GET_RUNNER_DIR_SCRIPT Key: FLINK-31184 URL: https://issues.apache.org/jira/browse/FLINK-31184 Project

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!

[jira] [Created] (FLINK-30245) NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method

Wei Zhong created FLINK-30245: - Summary: NPE thrown when filtering decimal(18, 4) values after calling DecimalDataUtils.subtract method Key: FLINK-30245 URL: https://issues.apache.org/jira/browse/FLINK-30245

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] 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]

[jira] [Created] (FLINK-28764) Support more than 64 distinct aggregate function calls in one aggregate SQL query

Wei Zhong created FLINK-28764: - Summary: Support more than 64 distinct aggregate function calls in one aggregate SQL query Key: FLINK-28764 URL: https://issues.apache.org/jira/browse/FLINK-28764 Project

[jira] [Created] (FLINK-27563) Resource Providers - Yarn doc page has minor display error

Wei Zhong created FLINK-27563: - Summary: Resource Providers - Yarn doc page has minor display error Key: FLINK-27563 URL: https://issues.apache.org/jira/browse/FLINK-27563 Project: Flink Issue

[jira] [Created] (FLINK-27438) SQL validation failed when constructing a map array

Wei Zhong created FLINK-27438: - Summary: SQL validation failed when constructing a map array Key: FLINK-27438 URL: https://issues.apache.org/jira/browse/FLINK-27438 Project: Flink Issue Type

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: [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

[jira] [Created] (FLINK-21969) PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data

Wei Zhong created FLINK-21969: - Summary: PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark before emitting all the data Key: FLINK-21969 URL: https://issues.apache.org/jira/browse/FLINK-21969

[jira] [Created] (FLINK-21842) Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API

Wei Zhong created FLINK-21842: - Summary: Support user defined WindowAssigner, Trigger and ProcessWindowFunction on Python DataStream API Key: FLINK-21842 URL: https://issues.apache.org/jira/browse/FLINK-21842

[jira] [Created] (FLINK-21792) Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner

Wei Zhong created FLINK-21792: - Summary: Add a PythonFunctionRunnerDescriptor and unify the creation of all the PythonFunctionRunner Key: FLINK-21792 URL: https://issues.apache.org/jira/browse/FLINK-21792

[jira] [Created] (FLINK-21679) Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan

Wei Zhong created FLINK-21679: - Summary: Set output type for transformations from SourceProvider and DataStreamScanProvider in CommonExecTableSourceScan Key: FLINK-21679 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-21509) "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time

Wei Zhong created FLINK-21509: - Summary: "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping by slide window with processing time Key: FLINK-21509 URL: https://issues.apache.o

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

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

[jira] [Created] (FLINK-21294) Support state access API for the map operation of Python ConnectedStreams

Wei Zhong created FLINK-21294: - Summary: Support state access API for the map operation of Python ConnectedStreams Key: FLINK-21294 URL: https://issues.apache.org/jira/browse/FLINK-21294 Project: Flink

[jira] [Created] (FLINK-21242) Support state access API for map operation

Wei Zhong created FLINK-21242: - Summary: Support state access API for map operation Key: FLINK-21242 URL: https://issues.apache.org/jira/browse/FLINK-21242 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-21180) Move the state module from 'pyflink.common' to 'pyflink.datastream'

Wei Zhong created FLINK-21180: - Summary: Move the state module from 'pyflink.common' to 'pyflink.datastream' Key: FLINK-21180 URL: https://issues.apache.org/jira/browse/FLINK-21180 Project: Flink

[jira] [Created] (FLINK-21179) Split the base class of Python DataStream Function to 'Function' and 'RichFunction'

Wei Zhong created FLINK-21179: - Summary: Split the base class of Python DataStream Function to 'Function' and 'RichFunction' Key: FLINK-21179 URL: https://issues.apache.org/jira/browse/FLINK-21179

[jira] [Created] (FLINK-21115) Add AggregatingState and corresponding StateDescriptor for Python DataStream API

Wei Zhong created FLINK-21115: - Summary: Add AggregatingState and corresponding StateDescriptor for Python DataStream API Key: FLINK-21115 URL: https://issues.apache.org/jira/browse/FLINK-21115 Project

[jira] [Created] (FLINK-21114) Support ReducingState in Python DataStream API

Wei Zhong created FLINK-21114: - Summary: Support ReducingState in Python DataStream API Key: FLINK-21114 URL: https://issues.apache.org/jira/browse/FLINK-21114 Project: Flink Issue Type: Sub

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

[jira] [Created] (FLINK-20963) Rewrite the example under 'flink-python/pyflink/table/examples'

Wei Zhong created FLINK-20963: - Summary: Rewrite the example under 'flink-python/pyflink/table/examples' Key: FLINK-20963 URL: https://issues.apache.org/jira/browse/FLINK-20963 Project: Flink

[jira] [Created] (FLINK-20962) Rewrite the example in 'flink-python/pyflink/shell.py'

Wei Zhong created FLINK-20962: - Summary: Rewrite the example in 'flink-python/pyflink/shell.py' Key: FLINK-20962 URL: https://issues.apache.org/jira/browse/FLINK-20962 Project: Flink Issue Type

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: [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: [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

[jira] [Created] (FLINK-20834) Add metrics for reporting the memory usage and CPU usage of the Python UDF workers

Wei Zhong created FLINK-20834: - Summary: Add metrics for reporting the memory usage and CPU usage of the Python UDF workers Key: FLINK-20834 URL: https://issues.apache.org/jira/browse/FLINK-20834 Project

[jira] [Created] (FLINK-20756) PythonCalcSplitConditionRule is not working as expected

Wei Zhong created FLINK-20756: - Summary: PythonCalcSplitConditionRule is not working as expected Key: FLINK-20756 URL: https://issues.apache.org/jira/browse/FLINK-20756 Project: Flink Issue Type

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: [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: [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: 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: [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) >

[jira] [Created] (FLINK-20333) Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs.

Wei Zhong created FLINK-20333: - Summary: Flink standalone cluster throws metaspace OOM after submitting multiple PyFlink UDF jobs. Key: FLINK-20333 URL: https://issues.apache.org/jira/browse/FLINK-20333

[jira] [Created] (FLINK-20207) Improve the error message printed when submitting the pyflink jobs via 'flink run'

Wei Zhong created FLINK-20207: - Summary: Improve the error message printed when submitting the pyflink jobs via 'flink run' Key: FLINK-20207 URL: https://issues.apache.org/jira/browse/FLINK-20207 Project

[jira] [Created] (FLINK-19236) Optimize the performance of Python UDAF

Wei Zhong created FLINK-19236: - Summary: Optimize the performance of Python UDAF Key: FLINK-19236 URL: https://issues.apache.org/jira/browse/FLINK-19236 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19233) Support DISTINCT KeyWord for Python UDAF

Wei Zhong created FLINK-19233: - Summary: Support DISTINCT KeyWord for Python UDAF Key: FLINK-19233 URL: https://issues.apache.org/jira/browse/FLINK-19233 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19234) Support FILTER KeyWord for Python UDAF

Wei Zhong created FLINK-19234: - Summary: Support FILTER KeyWord for Python UDAF Key: FLINK-19234 URL: https://issues.apache.org/jira/browse/FLINK-19234 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19235) Support mixed use with built-in aggs for Python UDAF

Wei Zhong created FLINK-19235: - Summary: Support mixed use with built-in aggs for Python UDAF Key: FLINK-19235 URL: https://issues.apache.org/jira/browse/FLINK-19235 Project: Flink Issue Type

[jira] [Created] (FLINK-19232) Support MapState and MapView for Python UDAF

Wei Zhong created FLINK-19232: - Summary: Support MapState and MapView for Python UDAF Key: FLINK-19232 URL: https://issues.apache.org/jira/browse/FLINK-19232 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19231) Support ListState and ListView for Python UDAF

Wei Zhong created FLINK-19231: - Summary: Support ListState and ListView for Python UDAF Key: FLINK-19231 URL: https://issues.apache.org/jira/browse/FLINK-19231 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-19230) Support Python UDAF on blink batch planner

Wei Zhong created FLINK-19230: - Summary: Support Python UDAF on blink batch planner Key: FLINK-19230 URL: https://issues.apache.org/jira/browse/FLINK-19230 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-19229) Support ValueState and Python UDAF on blink stream planner

Wei Zhong created FLINK-19229: - Summary: Support ValueState and Python UDAF on blink stream planner Key: FLINK-19229 URL: https://issues.apache.org/jira/browse/FLINK-19229 Project: Flink Issue

[jira] [Created] (FLINK-19185) Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139)

Wei Zhong created FLINK-19185: - Summary: Support General Python User-Defined Aggregate Function Support on Table API (FLIP-139) Key: FLINK-19185 URL: https://issues.apache.org/jira/browse/FLINK-19185

[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-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

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

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: [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写道： >> >>>

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

[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.

[jira] [Created] (FLINK-18937) Add a "Environment Setup" section to the "Installation" document

Wei Zhong created FLINK-18937: - Summary: Add a "Environment Setup" section to the "Installation" document Key: FLINK-18937 URL: https://issues.apache.org/jira/browse/FLINK-18937

[jira] [Created] (FLINK-18932) Add a "Overview" document under the "Python API" section

Wei Zhong created FLINK-18932: - Summary: Add a "Overview" document under the "Python API" section Key: FLINK-18932 URL: https://issues.apache.org/jira/browse/FLINK-18932 Project: F

[jira] [Created] (FLINK-18933) Delete the old Python Table API document section

Wei Zhong created FLINK-18933: - Summary: Delete the old Python Table API document section Key: FLINK-18933 URL: https://issues.apache.org/jira/browse/FLINK-18933 Project: Flink Issue Type: Sub

[jira] [Created] (FLINK-18929) Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section

Wei Zhong created FLINK-18929: - Summary: Add a "API Docs" link (linked to the generated sphinx docs) under the "Python API" section Key: FLINK-18929 URL: https://issues.apache.org/jir

[jira] [Created] (FLINK-18928) Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ"

Wei Zhong created FLINK-18928: - Summary: Move the "Common Questions" document from the old Python Table API documentation to the "Python API" section with a new name "FAQ" Key: FLINK-189

[jira] [Created] (FLINK-18927) Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18927: - Summary: Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18927 URL: htt

[jira] [Created] (FLINK-18926) Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18926: - Summary: Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18926 URL: htt

[jira] [Created] (FLINK-18925) Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18925: - Summary: Move the "Configuration" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[jira] [Created] (FLINK-18924) Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

Wei Zhong created FLINK-18924: - Summary: Move the "Metrics" document from the old Python Table API documentation to the "Python API" -> "User Guide" -> "Table API" section

[jira] [Created] (FLINK-18923) Add a "CEP" document under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18923: - Summary: Add a "CEP" document under the "Python API" -> "User Guide" section Key: FLINK-18923 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-18922) Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18922: - Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide" section Key: FLINK-18922 URL: https://issues.a

[jira] [Created] (FLINK-18921) Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18921: - Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" section Key: FLINK-18921 URL: https://issues.a

[jira] [Created] (FLINK-18920) Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section

Wei Zhong created FLINK-18920: - Summary: Move the "Dependency Management" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section Key: FLINK-

[jira] [Created] (FLINK-18919) Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

Wei Zhong created FLINK-18919: - Summary: Move the "User Defined Functions" document and "Vectorized User Defined Functions" document from the old Python Table API documentation to the "Python API" -> "User Guid

[jira] [Created] (FLINK-18918) Add a "Connectors" document under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18918: - Summary: Add a "Connectors" document under the "Python API" -> "User Guide" section Key: FLINK-18918 URL: https://issues.apache.org/jira/browse/FLINK-

[jira] [Created] (FLINK-18917) Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18917: - Summary: Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the "Python API" -> "User Guide" section Key: FLINK-

[jira] [Created] (FLINK-18916) Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18916: - Summary: Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guide" section Key: FLINK-18916 URL: https://issues.a

[jira] [Created] (FLINK-18914) Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section with a new name "DataTypes"

Wei Zhong created FLINK-18914: - Summary: Move the "Python DataTypes" document from the old Python Table API documentation to the "Python API" -> "GettingStart" section with a new name "DataTy

[jira] [Created] (FLINK-18913) Add a "TableEnvironment" document under the "Python API" -> "User Guide" section

Wei Zhong created FLINK-18913: - Summary: Add a "TableEnvironment" document under the "Python API" -> "User Guide" section Key: FLINK-18913 URL: https://issues.apache.org/jira/browse

[jira] [Created] (FLINK-18912) Add a Table API tutorial link under the "Python API" -> "GettingStart" -> "Tutorial" section

Wei Zhong created FLINK-18912: - Summary: Add a Table API tutorial link under the "Python API" -> "GettingStart" -> "Tutorial" section Key: FLINK-18912 URL: https://issue

[jira] [Created] (FLINK-18911) Move the "Installation" document from the old Python Table API documentation to the new Python API documentation

Wei Zhong created FLINK-18911: - Summary: Move the "Installation" document from the old Python Table API documentation to the new Python API documentation Key: FLINK-18911 URL: https://issues.apache.org/j

[jira] [Created] (FLINK-18910) Create the new document structure for Python documentation according to FLIP-133

Wei Zhong created FLINK-18910: - Summary: Create the new document structure for Python documentation according to FLIP-133 Key: FLINK-18910 URL: https://issues.apache.org/jira/browse/FLINK-18910 Project

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

[jira] [Created] (FLINK-18849) Improve the code tabs of the Flink documents

Wei Zhong created FLINK-18849: - Summary: Improve the code tabs of the Flink documents Key: FLINK-18849 URL: https://issues.apache.org/jira/browse/FLINK-18849 Project: Flink Issue Type

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 > >>> >&

[jira] [Created] (FLINK-18801) Add the new document "10 minutes to PyFlink"

Wei Zhong created FLINK-18801: - Summary: Add the new document "10 minutes to PyFlink" Key: FLINK-18801 URL: https://issues.apache.org/jira/browse/FLINK-18801 Project: Flink Issue Type

[jira] [Created] (FLINK-18750) SqlValidatorException thrown when select from a view which contains a UDTF call

Wei Zhong created FLINK-18750: - Summary: SqlValidatorException thrown when select from a view which contains a UDTF call Key: FLINK-18750 URL: https://issues.apache.org/jira/browse/FLINK-18750 Project

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> 写道： > >

[jira] [Created] (FLINK-18716) Remove the deprecated "execute" and "insert_into" calls in PyFlink Table API docs

Wei Zhong created FLINK-18716: - Summary: Remove the deprecated "execute" and "insert_into" calls in PyFlink Table API docs Key: FLINK-18716 URL: https://issues.apache.org/jira/browse/FLINK-18716

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: [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

[jira] [Created] (FLINK-18463) Make the "input_types" parameter of the Python udf decorator optional

Wei Zhong created FLINK-18463: - Summary: Make the "input_types" parameter of the Python udf decorator optional Key: FLINK-18463 URL: https://issues.apache.org/jira/browse/FLINK-18463 Proj

[jira] [Created] (FLINK-18460) If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect.

Wei Zhong created FLINK-18460: - Summary: If the Python UDFs are called before calling the Python Dependency Management API, the Python Dependency Management would not will not take effect. Key: FLINK-18460 URL

[jira] [Created] (FLINK-18218) Add yarn perjob, java dependency management e2e tests for pyflink.

Wei Zhong created FLINK-18218: - Summary: Add yarn perjob, java dependency management e2e tests for pyflink. Key: FLINK-18218 URL: https://issues.apache.org/jira/browse/FLINK-18218 Project: Flink

[jira] [Created] (FLINK-17881) Add documentation for PyFlink's Windows support

Wei Zhong created FLINK-17881: - Summary: Add documentation for PyFlink's Windows support Key: FLINK-17881 URL: https://issues.apache.org/jira/browse/FLINK-17881 Project: Flink Issue Type

[jira] [Created] (FLINK-17876) Add documents for the Python UDF SQL DDL.

Wei Zhong created FLINK-17876: - Summary: Add documents for the Python UDF SQL DDL. Key: FLINK-17876 URL: https://issues.apache.org/jira/browse/FLINK-17876 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17866) InvalidPathException was thrown when running the test cases of PyFlink on Windows

Wei Zhong created FLINK-17866: - Summary: InvalidPathException was thrown when running the test cases of PyFlink on Windows Key: FLINK-17866 URL: https://issues.apache.org/jira/browse/FLINK-17866 Project

[jira] [Created] (FLINK-17646) Reduce the python package size of PyFlink

Wei Zhong created FLINK-17646: - Summary: Reduce the python package size of PyFlink Key: FLINK-17646 URL: https://issues.apache.org/jira/browse/FLINK-17646 Project: Flink Issue Type: Improvement

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

[jira] [Created] (FLINK-17628) Remove the unnecessary py4j log information

Wei Zhong created FLINK-17628: - Summary: Remove the unnecessary py4j log information Key: FLINK-17628 URL: https://issues.apache.org/jira/browse/FLINK-17628 Project: Flink Issue Type

[jira] [Created] (FLINK-17612) The Python command line options are ignored by the CliOptionsParser in SQL Client

Wei Zhong created FLINK-17612: - Summary: The Python command line options are ignored by the CliOptionsParser in SQL Client Key: FLINK-17612 URL: https://issues.apache.org/jira/browse/FLINK-17612 Project

  1   2   >