[jira] [Closed] (FLINK-14202) Optimize the execution plan for Python Calc when there is a condition

[ https://issues.apache.org/jira/browse/FLINK-14202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14202. --- Resolution: Resolved > Optimize the execution plan for Python Calc when there is a condition >

[jira] [Commented] (FLINK-14202) Optimize the execution plan for Python Calc when there is a condition

[ https://issues.apache.org/jira/browse/FLINK-14202?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16957610#comment-16957610 ] Hequn Cheng commented on FLINK-14202: - Resolved in 1.10.0 via

[jira] [Updated] (FLINK-14469) Drop Python 2 support

[ https://issues.apache.org/jira/browse/FLINK-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14469: Release Note: Python 2 is not supported for PyFlink in 1.10.0. This is because Python 2 is coming

[jira] [Updated] (FLINK-14469) Drop Python 2 support

[ https://issues.apache.org/jira/browse/FLINK-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14469: Release Note: Python2 is not be supported for PyFlink in 1.10.0. This is because python2 is

[jira] [Updated] (FLINK-14388) Support all the data types in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14388: Description: Currently, only BigInt type is supported and we should support the other types as

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

Hequn Cheng created FLINK-14497: --- Summary: Support primitive data types in Python user-defined functions Key: FLINK-14497 URL: https://issues.apache.org/jira/browse/FLINK-14497 Project: Flink

[jira] [Assigned] (FLINK-14388) Support all the data types in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14388: --- Assignee: Huang Xingbo > Support all the data types in Python user-defined functions >

[jira] [Closed] (FLINK-14469) Drop Python 2 support

[ https://issues.apache.org/jira/browse/FLINK-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14469. --- Resolution: Resolved > Drop Python 2 support > - > > Key:

[jira] [Commented] (FLINK-14469) Drop Python 2 support

[ https://issues.apache.org/jira/browse/FLINK-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16956204#comment-16956204 ] Hequn Cheng commented on FLINK-14469: - Resolved in 1.10.0 via

[jira] [Assigned] (FLINK-14469) Drop Python 2 support

[ https://issues.apache.org/jira/browse/FLINK-14469?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14469: --- Assignee: Dian Fu > Drop Python 2 support > - > > Key:

[jira] [Updated] (FLINK-14027) Add documentation for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14027: Description: We should add documentation about how to use Python user-defined functions. (was:

[jira] [Closed] (FLINK-14027) Add documentation for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14027. --- Resolution: Resolved > Add documentation for Python user-defined functions >

[jira] [Commented] (FLINK-14027) Add documentation for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955415#comment-16955415 ] Hequn Cheng commented on FLINK-14027: - Resolved in 1.10.0 via

[jira] [Closed] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14459. --- Resolution: Fixed > Python module build hangs > - > > Key:

[jira] [Commented] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955156#comment-16955156 ] Hequn Cheng commented on FLINK-14459: - Fix in 1.10.0: 2b1187d299bc6fd8dcae0d4e565238d7800dd4bb

[jira] [Updated] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14459: Affects Version/s: (was: 1.10.0) > Python module build hangs > - > >

[jira] [Updated] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14459: Fix Version/s: 1.9.2 1.10.0 > Python module build hangs >

[jira] [Commented] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16955132#comment-16955132 ] Hequn Cheng commented on FLINK-14459: - It seems a problem with the latest conda installer.

[jira] [Assigned] (FLINK-14459) Python module build hangs

[ https://issues.apache.org/jira/browse/FLINK-14459?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14459: --- Assignee: Hequn Cheng > Python module build hangs > - > >

[jira] [Created] (FLINK-14459) Python module build hangs

Hequn Cheng created FLINK-14459: --- Summary: Python module build hangs Key: FLINK-14459 URL: https://issues.apache.org/jira/browse/FLINK-14459 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-14272) Support Blink planner for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-14272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14272. --- Resolution: Resolved > Support Blink planner for Python UDF >

[jira] [Commented] (FLINK-14272) Support Blink planner for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-14272?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954678#comment-16954678 ] Hequn Cheng commented on FLINK-14272: - Resolved in 1.10.0 via

[jira] [Commented] (FLINK-14445) Python module build failed when making sdist

[ https://issues.apache.org/jira/browse/FLINK-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954522#comment-16954522 ] Hequn Cheng commented on FLINK-14445: - fixed in 1.10.0 via 6fbdab71f782be9e3d7b1bedc51402d46bab1e62

[jira] [Closed] (FLINK-14445) Python module build failed when making sdist

[ https://issues.apache.org/jira/browse/FLINK-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14445. --- Resolution: Fixed > Python module build failed when making sdist >

[jira] [Updated] (FLINK-14445) Python module build failed when making sdist

[ https://issues.apache.org/jira/browse/FLINK-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14445: Fix Version/s: 1.9.1 > Python module build failed when making sdist >

[jira] [Commented] (FLINK-14445) Python module build failed when making sdist

[ https://issues.apache.org/jira/browse/FLINK-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16954460#comment-16954460 ] Hequn Cheng commented on FLINK-14445: - The pr has been merged into the master now. I will pick it

[jira] [Assigned] (FLINK-14445) Python module build failed when making sdist

[ https://issues.apache.org/jira/browse/FLINK-14445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14445: --- Assignee: Wei Zhong > Python module build failed when making sdist >

[jira] [Assigned] (FLINK-14202) Optimize the execution plan for Python Calc when there is a condition

[ https://issues.apache.org/jira/browse/FLINK-14202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14202: --- Assignee: Dian Fu > Optimize the execution plan for Python Calc when there is a condition

[jira] [Assigned] (FLINK-14272) Support Blink planner for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-14272?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14272: --- Assignee: Huang Xingbo > Support Blink planner for Python UDF >

[jira] [Assigned] (FLINK-14342) Remove method FunctionDefinition#getLanguage

[ https://issues.apache.org/jira/browse/FLINK-14342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14342: --- Assignee: Wei Zhong > Remove method FunctionDefinition#getLanguage >

[jira] [Created] (FLINK-14385) There are ClassNotFoundException when run the example in Local Setup Tutorial

Hequn Cheng created FLINK-14385: --- Summary: There are ClassNotFoundException when run the example in Local Setup Tutorial Key: FLINK-14385 URL: https://issues.apache.org/jira/browse/FLINK-14385 Project:

[jira] [Assigned] (FLINK-14027) Add documentation for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14027: --- Assignee: Wei Zhong > Add documentation for Python user-defined functions >

[jira] [Closed] (FLINK-14208) Optimize Python UDFs with parameters of constant values

[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14208. --- Resolution: Resolved > Optimize Python UDFs with parameters of constant values >

[jira] [Commented] (FLINK-14208) Optimize Python UDFs with parameters of constant values

[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950066#comment-16950066 ] Hequn Cheng commented on FLINK-14208: - Resolved in 1.10.0 via:

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

[ https://issues.apache.org/jira/browse/FLINK-14383?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14383: --- Assignee: Huang Xingbo > Support python UDFs with constant value of time interval types >

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

Hequn Cheng created FLINK-14383: --- Summary: Support python UDFs with constant value of time interval types Key: FLINK-14383 URL: https://issues.apache.org/jira/browse/FLINK-14383 Project: Flink

[jira] [Commented] (FLINK-14212) Support Python UDFs without arguments

[ https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16950018#comment-16950018 ] Hequn Cheng commented on FLINK-14212: - Resolved in 1.10.0 via:

[jira] [Closed] (FLINK-14212) Support Python UDFs without arguments

[ https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14212. --- Resolution: Fixed > Support Python UDFs without arguments > - >

[jira] [Assigned] (FLINK-14208) Optimize Python UDFs with parameters of constant values

[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14208: --- Assignee: Huang Xingbo > Optimize Python UDFs with parameters of constant values >

[jira] [Assigned] (FLINK-14212) Support Python UDFs without arguments

[ https://issues.apache.org/jira/browse/FLINK-14212?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14212: --- Assignee: Wei Zhong > Support Python UDFs without arguments >

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Affects Version/s: (was: 1.9.0) > Flink-python builds with failure: no such option: --prefix

[jira] [Closed] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14341. --- Resolution: Fixed > Flink-python builds with failure: no such option: --prefix >

[jira] [Commented] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949046#comment-16949046 ] Hequn Cheng commented on FLINK-14341: - Fixed in 1.10.0 via: 2750b2ea29c440c6e699f756e5cd3431653fc49f

[jira] [Commented] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16949044#comment-16949044 ] Hequn Cheng commented on FLINK-14341: - Change jira type to "improvement" as previously, only pip

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Issue Type: Improvement (was: Bug) > Flink-python builds with failure: no such option: --prefix

[jira] [Updated] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14341: Fix Version/s: 1.10.0 > Flink-python builds with failure: no such option: --prefix >

[jira] [Assigned] (FLINK-14341) Flink-python builds with failure: no such option: --prefix

[ https://issues.apache.org/jira/browse/FLINK-14341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14341: --- Assignee: liupengcheng > Flink-python builds with failure: no such option: --prefix >

[jira] [Commented] (FLINK-13011) Release the PyFlink into PyPI

[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16948110#comment-16948110 ] Hequn Cheng commented on FLINK-13011: - That's cool. (y) > Release the PyFlink into PyPI >

[jira] [Closed] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14306. --- Resolution: Fixed > flink-python build fails with No module named pkg_resources >

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16947788#comment-16947788 ] Hequn Cheng commented on FLINK-14306: - Fixed in 1.10.0 via df44cce7f1e1bc42715e6cd0e7268c1a46b07af8

[jira] [Updated] (FLINK-14027) Add documentation for Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14027: Description: We should add documentation about how to use Python user-defined functions. Python

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16946964#comment-16946964 ] Hequn Cheng commented on FLINK-14306: - Thank you all for your valuable feedbacks. Also thank you

[jira] [Assigned] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14306: --- Assignee: Dian Fu > flink-python build fails with No module named pkg_resources >

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16945324#comment-16945324 ] Hequn Cheng commented on FLINK-14306: - [~pnowojski] Yes, virtualenv requires some dependencies. We

[jira] [Commented] (FLINK-14306) flink-python build fails with No module named pkg_resources

[ https://issues.apache.org/jira/browse/FLINK-14306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16944976#comment-16944976 ] Hequn Cheng commented on FLINK-14306: - Hi [~pnowojski] [~chesnay] [~trohrmann], sorry for the

[jira] [Commented] (FLINK-14288) Add Py4j NOTICE for source release

[ https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940630#comment-16940630 ] Hequn Cheng commented on FLINK-14288: - Fixed in 1.9.1: c9c10d84f063a2a2bcf98563891e43cae2e95697

[jira] [Closed] (FLINK-14288) Add Py4j NOTICE for source release

[ https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14288. --- Fix Version/s: 1.10.0 Resolution: Fixed > Add Py4j NOTICE for source release >

[jira] [Commented] (FLINK-14288) Add Py4j NOTICE for source release

[ https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940629#comment-16940629 ] Hequn Cheng commented on FLINK-14288: - [~sunjincheng121] [~dian.fu] thanks a lot for reporting and

[jira] [Closed] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14018. --- Resolution: Resolved > Add Python building blocks to make sure the basic functionality of Python >

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

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940471#comment-16940471 ] Hequn Cheng commented on FLINK-14018: - Resolved in 1.10.0 via:

[jira] [Closed] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14016. --- Resolution: Resolved > Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and >

[jira] [Commented] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16938324#comment-16938324 ] Hequn Cheng commented on FLINK-14016: - Resolved in 1.10.0 via

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

[ https://issues.apache.org/jira/browse/FLINK-14198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14198: --- Assignee: Wei Zhong > Add type options to all flink python API doc >

[jira] [Closed] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14167. --- Resolution: Resolved > Move python-related scripts in flink-dist to flink-python >

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Fix Version/s: 1.10.0 > Move python-related scripts in flink-dist to flink-python >

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Affects Version/s: (was: 1.9.0) > Move python-related scripts in flink-dist to flink-python >

[jira] [Updated] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14167: Affects Version/s: 1.9.0 > Move python-related scripts in flink-dist to flink-python >

[jira] [Commented] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936698#comment-16936698 ] Hequn Cheng commented on FLINK-14167: - Resolved in 1.10.0 via

[jira] [Commented] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935791#comment-16935791 ] Hequn Cheng commented on FLINK-14015: - Resolved in 1.10.0 via

[jira] [Closed] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14015. --- Resolution: Resolved > Introduce PythonScalarFunctionOperator as a standalone StreamOperator for >

[jira] [Assigned] (FLINK-14167) Move python-related scripts in flink-dist to flink-python

[ https://issues.apache.org/jira/browse/FLINK-14167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14167: --- Assignee: Wei Zhong > Move python-related scripts in flink-dist to flink-python >

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

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935223#comment-16935223 ] Hequn Cheng commented on FLINK-14150: - Fix in 1.10.0 via 8155d465520c4b616866d35395c3b10f7e809b78

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

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14150. --- Resolution: Fixed > Unnecessary __pycache__ directories appears in pyflink.zip >

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

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14150: Fix Version/s: 1.9.1 1.10.0 > Unnecessary __pycache__ directories appears in

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14140. --- Resolution: Fixed > The Flink Logo Displayed in Flink Python Shell is Broken >

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14140: Fix Version/s: 1.9.1 1.10.0 > The Flink Logo Displayed in Flink Python Shell

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16935002#comment-16935002 ] Hequn Cheng commented on FLINK-14140: - Fixed via 1.9.1: 8109d7ed7a4f05694017d3e97ede4a99186c22aa

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934409#comment-16934409 ] Hequn Cheng commented on FLINK-14140: - [~zhongwei] Thanks a lot for the checking. The PR looks good.

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

[ https://issues.apache.org/jira/browse/FLINK-14150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14150: --- Assignee: Wei Zhong > Unnecessary __pycache__ directories appears in pyflink.zip >

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934149#comment-16934149 ] Hequn Cheng edited comment on FLINK-14140 at 9/20/19 7:15 AM: -- Good catch!

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16934149#comment-16934149 ] Hequn Cheng commented on FLINK-14140: - Good catch! > The Flink Logo Displayed in Flink Python Shell

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

[ https://issues.apache.org/jira/browse/FLINK-14140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14140: --- Assignee: Wei Zhong > The Flink Logo Displayed in Flink Python Shell is Broken >

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

[ https://issues.apache.org/jira/browse/FLINK-8545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933921#comment-16933921 ] Hequn Cheng commented on FLINK-8545: Hi [~enricoc], yes this feature is still be considered. Some

[jira] [Commented] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933288#comment-16933288 ] Hequn Cheng commented on FLINK-14019: - +1 Having a detailed design document is a good idea! >

[jira] [Closed] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14014. --- Resolution: Resolved > Introduce PythonScalarFunctionRunner to handle the communication with Python

[jira] [Commented] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932543#comment-16932543 ] Hequn Cheng commented on FLINK-14014: - Resolved in master: e7216eebc846a69272c21375af0f4db8009c2e3e

[jira] [Closed] (FLINK-14017) Support to start up Python worker in process mode

[ https://issues.apache.org/jira/browse/FLINK-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14017. --- Resolution: Resolved > Support to start up Python worker in process mode >

[jira] [Commented] (FLINK-14017) Support to start up Python worker in process mode

[ https://issues.apache.org/jira/browse/FLINK-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932539#comment-16932539 ] Hequn Cheng commented on FLINK-14017: - Resolved in master: f65ee55a53e50b7e09db5500565ee4884670b7d2

[jira] [Commented] (FLINK-14066) Pyflink building failure in master and 1.9.0 version

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16932312#comment-16932312 ] Hequn Cheng commented on FLINK-14066: - [~coldmoon777] Hi, thanks for reporting the problem! The

[jira] [Assigned] (FLINK-14021) Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node

[ https://issues.apache.org/jira/browse/FLINK-14021?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14021: --- Assignee: Huang Xingbo > Add rules to push down the Python ScalarFunctions contained in

[jira] [Assigned] (FLINK-14022) Add validation check for places where Python ScalarFunction cannot be used

[ https://issues.apache.org/jira/browse/FLINK-14022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14022: --- Assignee: Huang Xingbo > Add validation check for places where Python ScalarFunction

[jira] [Assigned] (FLINK-14020) User Apache Arrow as the serializer for data transmission between Java operator and Python harness

[ https://issues.apache.org/jira/browse/FLINK-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14020: --- Assignee: Dian Fu > User Apache Arrow as the serializer for data transmission between Java

[jira] [Assigned] (FLINK-14019) Python environment and dependency management

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14019: --- Assignee: Wei Zhong > Python environment and dependency management >

[jira] [Assigned] (FLINK-14018) Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work

[ https://issues.apache.org/jira/browse/FLINK-14018?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14018: --- Assignee: Dian Fu > Add Python building blocks to make sure the basic functionality of

[jira] [Assigned] (FLINK-14017) Support to start up Python worker in process mode

[ https://issues.apache.org/jira/browse/FLINK-14017?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14017: --- Assignee: Wei Zhong > Support to start up Python worker in process mode >

[jira] [Assigned] (FLINK-14015) Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14015?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14015: --- Assignee: Dian Fu > Introduce PythonScalarFunctionOperator as a standalone StreamOperator

[jira] [Assigned] (FLINK-14016) Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions

[ https://issues.apache.org/jira/browse/FLINK-14016?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14016: --- Assignee: Dian Fu > Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and >

[jira] [Assigned] (FLINK-14014) Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution

[ https://issues.apache.org/jira/browse/FLINK-14014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14014: --- Assignee: Dian Fu > Introduce PythonScalarFunctionRunner to handle the communication with

[jira] [Commented] (FLINK-13906) ExecutionConfigTests.test_equals_and_hash failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16921800#comment-16921800 ] Hequn Cheng commented on FLINK-13906: - [~jark] Thanks for the advice, good idea. >

[jira] [Closed] (FLINK-13906) ExecutionConfigTests.test_equals_and_hash failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13906?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-13906. --- Resolution: Fixed > ExecutionConfigTests.test_equals_and_hash failed on Travis >

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