[jira] [Assigned] (FLINK-12716) Add an interactive shell for Python Table API

2019-06-09 Thread Huang Xingbo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12716?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-12716: Assignee: Huang Xingbo > Add an interactive shell for Python Table API >

[jira] [Assigned] (FLINK-12720) Add the Python Table API Sphinx docs

2019-06-12 Thread Huang Xingbo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-12720: Assignee: Huang Xingbo > Add the Python Table API Sphinx docs >

[jira] [Assigned] (FLINK-12327) Add simplicity support for submitting Python Table API job in CliFrontend, i.e. `flink run -py wordcount.py` can be work(with simple test).

2019-05-07 Thread Huang Xingbo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12327?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-12327: Assignee: Huang Xingbo > Add simplicity support for submitting Python Table API job in

[jira] [Assigned] (FLINK-13137) Remove the legacy flink python docs

2019-07-07 Thread Huang Xingbo (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo reassigned FLINK-13137: Assignee: Huang Xingbo > Remove the legacy flink python docs >

[jira] [Created] (FLINK-13137) Remove the legacy flink python docs

2019-07-07 Thread Huang Xingbo (JIRA)
Huang Xingbo created FLINK-13137: Summary: Remove the legacy flink python docs Key: FLINK-13137 URL: https://issues.apache.org/jira/browse/FLINK-13137 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-14573) Support time data types in Python user-defined functions

2019-10-30 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-14573: Summary: Support time data types in Python user-defined functions Key: FLINK-14573 URL: https://issues.apache.org/jira/browse/FLINK-14573 Project: Flink

[jira] [Updated] (FLINK-14573) Support time data types in Python user-defined functions

2019-10-30 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14573: - Description: This jira is a sub-task of FLINK-14388. In this jira, only time types are

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

2019-12-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14383: - Parent: FLINK-14500 Issue Type: Sub-task (was: New Feature) > Support python UDFs with

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

2019-12-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14383: - Fix Version/s: (was: 1.10.0) 1.11.0 > Support python UDFs with constant

[jira] [Updated] (FLINK-14383) Support python UDFs with constant value of time interval types

2019-12-03 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14383: - Parent: (was: FLINK-14013) Issue Type: New Feature (was: Sub-task) > Support

[jira] [Created] (FLINK-14547) UDF cannot be in the join condition in blink planner

2019-10-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-14547: Summary: UDF cannot be in the join condition in blink planner Key: FLINK-14547 URL: https://issues.apache.org/jira/browse/FLINK-14547 Project: Flink Issue

[jira] [Updated] (FLINK-14573) Support time data types in Python user-defined functions

2019-10-31 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-14573: - Fix Version/s: 1.10.0 > Support time data types in Python user-defined functions >

[jira] [Created] (FLINK-14584) Support complex data types in Python user-defined functions

2019-10-31 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-14584: Summary: Support complex data types in Python user-defined functions Key: FLINK-14584 URL: https://issues.apache.org/jira/browse/FLINK-14584 Project: Flink

[jira] [Created] (FLINK-15168) Exception is thrown when using kafka source connector with flink planner

2019-12-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15168: Summary: Exception is thrown when using kafka source connector with flink planner Key: FLINK-15168 URL: https://issues.apache.org/jira/browse/FLINK-15168 Project:

[jira] [Created] (FLINK-16040) Change local import to global import

2020-02-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16040: Summary: Change local import to global import Key: FLINK-16040 URL: https://issues.apache.org/jira/browse/FLINK-16040 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

2020-02-11 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16008: Summary: Add rules to transpose the join condition of Python Correlate node Key: FLINK-16008 URL: https://issues.apache.org/jira/browse/FLINK-16008 Project: Flink

[jira] [Created] (FLINK-16007) Add rules to push down the Java Calls contained in Python Correlate node

2020-02-11 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16007: Summary: Add rules to push down the Java Calls contained in Python Correlate node Key: FLINK-16007 URL: https://issues.apache.org/jira/browse/FLINK-16007 Project:

[jira] [Created] (FLINK-16435) Fix ide static check

2020-03-05 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16435: Summary: Fix ide static check Key: FLINK-16435 URL: https://issues.apache.org/jira/browse/FLINK-16435 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-15861) Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode

2020-02-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15861: Summary: Change TableEnvironmentImpl to StreamTableaEnvironmentImpl in python blink batch mode Key: FLINK-15861 URL: https://issues.apache.org/jira/browse/FLINK-15861

[jira] [Updated] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15913: - Parent: FLINK-14500 Issue Type: Sub-task (was: New Feature) > Add Python Table

[jira] [Created] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15913: Summary: Add Python Table Function Runner And Operator Key: FLINK-15913 URL: https://issues.apache.org/jira/browse/FLINK-15913 Project: Flink Issue Type:

[jira] [Updated] (FLINK-15913) Add Python Table Function Runner And Operator

2020-02-05 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15913: - Description: This Jira will include two PRs: * Add Python Table Function Runner and Operator

[jira] [Updated] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

2020-02-09 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15961: - Summary: Introduce Python Physical Correlate RelNodes which are containers for Python

[jira] [Created] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python Python TableFunction

2020-02-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15961: Summary: Introduce Python Physical Correlate RelNodes which are containers for Python Python TableFunction Key: FLINK-15961 URL:

[jira] [Created] (FLINK-15972) Add Python building blocks to make sure the basic functionality of Python TableFunction could work

2020-02-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15972: Summary: Add Python building blocks to make sure the basic functionality of Python TableFunction could work Key: FLINK-15972 URL:

[jira] [Created] (FLINK-16252) Optimize the progress of the process_outputs in Python UDF

2020-02-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16252: Summary: Optimize the progress of the process_outputs in Python UDF Key: FLINK-16252 URL: https://issues.apache.org/jira/browse/FLINK-16252 Project: Flink

[jira] [Created] (FLINK-16251) Optimize the cost of function call in ScalarFunctionOpertation

2020-02-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16251: Summary: Optimize the cost of function call in ScalarFunctionOpertation Key: FLINK-16251 URL: https://issues.apache.org/jira/browse/FLINK-16251 Project: Flink

[jira] [Created] (FLINK-16071) Optimize the cost of the get item of the Row in operation and coder

2020-02-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16071: Summary: Optimize the cost of the get item of the Row in operation and coder Key: FLINK-16071 URL: https://issues.apache.org/jira/browse/FLINK-16071 Project: Flink

[jira] [Created] (FLINK-16072) Optimize the performance of the write/read null mask in RowCoder

2020-02-15 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16072: Summary: Optimize the performance of the write/read null mask in RowCoder Key: FLINK-16072 URL: https://issues.apache.org/jira/browse/FLINK-16072 Project: Flink

[jira] [Commented] (FLINK-16026) Travis failed due to python setup

2020-02-12 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17035916#comment-17035916 ] Huang Xingbo commented on FLINK-16026: -- This issue is caused by the latest released avro package.

[jira] [Created] (FLINK-15650) Improve the udfs documentation of the Python API

2020-01-18 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15650: Summary: Improve the udfs documentation of the Python API Key: FLINK-15650 URL: https://issues.apache.org/jira/browse/FLINK-15650 Project: Flink Issue Type:

[jira] [Created] (FLINK-15657) Fix the python table api doc link

2020-01-18 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15657: Summary: Fix the python table api doc link Key: FLINK-15657 URL: https://issues.apache.org/jira/browse/FLINK-15657 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-15657) Fix the python table api doc link in Python API tutorial

2020-01-18 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15657?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15657: - Summary: Fix the python table api doc link in Python API tutorial (was: Fix the python table

[jira] [Created] (FLINK-15700) Improve Python API Tutorial doc

2020-01-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-15700: Summary: Improve Python API Tutorial doc Key: FLINK-15700 URL: https://issues.apache.org/jira/browse/FLINK-15700 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-15700) Improve Python API Tutorial doc

2020-01-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15700?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-15700: - Fix Version/s: 1.9.2 > Improve Python API Tutorial doc > --- > >

[jira] [Created] (FLINK-16516) Remove Python UDF Codegen Code

2020-03-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16516: Summary: Remove Python UDF Codegen Code Key: FLINK-16516 URL: https://issues.apache.org/jira/browse/FLINK-16516 Project: Flink Issue Type: Improvement

[jira] [Updated] (FLINK-16524) Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-11 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-16524: - Summary: Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate

[jira] [Updated] (FLINK-16524) Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate unnecessary function calls

2020-03-11 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16524?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-16524: - Description: Optimize the result of FlattenRowCoder and ArrowCoder to generator to eliminate

[jira] [Created] (FLINK-16522) Take use of Python3 type hint to rebuild Python Function signature

2020-03-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16522: Summary: Take use of Python3 type hint to rebuild Python Function signature Key: FLINK-16522 URL: https://issues.apache.org/jira/browse/FLINK-16522 Project: Flink

[jira] [Created] (FLINK-16524) Optimize the result of FlattenRowCoder to generator to eliminate unnecessary function calls

2020-03-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16524: Summary: Optimize the result of FlattenRowCoder to generator to eliminate unnecessary function calls Key: FLINK-16524 URL: https://issues.apache.org/jira/browse/FLINK-16524

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

2020-04-09 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17066: - Summary: Update pyarrow version bounds less than 0.14.0 (was: Limits the PyArrow version to

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

2020-04-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17066: Summary: Limits the PyArrow version to 0.13 Key: FLINK-17066 URL: https://issues.apache.org/jira/browse/FLINK-17066 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17065) Adds notes of Python versions supported by PyFlink in doc

2020-04-09 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17065?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17065: - Description: We need to add notes of Python versions supported by PyFlink in doc so that users

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

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

[jira] [Created] (FLINK-17065) Adds notes of Python versions supported by PyFlink in doc

2020-04-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17065: Summary: Adds notes of Python versions supported by PyFlink in doc Key: FLINK-17065 URL: https://issues.apache.org/jira/browse/FLINK-17065 Project: Flink

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

2020-04-09 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17066: - Description: We need to update pyarrow version bounds less than 0.14.0 in PyFlink 1.10. The

[jira] [Created] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17124: Summary: The PyFlink Job runs into infinite loop if the UDF file imports job code. Key: FLINK-17124 URL: https://issues.apache.org/jira/browse/FLINK-17124 Project:

[jira] [Commented] (FLINK-17124) The PyFlink Job runs into infinite loop if the UDF file imports job code.

2020-04-13 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17124?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17082398#comment-17082398 ] Huang Xingbo commented on FLINK-17124: -- I have prepared code to fix it. I think it will be merged

[jira] [Created] (FLINK-17121) Adds Pipeline of Building Wheel Packages in Azure CI

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17121: Summary: Adds Pipeline of Building Wheel Packages in Azure CI Key: FLINK-17121 URL: https://issues.apache.org/jira/browse/FLINK-17121 Project: Flink Issue

[jira] [Updated] (FLINK-17188) Failed to download conda when running python tests

2020-04-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17188: - Attachment: (was: image-2020-04-16-20-53-12-475.png) > Failed to download conda when

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

2020-04-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17084837#comment-17084837 ] Huang Xingbo commented on FLINK-17188: -- Thanks [~dwysakowicz] for finding this error. If it happens

[jira] [Updated] (FLINK-17188) Failed to download conda when running python tests

2020-04-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17188: - Attachment: image-2020-04-16-20-53-12-475.png > Failed to download conda when running python

[jira] [Created] (FLINK-17125) Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17125: Summary: Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users Key: FLINK-17125 URL: https://issues.apache.org/jira/browse/FLINK-17125

[jira] [Updated] (FLINK-17125) Add a Usage Notes Page to Answer Common Questions Encountered by PyFlink Users

2020-04-13 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17125?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17125: - Attachment: (was: image-2020-04-14-10-19-12-004.png) > Add a Usage Notes Page to Answer

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

2020-04-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087394#comment-17087394 ] Huang Xingbo commented on FLINK-17188: -- Thanks for the sharing. This issue occurs very frenquently

[jira] [Created] (FLINK-17115) Support Cython Optimizing Python User Defined Function(FLIP-121)

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17115: Summary: Support Cython Optimizing Python User Defined Function(FLIP-121) Key: FLINK-17115 URL: https://issues.apache.org/jira/browse/FLINK-17115 Project: Flink

[jira] [Updated] (FLINK-17212) Disable the cython tests

2020-04-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17212: - Parent: FLINK-17115 Issue Type: Sub-task (was: Improvement) > Disable the cython tests

[jira] [Created] (FLINK-17212) Disable the cython tests

2020-04-17 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17212: Summary: Disable the cython tests Key: FLINK-17212 URL: https://issues.apache.org/jira/browse/FLINK-17212 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-17188) Failed to download conda when running python tests

2020-04-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17085732#comment-17085732 ] Huang Xingbo commented on FLINK-17188: -- It looks like this is not an accident. I will add retrying

[jira] [Updated] (FLINK-17188) Failed to download conda when running python tests

2020-04-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17188: - Attachment: (was: image-2020-04-17-21-12-21-901.png) > Failed to download conda when

[jira] [Updated] (FLINK-17188) Failed to download conda when running python tests

2020-04-17 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17188: - Attachment: image-2020-04-17-21-12-21-901.png > Failed to download conda when running python

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

2020-04-06 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17013: Summary: Support Python UDTF in old planner under batch mode Key: FLINK-17013 URL: https://issues.apache.org/jira/browse/FLINK-17013 Project: Flink Issue

[jira] [Commented] (FLINK-16522) Use type hints to declare the signature of the methods

2020-04-06 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16522?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17076857#comment-17076857 ] Huang Xingbo commented on FLINK-16522: -- Hi [~rongr], thanks for your reminder. This Jira will

[jira] [Created] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1

2020-04-04 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16980: Summary: PyFlink UDF execution module is not compatible with protobuf 3.6.1 Key: FLINK-16980 URL: https://issues.apache.org/jira/browse/FLINK-16980 Project: Flink

[jira] [Updated] (FLINK-16980) PyFlink UDF execution module is not compatible with protobuf 3.6.1

2020-04-04 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16980?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-16980: - Affects Version/s: (was: 1.10.1) 1.10.0 > PyFlink UDF execution

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

2020-03-31 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16748?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-16748: - Parent: FLINK-14500 Issue Type: Sub-task (was: Improvement) > Add Python UDTF doc >

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

2020-03-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16796: Summary: Fix The Bug of Python UDTF in SQL Query Key: FLINK-16796 URL: https://issues.apache.org/jira/browse/FLINK-16796 Project: Flink Issue Type: Bug

[jira] [Commented] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

2020-04-27 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093241#comment-17093241 ] Huang Xingbo commented on FLINK-17394: -- Thanks a lot for your feedback. It makes sense to me. I'll

[jira] [Created] (FLINK-17414) Change the steps of building PyFlink in doc

2020-04-27 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17414: Summary: Change the steps of building PyFlink in doc Key: FLINK-17414 URL: https://issues.apache.org/jira/browse/FLINK-17414 Project: Flink Issue Type:

[jira] [Updated] (FLINK-17311) Add executable permissions to the script in the wheel package

2020-04-21 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17311: - Parent: FLINK-17115 Issue Type: Sub-task (was: Improvement) > Add executable

[jira] [Created] (FLINK-17311) Add executable permissions to the script in the wheel package

2020-04-21 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17311: Summary: Add executable permissions to the script in the wheel package Key: FLINK-17311 URL: https://issues.apache.org/jira/browse/FLINK-17311 Project: Flink

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

2020-04-28 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17423: Summary: Support Python UDTF in blink planner under batch mode Key: FLINK-17423 URL: https://issues.apache.org/jira/browse/FLINK-17423 Project: Flink Issue

[jira] [Created] (FLINK-17394) Add RemoteEnvironment and RemoteStreamEnvironment in Python

2020-04-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17394: Summary: Add RemoteEnvironment and RemoteStreamEnvironment in Python Key: FLINK-17394 URL: https://issues.apache.org/jira/browse/FLINK-17394 Project: Flink

[jira] [Created] (FLINK-17395) Add the sign and sha logic for PyFlink wheel packages

2020-04-26 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17395: Summary: Add the sign and sha logic for PyFlink wheel packages Key: FLINK-17395 URL: https://issues.apache.org/jira/browse/FLINK-17395 Project: Flink Issue

[jira] [Updated] (FLINK-17311) Add the logic of compressed in tgz before uploading artifacts

2020-04-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17311: - Summary: Add the logic of compressed in tgz before uploading artifacts (was: Add executable

[jira] [Updated] (FLINK-17311) Add executable permissions to the script in the wheel package

2020-04-26 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17311?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-17311: - Description:  Script files in packages downloaded from Azure will lose executable permissions

[jira] [Created] (FLINK-17118) Support Primitive DataTypes in Cython

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17118: Summary: Support Primitive DataTypes in Cython Key: FLINK-17118 URL: https://issues.apache.org/jira/browse/FLINK-17118 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17119) Support Composite DataTypes in Cython

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17119: Summary: Support Composite DataTypes in Cython Key: FLINK-17119 URL: https://issues.apache.org/jira/browse/FLINK-17119 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-17120) Support Cython Optimizing Python Operations

2020-04-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17120: Summary: Support Cython Optimizing Python Operations Key: FLINK-17120 URL: https://issues.apache.org/jira/browse/FLINK-17120 Project: Flink Issue Type:

[jira] [Commented] (FLINK-17679) Fix the bug of encoding bytes in cython coder

2020-05-13 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17679?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17106844#comment-17106844 ] Huang Xingbo commented on FLINK-17679: -- The suffix of bytes is ​​\x00 bytes, such as the example of

[jira] [Created] (FLINK-17679) Fix the bug of encoding bytes in cython coder

2020-05-13 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17679: Summary: Fix the bug of encoding bytes in cython coder Key: FLINK-17679 URL: https://issues.apache.org/jira/browse/FLINK-17679 Project: Flink Issue Type:

[jira] [Created] (FLINK-16691) Adjust Python UDF document to remind users to install PyFlink on the cluster

2020-03-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16691: Summary: Adjust Python UDF document to remind users to install PyFlink on the cluster Key: FLINK-16691 URL: https://issues.apache.org/jira/browse/FLINK-16691

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

2020-03-24 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16748: Summary: Add Python UDTF doc Key: FLINK-16748 URL: https://issues.apache.org/jira/browse/FLINK-16748 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-17567) Create a dedicated Python directory in release directory to place Python-related source and binary packages

2020-05-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-17567: Summary: Create a dedicated Python directory in release directory to place Python-related source and binary packages Key: FLINK-17567 URL:

[jira] [Created] (FLINK-19138) Python UDF supports directly specifying input_types as DataTypes.ROW

2020-09-03 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19138: Summary: Python UDF supports directly specifying input_types as DataTypes.ROW Key: FLINK-19138 URL: https://issues.apache.org/jira/browse/FLINK-19138 Project: Flink

[jira] [Created] (FLINK-19173) Add Pandas Batch Group Aggregation Function Operator

2020-09-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19173: Summary: Add Pandas Batch Group Aggregation Function Operator Key: FLINK-19173 URL: https://issues.apache.org/jira/browse/FLINK-19173 Project: Flink Issue

[jira] [Commented] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

2020-09-10 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17193498#comment-17193498 ] Huang Xingbo commented on FLINK-18836: -- [~dian.fu] Thanks a lot for reporting this. I will take a

[jira] [Created] (FLINK-19163) Add building py38 wheel package of PyFlink in Azure CI

2020-09-08 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19163: Summary: Add building py38 wheel package of PyFlink in Azure CI Key: FLINK-19163 URL: https://issues.apache.org/jira/browse/FLINK-19163 Project: Flink Issue

[jira] [Created] (FLINK-19184) Add Batch Physical Pandas Group Aggregate Rule and RelNode

2020-09-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19184: Summary: Add Batch Physical Pandas Group Aggregate Rule and RelNode Key: FLINK-19184 URL: https://issues.apache.org/jira/browse/FLINK-19184 Project: Flink

[jira] [Created] (FLINK-19186) Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work

2020-09-10 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19186: Summary: Add Python building blocks to make sure the basic functionality of Pandas Batch Group Aggregation could work Key: FLINK-19186 URL:

[jira] [Created] (FLINK-19169) Support Pandas UDAF in PyFlink (FLIP-137)

2020-09-09 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19169: Summary: Support Pandas UDAF in PyFlink (FLIP-137) Key: FLINK-19169 URL: https://issues.apache.org/jira/browse/FLINK-19169 Project: Flink Issue Type:

[jira] [Commented] (FLINK-19654) Improve the execution time of PyFlink end-to-end tests

2020-10-15 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17214571#comment-17214571 ] Huang Xingbo commented on FLINK-19654: -- [~dian.fu] Thanks a lot for opening this ticket.

[jira] [Commented] (FLINK-19534) build_wheels: linux failed with "ValueError: Incompatible component merge"

2020-10-11 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19534?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17212096#comment-17212096 ] Huang Xingbo commented on FLINK-19534: -- Thanks [~dian.fu] and [~rmetzger] for reporting this. I

[jira] [Commented] (FLINK-19654) Improve the execution time of PyFlink end-to-end tests

2020-10-16 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17215230#comment-17215230 ] Huang Xingbo commented on FLINK-19654: -- [~rmetzger]Thanks a lot for sharing. I have created a PR to

[jira] [Updated] (FLINK-19138) Python UDF supports directly specifying input_types as DataTypes.ROW

2020-10-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-19138: - Fix Version/s: (was: 1.12.0) > Python UDF supports directly specifying input_types as

[jira] [Created] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

2020-10-20 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19733: Summary: Make fast_operation and slow_operation produce functions consistent Key: FLINK-19733 URL: https://issues.apache.org/jira/browse/FLINK-19733 Project: Flink

[jira] [Commented] (FLINK-19483) PyFlink Table end-to-end test failed with "FileExistsError: [Errno 17] File exists: '/home/vsts/work/1/s/flink-python/dev/.conda/pkgs'"

2020-10-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19483?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217458#comment-17217458 ] Huang Xingbo commented on FLINK-19483: -- I will take a look soon. > PyFlink Table end-to-end test

[jira] [Updated] (FLINK-19733) Make fast_operation and slow_operation produce functions consistent

2020-10-20 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-19733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Huang Xingbo updated FLINK-19733: - Issue Type: Improvement (was: New Feature) > Make fast_operation and slow_operation produce

[jira] [Created] (FLINK-19643) Add Pandas UDAF Doc

2020-10-14 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-19643: Summary: Add Pandas UDAF Doc Key: FLINK-19643 URL: https://issues.apache.org/jira/browse/FLINK-19643 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-18836) Python UDTF doesn't work well when the return type isn't generator

2020-10-19 Thread Huang Xingbo (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18836?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17217235#comment-17217235 ] Huang Xingbo commented on FLINK-18836: -- [~dian.fu] Thanks a lot for review. I have submitted the PR 

  1   2   3   4   5   6   7   8   9   10   >