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

2023-02-22 Thread Wei Zhong (Jira)
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: Flink

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

2022-11-30 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641235#comment-17641235 ] Wei Zhong commented on FLINK-30245: --- [~jark] Could you help to take a look at this iss

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

2022-11-30 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-30245?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17641223#comment-17641223 ] Wei Zhong commented on FLINK-30245: --- The precision change (18 -> 19) is caused by org

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

2022-11-29 Thread Wei Zhong (Jira)
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

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

2022-08-01 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-28764?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17573645#comment-17573645 ] Wei Zhong commented on FLINK-28764: --- cc [~jark] > Support more than 64 distinct aggre

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

2022-08-01 Thread Wei Zhong (Jira)
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

2022-05-10 Thread Wei Zhong (Jira)
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] [Commented] (FLINK-27438) SQL validation failed when constructing a map array

2022-04-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529354#comment-17529354 ] Wei Zhong commented on FLINK-27438: --- I found a duplicate issue and it seems has been c

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

2022-04-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17529349#comment-17529349 ] Wei Zhong commented on FLINK-27438: --- Thanks for your reply. It was discovered when we

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

2022-04-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-27438?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-27438: -- Affects Version/s: 1.14.4 > SQL validation failed when constructing a map array >

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

2022-04-28 Thread Wei Zhong (Jira)
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: Bug

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

2021-04-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21969. - Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed > PythonTimestampsAndWatermarks

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

2021-04-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21969?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17318486#comment-17318486 ] Wei Zhong commented on FLINK-21969: --- Merged into master via 5b3a8f3b25dcac71375d1a81fa

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

2021-03-30 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21842?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312099#comment-17312099 ] Wei Zhong commented on FLINK-21842: --- Merged via 62838c90bc5b1851d6a9b92a4e80a46df94ba8

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

2021-03-30 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21842. - Fix Version/s: 1.13.0 Resolution: Fixed > Support user defined WindowAssigner, Trigger and Proces

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

2021-03-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21969?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21969: -- Component/s: API / Python > PythonTimestampsAndWatermarksOperator emitted the Long.MAX_VALUE watermark

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

2021-03-24 Thread Wei Zhong (Jira)
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] [Commented] (FLINK-21294) Support state access API for the map/flat_map operation of Python ConnectedStreams

2021-03-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17308286#comment-17308286 ] Wei Zhong commented on FLINK-21294: --- Merged via 7e49b1af59341d924eee1742ea59e8c43c3be7

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

2021-03-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21294: - Assignee: Wei Zhong > Support state access API for the map/flat_map operation of Python > Conn

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

2021-03-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21294. - Resolution: Fixed > Support state access API for the map/flat_map operation of Python > ConnectedStream

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

2021-03-17 Thread Wei Zhong (Jira)
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

2021-03-15 Thread Wei Zhong (Jira)
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] [Updated] (FLINK-21294) Support state access API for the map/flat_map operation of Python ConnectedStreams

