[jira] [Commented] (FLINK-17423) Support Python UDTF in blink planner under batch mode

2020-05-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17098484#comment-17098484 ] Hequn Cheng commented on FLINK-17423: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-17423) Support Python UDTF in blink planner under batch mode

2020-05-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17423. --- Resolution: Resolved > Support Python UDTF in blink planner under batch mode >

[jira] [Commented] (FLINK-17148) Support converting pandas dataframe to flink table

2020-04-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17096012#comment-17096012 ] Hequn Cheng commented on FLINK-17148: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-17148) Support converting pandas dataframe to flink table

2020-04-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17148. --- Resolution: Resolved > Support converting pandas dataframe to flink table >

[jira] [Updated] (FLINK-17431) Implement table DDLs for Hive dialect part 1

2020-04-28 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17431: Component/s: Table SQL / API Connectors / Hive > Implement table DDLs for Hive

[jira] [Updated] (FLINK-17285) Translate "Python Table API" page into Chinese

2020-04-28 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17285?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17285: Component/s: API / Python > Translate "Python Table API" page into Chinese >

[jira] [Closed] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

2020-04-23 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16485. --- Resolution: Resolved > Support vectorized Python UDF in the batch mode of old planner >

[jira] [Commented] (FLINK-16485) Support vectorized Python UDF in the batch mode of old planner

2020-04-23 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16485?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090668#comment-17090668 ] Hequn Cheng commented on FLINK-16485: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16766. --- Resolution: Resolved > Support create StreamTableEnvironment without passing >

[jira] [Updated] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16766: Fix Version/s: (was: 1.9.4) (was: 1.10.1) > Support create

[jira] [Commented] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090151#comment-17090151 ] Hequn Cheng commented on FLINK-16766: - Resolved in 1.11.0 via

[jira] [Assigned] (FLINK-17303) Return TableResult for Python TableEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17303: --- Assignee: Nicholas Jiang > Return TableResult for Python TableEnvironment >

[jira] [Commented] (FLINK-17318) The comment is not right in `org.apache.flink.table.planner.delegation.PlannerBase`

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17089452#comment-17089452 ] Hequn Cheng commented on FLINK-17318: - CC [~godfreyhe] > The comment is not right in >

[jira] [Created] (FLINK-17318) The comment is not right in `org.apache.flink.table.planner.delegation.PlannerBase`

2020-04-22 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-17318: --- Summary: The comment is not right in `org.apache.flink.table.planner.delegation.PlannerBase` Key: FLINK-17318 URL: https://issues.apache.org/jira/browse/FLINK-17318

[jira] [Closed] (FLINK-17013) Support Python UDTF in old planner under batch mode

2020-04-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17013. --- Resolution: Resolved > Support Python UDTF in old planner under batch mode >

[jira] [Commented] (FLINK-17013) Support Python UDTF in old planner under batch mode

2020-04-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17013?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088298#comment-17088298 ] Hequn Cheng commented on FLINK-17013: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17135. --- Resolution: Fixed > PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction >

[jira] [Commented] (FLINK-17135) PythonCalcSplitRuleTest.testPandasFunctionMixedWithGeneralPythonFunction failed

2020-04-20 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17135?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17088230#comment-17088230 ] Hequn Cheng commented on FLINK-17135: - Hi, the fix has been merged into master via

[jira] [Assigned] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

2020-04-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16763: --- Assignee: Hequn Cheng > Should not use BatchTableEnvironment for Python UDF in the

[jira] [Closed] (FLINK-16983) Support RowType in vectorized Python UDF

2020-04-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16983?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16983. --- Resolution: Resolved > Support RowType in vectorized Python UDF >

[jira] [Created] (FLINK-17215) Clean the build document for Pyflink