2021-03-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21294: -- Summary: Support state access API for the map/flat_map operation of Python ConnectedStreams (was: Sup

[jira] [Closed] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21242. - Resolution: Fixed > Support state access API for the map/flat_map/filter/reduce operations of > Python

[jira] [Commented] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17299263#comment-17299263 ] Wei Zhong commented on FLINK-21242: --- Merged via 582c7b5596738ab2c8fa73fbbc2e09189b863f

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

2021-03-08 Thread Wei Zhong (Jira)
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/FLIN

[jira] [Assigned] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21242: - Assignee: Wei Zhong > Support state access API for the map/flat_map/filter/reduce operations of

[jira] [Updated] (FLINK-21242) Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21242: -- Summary: Support state access API for the map/flat_map/filter/reduce operations of Python KeyedStream

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

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295023#comment-17295023 ] Wei Zhong commented on FLINK-21115: --- Merged via 044f8e17237d0fdbff96ca973817c932a3c985

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

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21115. - Resolution: Fixed > Add AggregatingState and corresponding StateDescriptor for Python DataStream > API

[jira] [Closed] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21434. - Resolution: Fixed > When UDAF return ROW type, and the number of fields is more than 14, the > crash ha

[jira] [Commented] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend

2021-03-03 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21434?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17295022#comment-17295022 ] Wei Zhong commented on FLINK-21434: --- Fixed via:  - master: 1b0e592cf56005bff430252b0d

[jira] [Assigned] (FLINK-21434) When UDAF return ROW type, and the number of fields is more than 14, the crash happend

2021-03-02 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21434?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21434: - Assignee: Wei Zhong > When UDAF return ROW type, and the number of fields is more than 14, the

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

2021-03-01 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21509. - Fix Version/s: 1.13.0 Resolution: Fixed > "w.start" returns "1970-01-01" when used with Pandas UD

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

2021-03-01 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293324#comment-17293324 ] Wei Zhong commented on FLINK-21509: --- Fixed via f00da5561075990ea200f168bcdd0fa5b084bb4

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

2021-03-01 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21180?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21180. - Assignee: Wei Zhong Resolution: Fixed > Move the state module from 'pyflink.common' to 'pyflink.da

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

2021-03-01 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21180?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17293302#comment-17293302 ] Wei Zhong commented on FLINK-21180: --- Merged via 6c998024e97d02a6a94c34c1e1fdd432d29aa1

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

2021-02-28 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21509: -- Affects Version/s: (was: 1.12.1) > "w.start" returns "1970-01-01" when used with Pandas UDAF after

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

2021-02-26 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21115: - Assignee: Wei Zhong > Add AggregatingState and corresponding StateDescriptor for Python DataStr

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

2021-02-25 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong reassigned FLINK-21509: - Assignee: Wei Zhong > "w.start" returns "1970-01-01" when used with Pandas UDAF after grouping

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

2021-02-25 Thread Wei Zhong (Jira)
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.org/jira/browse/FLINK-

[jira] [Commented] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-02-22 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288786#comment-17288786 ] Wei Zhong commented on FLINK-20994: --- [~dwysakowicz] Sorry for the late response. The P

[jira] [Commented] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-02-22 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17288782#comment-17288782 ] Wei Zhong commented on FLINK-20994: --- Merged via 3f99f293bff7da40af387fa76b637bfc8f4d40

[jira] [Closed] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-02-22 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-20994. - Resolution: Fixed > Add public method to create TableEnvironment in PyFlink > --

[jira] [Closed] (FLINK-21238) Support to close PythonFunctionFactory

2021-02-06 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21238?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong closed FLINK-21238. - Resolution: Fixed Merged to master via 08bb6c185c1f080be422bfda520c6f1ffe248fa6 > Support to close Pyth

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

2021-02-05 Thread Wei Zhong (Jira)
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] [Updated] (FLINK-21242) Support state access API for the map operation of Python KeyedStream

2021-02-02 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21242: -- Summary: Support state access API for the map operation of Python KeyedStream (was: Support state acc

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

2021-02-02 Thread Wei Zhong (Jira)
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'

2021-01-27 Thread Wei Zhong (Jira)
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] [Updated] (FLINK-21179) Make sure that the open/close methods of the Python DataStream Function are not implemented when using in ReducingState and AggregatingState

2021-01-27 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21179?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21179: -- Description: As the ReducingState and AggregatingState only support non-rich functions, we need to mak

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

2021-01-27 Thread Wei Zhong (Jira)
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 Project

[jira] [Updated] (FLINK-21114) Add ReducingState and corresponding StateDescriptor for Python DataStream API

2021-01-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21114: -- Fix Version/s: 1.13.0 > Add ReducingState and corresponding StateDescriptor for Python DataStream API

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

2021-01-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21115?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21115: -- Fix Version/s: 1.13.0 > Add AggregatingState and corresponding StateDescriptor for Python DataStream

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

2021-01-24 Thread Wei Zhong (Jira)
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: F

[jira] [Updated] (FLINK-21114) Add ReducingState and corresponding StateDescriptor for Python DataStream API

2021-01-24 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21114?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-21114: -- Summary: Add ReducingState and corresponding StateDescriptor for Python DataStream API (was: Support

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

2021-01-24 Thread Wei Zhong (Jira)
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-task

[jira] [Commented] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-01-18 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267598#comment-17267598 ] Wei Zhong commented on FLINK-20994: --- [~dian.fu] Could you help to assign this JIRA to

[jira] [Commented] (FLINK-20994) Add public method to create TableEnvironment in PyFlink

2021-01-18 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20994?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17267597#comment-17267597 ] Wei Zhong commented on FLINK-20994: --- [~sjwiesman] Thanks for your notification. I'll t

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

2021-01-13 Thread Wei Zhong (Jira)
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 Is

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

2021-01-13 Thread Wei Zhong (Jira)
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:

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

2021-01-03 Thread Wei Zhong (Jira)
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

2020-12-23 Thread Wei Zhong (Jira)
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:

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

2020-11-25 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17239008#comment-17239008 ] Wei Zhong commented on FLINK-20333: --- Hi [~f.pompermaier], as the `org.apache.flink.st

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

2020-11-24 Thread Wei Zhong (Jira)
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 P

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

2020-11-17 Thread Wei Zhong (Jira)
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] [Commented] (FLINK-20134) Test non-vectorized Python UDAF

2020-11-15 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20134?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17232484#comment-17232484 ] Wei Zhong commented on FLINK-20134: --- Hi [~dian.fu], I have tested the non-vectorized P

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