2020-04-17 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-17215: --- Summary: Clean the build document for Pyflink Key: FLINK-17215 URL: https://issues.apache.org/jira/browse/FLINK-17215 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-16983) Support RowType in vectorized Python UDF

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16983?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084512#comment-17084512 ] Hequn Cheng commented on FLINK-16983: - Resolved in 1.11.0 via

[jira] [Commented] (FLINK-16486) Add documentation for vectorized Python UDF

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084506#comment-17084506 ] Hequn Cheng commented on FLINK-16486: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16486) Add documentation for vectorized Python UDF

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16486. --- Resolution: Resolved > Add documentation for vectorized Python UDF >

[jira] [Commented] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083919#comment-17083919 ] Hequn Cheng commented on FLINK-17093: - Hi, I will close this jira. We can discuss the problem raised

[jira] [Closed] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17093. --- Resolution: Fixed > Python UDF doesn't work when the input column is from composite field >

[jira] [Comment Edited] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-15 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081768#comment-17081768 ] Hequn Cheng edited comment on FLINK-17093 at 4/15/20, 8:42 AM: --- Resolved

[jira] [Closed] (FLINK-16748) Add Python UDTF doc

2020-04-14 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16748. --- Resolution: Resolved > Add Python UDTF doc > --- > > Key:

[jira] [Commented] (FLINK-16748) Add Python UDTF doc

2020-04-14 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17083765#comment-17083765 ] Hequn Cheng commented on FLINK-16748: - Resolved in 1.11.0 via

[jira] [Assigned] (FLINK-16748) Add Python UDTF doc

2020-04-14 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16748: --- Assignee: Huang Xingbo > Add Python UDTF doc > --- > >

[jira] [Commented] (FLINK-17093) Python UDF doesn't work when the input column is from composite field

2020-04-12 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17093?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081768#comment-17081768 ] Hequn Cheng commented on FLINK-17093: - Resolved in 1.10.1 via

[jira] [Closed] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-10 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16761. --- Resolution: Resolved > Return JobExecutionResult for Python ExecutionEnvironment and

[jira] [Updated] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-10 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16761: Issue Type: Improvement (was: Bug) > Return JobExecutionResult for Python ExecutionEnvironment

[jira] [Updated] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-10 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16761: Fix Version/s: (was: 1.10.1) (was: 1.9.3) > Return JobExecutionResult

[jira] [Commented] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-10 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17081106#comment-17081106 ] Hequn Cheng commented on FLINK-16761: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16687) Support Python UDF in Java Correlate

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16687. --- Resolution: Resolved > Support Python UDF in Java Correlate >

[jira] [Commented] (FLINK-16687) Support Python UDF in Java Correlate

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17080199#comment-17080199 ] Hequn Cheng commented on FLINK-16687: - Resolved in 1.11.0 via

[jira] [Updated] (FLINK-16687) PyFlink Cannot determine simple type name "PythonScalarFunction$0"

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16687: Issue Type: New Feature (was: Bug) > PyFlink Cannot determine simple type name