2020-11-11 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17230326#comment-17230326 ] Wei Zhong commented on FLINK-18932: --- [~sjwiesman] Of course. Thank you! > Add a "Over

[jira] [Commented] (FLINK-20046) StreamTableAggregateTests.test_map_view_iterate is instable

2020-11-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17229678#comment-17229678 ] Wei Zhong commented on FLINK-20046: --- [~dian.fu] Thanks for your notification, I'll tak

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

2020-09-14 Thread Wei Zhong (Jira)
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

2020-09-14 Thread Wei Zhong (Jira)
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-19235) Support mixed use with built-in aggs for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
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: Su

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

2020-09-14 Thread Wei Zhong (Jira)
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-19231) Support ListState and ListView for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
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-task

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

2020-09-14 Thread Wei Zhong (Jira)
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-19232) Support MapState and MapView for Python UDAF

2020-09-14 Thread Wei Zhong (Jira)
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-19229) Support ValueState and Python UDAF on blink stream planner

2020-09-14 Thread Wei Zhong (Jira)
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 Ty

[jira] [Commented] (FLINK-17879) Update Python row serializer

2020-09-10 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17193463#comment-17193463 ] Wei Zhong commented on FLINK-17879: --- As there are some other works depending on this t

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

2020-09-10 Thread Wei Zhong (Jira)
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 Proj

[jira] [Created] (FLINK-19110) Flatten current PyFlink documentation structure

2020-09-01 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-19110: - Summary: Flatten current PyFlink documentation structure Key: FLINK-19110 URL: https://issues.apache.org/jira/browse/FLINK-19110 Project: Flink Issue Type: Sub-tas

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18849: -- Fix Version/s: 1.11.2 1.12.0 > Improve the code tabs of the Flink documents > -

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

2020-08-13 Thread Wei Zhong (Jira)
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 Project: Flink I

[jira] [Updated] (FLINK-18912) Add a Table API tutorial link(lined to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18912: -- Summary: Add a Table API tutorial link(lined to try-flink/python_table_api.md) under the "Python API"

[jira] [Updated] (FLINK-18912) Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API" -> "GettingStart" -> "Tutorial" section

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18912?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18912: -- Summary: Add a Table API tutorial link(linked to try-flink/python_table_api.md) under the "Python API

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

2020-08-13 Thread Wei Zhong (Jira)
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-ta

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

2020-08-13 Thread Wei Zhong (Jira)
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: Flink Issue Typ

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18922?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18922: -- Summary: Add a "Catalogs" link (linked to dev/table/catalogs.md) under the "Python API" -> "User Guide

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18923?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18923: -- Summary: Add a "CEP" document under the "Python API" -> "User Guide" -> "Table API" section (was: Ad

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18921?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18921: -- Summary: Add a "SQL" link (linked to dev/table/sql/index.md) under the "Python API" -> "User Guide" ->

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18920: -- Summary: Move the "Dependency Management" document from the old Python Table API documentation to the

[jira] [Updated] (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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18919?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18919: -- Summary: Move the "User Defined Functions" document and "Vectorized User Defined Functions" document f

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18918?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18918: -- Summary: Add a "Connectors" document under the "Python API" -> "User Guide" -> "Table API" section (

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18917: -- Summary: Add a "Built-in Functions" link (linked to dev/table/functions/systemFunctions.md) under the

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18916?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18916: -- Summary: Add a "Operations" link(linked to dev/table/tableApi.md) under the "Python API" -> "User Guid

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18914: -- Summary: Move the "Python DataTypes" document from the old Python Table API documentation to the "Pyth

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

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18913: -- Summary: Add a "TableEnvironment" document under the "Python API" -> "User Guide" -> "Table API" sect

[jira] [Updated] (FLINK-18801) Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table API" section

2020-08-13 Thread Wei Zhong (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Wei Zhong updated FLINK-18801: -- Summary: Add a "10 minutes to Table API" document under the "Python API" -> "User Guide" -> "Table AP

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

2020-08-12 Thread Wei Zhong (Jira)
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/jira/browse/FLINK-18929

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

2020-08-12 Thread Wei Zhong (Jira)
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-18928 URL: https://issues.apache.o

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

2020-08-12 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18927: - Summary: Add a "Debugging" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18927 URL: https://issues.apache.org/jira/browse/FLINK-18927 P

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

2020-08-12 Thread Wei Zhong (Jira)
Wei Zhong created FLINK-18926: - Summary: Add a "Environment Variables" document under the "Python API" -> "User Guide" -> "Table API" section Key: FLINK-18926 URL: https://issues.apache.org/jira/browse/FLINK-18926

  1   2   3   >