[jira] [Updated] (FLINK-16687) Support Python UDF in Java Correlate

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16687: Summary: Support Python UDF in Java Correlate (was: PyFlink Cannot determine simple type name

[jira] [Updated] (FLINK-16687) Support Python UDF in Java Correlate

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16687: Fix Version/s: 1.11.0 > Support Python UDF in Java Correlate >

[jira] [Commented] (FLINK-17066) Update pyarrow version bounds less than 0.14.0

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079412#comment-17079412 ] Hequn Cheng commented on FLINK-17066: - The problem does not exist in 1.11.0 since pyflink depends on

[jira] [Closed] (FLINK-17066) Update pyarrow version bounds less than 0.14.0

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17066. --- Resolution: Fixed > Update pyarrow version bounds less than 0.14.0 >

[jira] [Commented] (FLINK-17066) Update pyarrow version bounds less than 0.14.0

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079413#comment-17079413 ] Hequn Cheng commented on FLINK-17066: - Fixed in 1.10.1 via 2833504f830ddb7b1172ae57428865fcb5cc9a83

[jira] [Assigned] (FLINK-17066) Update pyarrow version bounds less than 0.14.0

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17066: --- Assignee: Huang Xingbo > Update pyarrow version bounds less than 0.14.0 >

[jira] [Updated] (FLINK-17066) Limits the PyArrow version to 0.13

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17066: Priority: Blocker (was: Critical) > Limits the PyArrow version to 0.13 >

[jira] [Commented] (FLINK-17065) Add documentation about the Python versions supported for PyFlink

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17079125#comment-17079125 ] Hequn Cheng commented on FLINK-17065: - Resolved in 1.10.1 via

[jira] [Closed] (FLINK-17065) Add documentation about the Python versions supported for PyFlink

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17065. --- Resolution: Resolved > Add documentation about the Python versions supported for PyFlink >

[jira] [Updated] (FLINK-17066) Limits the PyArrow version to 0.13

2020-04-09 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17066: Priority: Critical (was: Major) > Limits the PyArrow version to 0.13 >

[jira] [Commented] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

2020-04-08 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17078244#comment-17078244 ] Hequn Cheng commented on FLINK-9528: Hi everyone, I have freed this ticket as I have switched my work

[jira] [Assigned] (FLINK-9528) Incorrect results: Filter does not treat Upsert messages correctly.

2020-04-08 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9528: -- Assignee: (was: Hequn Cheng) > Incorrect results: Filter does not treat Upsert messages

[jira] [Assigned] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-08 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16766: --- Assignee: Nicholas Jiang > Support create StreamTableEnvironment without passing >

[jira] [Commented] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-08 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077896#comment-17077896 ] Hequn Cheng commented on FLINK-16761: - [~nicholasjiang] Thanks. I have assigned this to you. :) >

[jira] [Assigned] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-04-08 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16761: --- Assignee: Nicholas Jiang > Return JobExecutionResult for Python ExecutionEnvironment and

[jira] [Commented] (FLINK-16914) Support ArrayType in vectorized Python UDF

2020-04-07 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16914?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17077080#comment-17077080 ] Hequn Cheng commented on FLINK-16914: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16914) Support ArrayType in vectorized Python UDF

2020-04-07 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16914?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16914. --- Resolution: Resolved > Support ArrayType in vectorized Python UDF >

[jira] [Assigned] (FLINK-8545) Implement upsert stream table source

2020-04-06 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-8545: -- Assignee: (was: Hequn Cheng) > Implement upsert stream table source >

[jira] [Closed] (FLINK-16670) Support User-Defined Metrics in Python UDF

2020-04-03 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16670?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16670. --- Resolution: Resolved > Support User-Defined Metrics in Python UDF >

[jira] [Closed] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16796. --- Resolution: Fixed > Fix The Bug of Python UDTF in SQL Query >

[jira] [Commented] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071408#comment-17071408 ] Hequn Cheng commented on FLINK-16796: - Fixed in 1.11.0 via 52315e79b439eda4f6cd7836051c1791382a4a7d

[jira] [Assigned] (FLINK-16796) Fix The Bug of Python UDTF in SQL Query

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16796?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16796: --- Assignee: Huang Xingbo > Fix The Bug of Python UDTF in SQL Query >

[jira] [Closed] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16847. --- Resolution: Resolved > Support timestamp types in vectorized Python UDF >

[jira] [Commented] (FLINK-16847) Support timestamp types in vectorized Python UDF

2020-03-30 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17071406#comment-17071406 ] Hequn Cheng commented on FLINK-16847: - Resolved in 1.11.0 via 

[jira] [Assigned] (FLINK-16854) Correct dependency versions in the NOTICE file of module statefun-ridesharing-example-simulator

2020-03-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16854: --- Assignee: Hequn Cheng > Correct dependency versions in the NOTICE file of module >

[jira] [Updated] (FLINK-16854) Correct dependency versions in the NOTICE file of module statefun-ridesharing-example-simulator

2020-03-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16854?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16854: Priority: Blocker (was: Major) > Correct dependency versions in the NOTICE file of module >

[jira] [Assigned] (FLINK-16853) Update the version of protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module statefun-flink-distribution

2020-03-29 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16853?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16853: --- Assignee: Hequn Cheng > Update the version of protobuf-java from 3.8.0 to 3.7.1 in the

[jira] [Created] (FLINK-16854) Correct dependency versions in the NOTICE file of module statefun-ridesharing-example-simulator

2020-03-29 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16854: --- Summary: Correct dependency versions in the NOTICE file of module statefun-ridesharing-example-simulator Key: FLINK-16854 URL: https://issues.apache.org/jira/browse/FLINK-16854

[jira] [Created] (FLINK-16853) Update the version of protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module statefun-flink-distribution

2020-03-29 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16853: --- Summary: Update the version of protobuf-java from 3.8.0 to 3.7.1 in the NOTICE file of module statefun-flink-distribution Key: FLINK-16853 URL:

[jira] [Assigned] (FLINK-16837) Disable trimStackTrace in surefire plugin

2020-03-27 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16837: --- Assignee: Chesnay Schepler > Disable trimStackTrace in surefire plugin >

[jira] [Assigned] (FLINK-16837) Disable trimStackTrace in surefire plugin

2020-03-27 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16837: --- Assignee: (was: Hequn Cheng) > Disable trimStackTrace in surefire plugin >

[jira] [Assigned] (FLINK-16837) Disable trimStackTrace in surefire plugin

2020-03-27 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16837?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16837: --- Assignee: Hequn Cheng (was: Chesnay Schepler) > Disable trimStackTrace in surefire plugin

[jira] [Commented] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067802#comment-17067802 ] Hequn Cheng commented on FLINK-16483: - [~rongr] The fix has been merged. Thank you for the PR.(y) >

[jira] [Commented] (FLINK-16786) Fix pyarrow version incompatible problem

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067799#comment-17067799 ] Hequn Cheng commented on FLINK-16786: - Fixed in 1.11.0 via 7ce9d7c96fbdc6a871e720ca8b2f9f461b3971c7

[jira] [Closed] (FLINK-16786) Fix pyarrow version incompatible problem

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16786. --- Resolution: Fixed > Fix pyarrow version incompatible problem >

[jira] [Commented] (FLINK-16790) enables the interpretation of backslash escapes

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067582#comment-17067582 ] Hequn Cheng commented on FLINK-16790: - Resolved in 1.10.1 via

[jira] [Closed] (FLINK-16790) enables the interpretation of backslash escapes

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16790. --- Resolution: Resolved > enables the interpretation of backslash escapes >

[jira] [Commented] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067508#comment-17067508 ] Hequn Cheng commented on FLINK-15616: - Resolved in 1.10.1 via

[jira] [Commented] (FLINK-15616) Move boot error messages from python-udf-boot.log to taskmanager's log file

2020-03-26 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067387#comment-17067387 ] Hequn Cheng commented on FLINK-15616: - The problem has been reported by several users within 1.10.0.

[jira] [Commented] (FLINK-16790) enables the interpretation of backslash escapes

2020-03-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067375#comment-17067375 ] Hequn Cheng commented on FLINK-16790: - [~yuwenbing] Thanks a lot for reporting the problem. I have

[jira] [Assigned] (FLINK-16790) enables the interpretation of backslash escapes

2020-03-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16790: --- Assignee: yuwenbing > enables the interpretation of backslash escapes >

[jira] [Updated] (FLINK-16765) Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink

2020-03-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16765: Fix Version/s: (was: 1.10.1) (was: 1.11.0) > Replace all

[jira] [Assigned] (FLINK-16765) Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink

2020-03-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16765: --- Assignee: yuwenbing > Replace all BatchTableEnvironment to StreamTableEnvironment in the

[jira] [Created] (FLINK-16786) Fix pyarrow version incompatible problem

2020-03-25 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16786: --- Summary: Fix pyarrow version incompatible problem Key: FLINK-16786 URL: https://issues.apache.org/jira/browse/FLINK-16786 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

2020-03-25 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17067282#comment-17067282 ] Hequn Cheng commented on FLINK-16483: - [~rongr] The version should be consistent between pyflink and

[jira] [Created] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-03-24 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16766: --- Summary: Support create StreamTableEnvironment without passing StreamExecutionEnvironment Key: FLINK-16766 URL: https://issues.apache.org/jira/browse/FLINK-16766

[jira] [Created] (FLINK-16765) Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink

2020-03-24 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16765: --- Summary: Replace all BatchTableEnvironment to StreamTableEnvironment in the document of PyFlink Key: FLINK-16765 URL: https://issues.apache.org/jira/browse/FLINK-16765

[jira] [Updated] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

2020-03-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16763: Component/s: Documentation > Should not use BatchTableEnvironment for Python UDF in the document

[jira] [Created] (FLINK-16763) Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10

2020-03-24 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16763: --- Summary: Should not use BatchTableEnvironment for Python UDF in the document of flink-1.10 Key: FLINK-16763 URL: https://issues.apache.org/jira/browse/FLINK-16763

[jira] [Updated] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-03-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16761: Description: For ExecutionEnvironment and TableEnvironment, the JobExecutionResult should be

[jira] [Created] (FLINK-16761) Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment

2020-03-24 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16761: --- Summary: Return JobExecutionResult for Python ExecutionEnvironment and TableEnvironment Key: FLINK-16761 URL: https://issues.apache.org/jira/browse/FLINK-16761

[jira] [Commented] (FLINK-16608) Support primitive data types for vectorized Python UDF

2020-03-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17065353#comment-17065353 ] Hequn Cheng commented on FLINK-16608: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16608) Support primitive data types for vectorized Python UDF

2020-03-24 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16608. --- Resolution: Resolved > Support primitive data types for vectorized Python UDF >

[jira] [Closed] (FLINK-16650) Support LocalZonedTimestampType for Python UDF in blink planner

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16650. --- Resolution: Resolved > Support LocalZonedTimestampType for Python UDF in blink planner >

[jira] [Commented] (FLINK-16650) Support LocalZonedTimestampType for Python UDF in blink planner

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16650?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17063034#comment-17063034 ] Hequn Cheng commented on FLINK-16650: - Resolved in 1.11.0 via

[jira] [Commented] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062650#comment-17062650 ] Hequn Cheng commented on FLINK-16676: - Resolved in 1.11.0 via

[jira] [Closed] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16676. --- Resolution: Fixed > test_pipeline_from_invalid_json is failing Azure >

[jira] [Comment Edited] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062465#comment-17062465 ] Hequn Cheng edited comment on FLINK-16676 at 3/19/20, 11:13 AM: The

[jira] [Commented] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062465#comment-17062465 ] Hequn Cheng commented on FLINK-16676: - The problem is the detailed error message would be different

[jira] [Commented] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17062381#comment-17062381 ] Hequn Cheng commented on FLINK-16676: - Looking into the problem now. >

[jira] [Assigned] (FLINK-16676) test_pipeline_from_invalid_json is failing Azure

2020-03-19 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16676: --- Assignee: Hequn Cheng > test_pipeline_from_invalid_json is failing Azure >

[jira] [Created] (FLINK-16674) Add documentation about how to use user-defined metrics for Python UDF

2020-03-19 Thread Hequn Cheng (Jira)
Hequn Cheng created FLINK-16674: --- Summary: Add documentation about how to use user-defined metrics for Python UDF Key: FLINK-16674 URL: https://issues.apache.org/jira/browse/FLINK-16674 Project: Flink

<    1   2   3   4   5   6   7   8   9   10   >