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

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12716: --- Summary: Add an interactive shell for Python Table API Key: FLINK-12716 URL: https://issues.apache.org/jira/browse/FLINK-12716 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12717) Add windows support for the Python shell script

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12717: --- Summary: Add windows support for the Python shell script Key: FLINK-12717 URL: https://issues.apache.org/jira/browse/FLINK-12717 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12719) Add the catalog API for the Python Table API

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12719: --- Summary: Add the catalog API for the Python Table API Key: FLINK-12719 URL: https://issues.apache.org/jira/browse/FLINK-12719 Project: Flink Issue Type: Sub-task

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

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12720: --- Summary: Add the Python Table API Sphinx docs Key: FLINK-12720 URL: https://issues.apache.org/jira/browse/FLINK-12720 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12722) Adds Python Table API tutorial

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12722: --- Summary: Adds Python Table API tutorial Key: FLINK-12722 URL: https://issues.apache.org/jira/browse/FLINK-12722 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12719) Add the Python catalog API

2019-06-03 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12719?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12719: Summary: Add the Python catalog API (was: Add the catalog API for the Python Table API) > Add the

[jira] [Created] (FLINK-12723) Adds a wiki page about setting up a Python Table API development environment

2019-06-03 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12723: --- Summary: Adds a wiki page about setting up a Python Table API development environment Key: FLINK-12723 URL: https://issues.apache.org/jira/browse/FLINK-12723 Project: Flink

[jira] [Updated] (FLINK-12767) Support user defined connectors/format

2019-06-06 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12767: Component/s: (was: API / Python) Table SQL / API > Support user defined

[jira] [Created] (FLINK-12757) Improves the Python word_count example to use the descriptor API

2019-06-05 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12757: --- Summary: Improves the Python word_count example to use the descriptor API Key: FLINK-12757 URL: https://issues.apache.org/jira/browse/FLINK-12757 Project: Flink

[jira] [Commented] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

2019-06-05 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16857303#comment-16857303 ] Dian Fu commented on FLINK-12541: - Hi [~sunjincheng121]  Regarding to Kubernetes support for Python

[jira] [Updated] (FLINK-12767) Support user defined connectors/format

2019-06-06 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12767?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12767: Component/s: (was: Table SQL / API) API / Python > Support user defined

[jira] [Comment Edited] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

2019-06-05 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16857303#comment-16857303 ] Dian Fu edited comment on FLINK-12541 at 6/6/19 5:32 AM: - Hi [~sunjincheng121] 

[jira] [Created] (FLINK-12767) Support user defined connectors/format

2019-06-06 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12767: --- Summary: Support user defined connectors/format Key: FLINK-12767 URL: https://issues.apache.org/jira/browse/FLINK-12767 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12821) Fix the bug that fix time quantifier can not be the last element of a pattern

2019-06-16 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12821: Description: Currently, exception "Greedy quantifiers are not allowed as the last element of a Pattern

[jira] [Updated] (FLINK-12821) Fix the bug that fix time quantifier can not be the last element of a pattern

2019-06-16 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12821: Fix Version/s: 1.8.1 1.9.0 1.7.3 > Fix the bug that fix time

[jira] [Updated] (FLINK-12821) Fix the bug that fix time quantifier can not be the last element of a pattern

2019-06-16 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12821?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12821: Fix Version/s: (was: 1.8.1) (was: 1.7.3) (was: 1.9.0) >

[jira] [Updated] (FLINK-12788) Add support to run a Python job-specific cluster on Kubernetes

2019-06-10 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12788: Labels: pull-request-available (was: ) > Add support to run a Python job-specific cluster on Kubernetes

[jira] [Commented] (FLINK-12803) Correct the package name for python API

2019-06-11 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12803?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16860954#comment-16860954 ] Dian Fu commented on FLINK-12803: - Good catch. +1.  > Correct the package name for python API >

[jira] [Created] (FLINK-12787) Allow to specify directory in option -pyfs

2019-06-09 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12787: --- Summary: Allow to specify directory in option -pyfs Key: FLINK-12787 URL: https://issues.apache.org/jira/browse/FLINK-12787 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12788) Add support to run a Python job-specific cluster on Kubernetes

2019-06-09 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12788: --- Summary: Add support to run a Python job-specific cluster on Kubernetes Key: FLINK-12788 URL: https://issues.apache.org/jira/browse/FLINK-12788 Project: Flink Issue

[jira] [Commented] (FLINK-12541) Add deploy a Python Flink job and session cluster on Kubernetes support.

2019-06-09 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12541?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16859718#comment-16859718 ] Dian Fu commented on FLINK-12541: - [~sunjincheng121] Thanks a lot for the suggestions. I have create a

[jira] [Created] (FLINK-12821) Fix the bug that fix time quantifier can not be the last element of a pattern

2019-06-12 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12821: --- Summary: Fix the bug that fix time quantifier can not be the last element of a pattern Key: FLINK-12821 URL: https://issues.apache.org/jira/browse/FLINK-12821 Project: Flink

[jira] [Commented] (FLINK-12910) Fix the Python catalog test issue

2019-06-20 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12910?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16868468#comment-16868468 ] Dian Fu commented on FLINK-12910: - This issue is introduced in 

[jira] [Created] (FLINK-12910) Fix the Python catalog test issue

2019-06-20 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12910: --- Summary: Fix the Python catalog test issue Key: FLINK-12910 URL: https://issues.apache.org/jira/browse/FLINK-12910 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12897) Improve the Python Table API docs by adding more examples

2019-06-19 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12897: --- Summary: Improve the Python Table API docs by adding more examples Key: FLINK-12897 URL: https://issues.apache.org/jira/browse/FLINK-12897 Project: Flink Issue Type:

[jira] [Created] (FLINK-12920) Drop support for register_table_sink with field_names and field_types parameters

2019-06-20 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12920: --- Summary: Drop support for register_table_sink with field_names and field_types parameters Key: FLINK-12920 URL: https://issues.apache.org/jira/browse/FLINK-12920 Project:

[jira] [Assigned] (FLINK-12931) lint-python.sh cannot find flake8

2019-06-22 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12931?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-12931: --- Assignee: Dian Fu (was: sunjincheng) > lint-python.sh cannot find flake8 >

[jira] [Created] (FLINK-12962) Allows pyflink to be pip installed

2019-06-24 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12962: --- Summary: Allows pyflink to be pip installed Key: FLINK-12962 URL: https://issues.apache.org/jira/browse/FLINK-12962 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-12585) Align Stream/BatchTableEnvironment with JAVA Table API

2019-05-21 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16845494#comment-16845494 ] Dian Fu commented on FLINK-12585: - Agree. Having a Python

[jira] [Updated] (FLINK-12609) Align the data types of Python with Java

2019-05-23 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12609: Description: As discussed in  https://github.com/apache/flink/pull/8420#issuecomment-495444623,

[jira] [Created] (FLINK-12609) Align the data types of Python with Java

2019-05-23 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12609: --- Summary: Align the data types of Python with Java Key: FLINK-12609 URL: https://issues.apache.org/jira/browse/FLINK-12609 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12609) Align the Python data types with Java

2019-05-23 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12609?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12609: Summary: Align the Python data types with Java (was: Align the data types of Python with Java) > Align

[jira] [Commented] (FLINK-12456) Wrong CharType convertion in type_utils.py

2019-05-24 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16847539#comment-16847539 ] Dian Fu commented on FLINK-12456: - [~lzljs3620320]  Thanks a lot for reporting this issue. Good catch!

[jira] [Commented] (FLINK-11052) Add Bounded(Group Window) FlatAggregate operator to batch Table API

2019-05-10 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16837117#comment-16837117 ] Dian Fu commented on FLINK-11052: - I'm afraid I have no time to work on this issue these days. Feel free

[jira] [Updated] (FLINK-12455) Move the packaging of pyflink to flink-dist

2019-05-08 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12455?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12455: Summary: Move the packaging of pyflink to flink-dist (was: Move the package of pyflink to flink-dist) >

[jira] [Created] (FLINK-12455) Move the package of pyflink to flink-dist

2019-05-08 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12455: --- Summary: Move the package of pyflink to flink-dist Key: FLINK-12455 URL: https://issues.apache.org/jira/browse/FLINK-12455 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12409) Adds from_elements in TableEnvironment

2019-05-05 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12409: --- Summary: Adds from_elements in TableEnvironment Key: FLINK-12409 URL: https://issues.apache.org/jira/browse/FLINK-12409 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12408) Support to define all kinds of types in Python API

2019-05-05 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12408: --- Summary: Support to define all kinds of types in Python API Key: FLINK-12408 URL: https://issues.apache.org/jira/browse/FLINK-12408 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-10976) Add Aggregate operator to Table API

2019-05-04 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-10976?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-10976: --- Assignee: (was: Dian Fu) > Add Aggregate operator to Table API >

[jira] [Closed] (FLINK-13085) unable to run python test locally

2019-07-05 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-13085. --- Resolution: Cannot Reproduce [~phoenixjiangnan] As explained above, I think this is not a bug. Just close

[jira] [Closed] (FLINK-12456) Wrong CharType convertion in type_utils.py

2019-07-05 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12456?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu closed FLINK-12456. --- Resolution: Duplicate [~lzljs3620320] This issue should have been resolved in FLINK-12408. Just close this

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

2019-06-27 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16874684#comment-16874684 ] Dian Fu commented on FLINK-13011: - [~sunjincheng121] [~Zentol] I have contacted the owner of

[jira] [Commented] (FLINK-13085) unable to run python test locally

2019-07-03 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16878255#comment-16878255 ] Dian Fu commented on FLINK-13085: - [~phoenixjiangnan] The exception is because the interfaces of Java

[jira] [Assigned] (FLINK-12326) Add a basic test framework, just like the existing Java TableAPI, abstract some TestBase.

2019-04-24 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-12326: --- Assignee: Dian Fu > Add a basic test framework, just like the existing Java TableAPI, abstract >

[jira] [Commented] (FLINK-12308) Support python language in Flink Table API

2019-04-24 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16825698#comment-16825698 ] Dian Fu commented on FLINK-12308: - Hi [~sunjincheng121] that's very kind of you. It is great to

[jira] [Commented] (FLINK-12308) Support python language in Flink Table API

2019-04-23 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16824834#comment-16824834 ] Dian Fu commented on FLINK-12308: - Thanks [~sunjincheng121] for creating this ticket. A big +1 on this

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

2019-06-26 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12991: Description: The following method is added in catalog.py in FLINK-11480: {code} def

[jira] [Updated] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

2019-06-26 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12991?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-12991: Description: The following method is added in catalog.py in FLINK-11480: {code:java} def

[jira] [Created] (FLINK-12990) Date type doesn't consider the local TimeZone

2019-06-25 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12990: --- Summary: Date type doesn't consider the local TimeZone Key: FLINK-12990 URL: https://issues.apache.org/jira/browse/FLINK-12990 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-12991) Correct the implementation of Catalog.get_table_factory

2019-06-26 Thread Dian Fu (JIRA)
Dian Fu created FLINK-12991: --- Summary: Correct the implementation of Catalog.get_table_factory Key: FLINK-12991 URL: https://issues.apache.org/jira/browse/FLINK-12991 Project: Flink Issue Type:

[jira] [Created] (FLINK-13743) Port PythonTableUtils to flink-python module

2019-08-16 Thread Dian Fu (JIRA)
Dian Fu created FLINK-13743: --- Summary: Port PythonTableUtils to flink-python module Key: FLINK-13743 URL: https://issues.apache.org/jira/browse/FLINK-13743 Project: Flink Issue Type: Task

[jira] [Comment Edited] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916370#comment-16916370 ] Dian Fu edited comment on FLINK-13488 at 8/27/19 5:01 AM: -- Hi [~ykt836], I

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-08-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916370#comment-16916370 ] Dian Fu commented on FLINK-13488: - Hi [~ykt836], I guess this fix is actually contained in

[jira] [Commented] (FLINK-6935) Integration of SQL and CEP

2019-08-28 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-6935?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16917548#comment-16917548 ] Dian Fu commented on FLINK-6935: Hi [~libenchao] Most of the features mentioned there is available in

[jira] [Commented] (FLINK-14066) bug of building pyflink in master and 1.9.0 version

2019-09-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928369#comment-16928369 ] Dian Fu commented on FLINK-14066: - Hi [~coldmoon777], currently PyFlink is still not supported on

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

2019-09-12 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16928507#comment-16928507 ] Dian Fu commented on FLINK-14066: - I mean that for windows support, we need to consider both building

[jira] [Created] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14013: --- Summary: Support Flink Python User-Defined Stateless Function for Table Key: FLINK-14013 URL: https://issues.apache.org/jira/browse/FLINK-14013 Project: Flink Issue

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14015: --- Summary: Introduce PythonScalarFunctionOperator as a standalone StreamOperator for Python ScalarFunction execution Key: FLINK-14015 URL: https://issues.apache.org/jira/browse/FLINK-14015

[jira] [Updated] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2019-09-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14013: Description: The Python Table API has been supported in release 1.9.0. See the

[jira] [Updated] (FLINK-14013) Support Flink Python User-Defined Stateless Function for Table

2019-09-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14013?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14013: Description: The Python Table API has been supported in release 1.9.0. See the

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14014: --- Summary: Introduce PythonScalarFunctionRunner to handle the communication with Python worker for Python ScalarFunction execution Key: FLINK-14014 URL:

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14016: --- Summary: Introduce RelNodes FlinkLogicalPythonScalarFunctionExec and DataStreamPythonScalarFunctionExec which are containers for Python PythonScalarFunctions Key: FLINK-14016 URL:

[jira] [Created] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

2019-09-06 Thread Dian Fu (Jira)
Dian Fu created FLINK-13999: --- Summary: Correct the documentation of MATCH_RECOGNIZE Key: FLINK-13999 URL: https://issues.apache.org/jira/browse/FLINK-13999 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

2019-09-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-13999: Description: Regarding to the following [example|#aggregations]] in the doc: {code:java} SELECT * FROM

[jira] [Commented] (FLINK-13999) Correct the documentation of MATCH_RECOGNIZE

2019-09-06 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13999?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16924731#comment-16924731 ] Dian Fu commented on FLINK-13999: - This issue is reported in the user list: 

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14027: --- Summary: Add documentation for Python user-defined functions Key: FLINK-14027 URL: https://issues.apache.org/jira/browse/FLINK-14027 Project: Flink Issue Type:

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14022: --- Summary: Add validation check for places where Python ScalarFunction cannot be used Key: FLINK-14022 URL: https://issues.apache.org/jira/browse/FLINK-14022 Project: Flink

[jira] [Created] (FLINK-14023) Support accessing job parameters in Python user-defined functions

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14023: --- Summary: Support accessing job parameters in Python user-defined functions Key: FLINK-14023 URL: https://issues.apache.org/jira/browse/FLINK-14023 Project: Flink

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14017: --- Summary: Support to start up Python worker in process mode Key: FLINK-14017 URL: https://issues.apache.org/jira/browse/FLINK-14017 Project: Flink Issue Type: Sub-task

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14018: --- Summary: Add Python building blocks to make sure the basic functionality of Python ScalarFunction could work Key: FLINK-14018 URL: https://issues.apache.org/jira/browse/FLINK-14018

[jira] [Created] (FLINK-14024) Support use-defined metrics in Python user-defined functions

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14024: --- Summary: Support use-defined metrics in Python user-defined functions Key: FLINK-14024 URL: https://issues.apache.org/jira/browse/FLINK-14024 Project: Flink Issue

[jira] [Created] (FLINK-14026) Manage the resource of Python worker properly

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14026: --- Summary: Manage the resource of Python worker properly Key: FLINK-14026 URL: https://issues.apache.org/jira/browse/FLINK-14026 Project: Flink Issue Type: Sub-task

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

2019-09-09 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14020?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14020: Description: Apache Arrow is "a cross-language development platform for in-memory data. It specifies a

[jira] [Created] (FLINK-14025) Support to run the Python worker in docker mode

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14025: --- Summary: Support to run the Python worker in docker mode Key: FLINK-14025 URL: https://issues.apache.org/jira/browse/FLINK-14025 Project: Flink Issue Type: Sub-task

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14019: --- Summary: Python environment and dependency management Key: FLINK-14019 URL: https://issues.apache.org/jira/browse/FLINK-14019 Project: Flink Issue Type: Sub-task

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14020: --- Summary: User Apache Arrow as the serializer for data transmission between Java operator and Python harness Key: FLINK-14020 URL: https://issues.apache.org/jira/browse/FLINK-14020

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

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14021: --- Summary: Add rules to push down the Python ScalarFunctions contained in the join condition of Correlate node Key: FLINK-14021 URL: https://issues.apache.org/jira/browse/FLINK-14021

[jira] [Created] (FLINK-14028) Support logging aggregation in Python user-defined functions

2019-09-09 Thread Dian Fu (Jira)
Dian Fu created FLINK-14028: --- Summary: Support logging aggregation in Python user-defined functions Key: FLINK-14028 URL: https://issues.apache.org/jira/browse/FLINK-14028 Project: Flink Issue

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-07-30 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16895917#comment-16895917 ] Dian Fu commented on FLINK-13488: - [~sunjincheng121] +1 to drop the support for python 3.3 and 3.4.

[jira] [Commented] (FLINK-13488) flink-python fails to build on Travis due to PackagesNotFoundError

2019-07-30 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16896098#comment-16896098 ] Dian Fu commented on FLINK-13488: - Make sense to me. > flink-python fails to build on Travis due to

[jira] [Assigned] (FLINK-13308) flink-python releases 2 jars

2019-07-17 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-13308: --- Assignee: Dian Fu > flink-python releases 2 jars > > >

[jira] [Commented] (FLINK-13308) flink-python releases 2 jars

2019-07-17 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886965#comment-16886965 ] Dian Fu commented on FLINK-13308: - Hi [~Zentol] Thanks a lot for opening this ticket. Either way makes

[jira] [Commented] (FLINK-13308) flink-python releases 2 jars

2019-07-17 Thread Dian Fu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-13308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16886978#comment-16886978 ] Dian Fu commented on FLINK-13308: - Sounds good. I'll take this issue and provide a PR ASAP. >

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

2019-09-19 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16933348#comment-16933348 ] Dian Fu commented on FLINK-14019: - Looking forward to the design doc. This is a very important feature

[jira] [Created] (FLINK-14269) The close method does not work for UserDefinedFunction

2019-09-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-14269: --- Summary: The close method does not work for UserDefinedFunction Key: FLINK-14269 URL: https://issues.apache.org/jira/browse/FLINK-14269 Project: Flink Issue Type:

[jira] [Updated] (FLINK-14269) The close method does not work for UserDefinedFunction

2019-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14269: Description: As discussed in [https://github.com/apache/flink/pull/9766], the close method of

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

2019-09-29 Thread Dian Fu (Jira)
Dian Fu created FLINK-14272: --- Summary: Support Blink planner for Python UDF Key: FLINK-14272 URL: https://issues.apache.org/jira/browse/FLINK-14272 Project: Flink Issue Type: Sub-task

[jira] [Commented] (FLINK-14269) The close method does not work for Python UserDefinedFunction

2019-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940303#comment-16940303 ] Dian Fu commented on FLINK-14269: - [~jark] Thanks for correction the title. The new title makes sense to

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

2019-09-26 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14208: Description: We need support Python UDFs with parameters of constant values. It should be noticed that

[jira] [Created] (FLINK-14240) The configuration added via TableConfig#configuration should be added to GlobalJobParameters for the legacy planner

2019-09-26 Thread Dian Fu (Jira)
Dian Fu created FLINK-14240: --- Summary: The configuration added via TableConfig#configuration should be added to GlobalJobParameters for the legacy planner Key: FLINK-14240 URL:

[jira] [Commented] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936693#comment-16936693 ] Dian Fu commented on FLINK-14178: - Hi [~wangxiyuan], Thanks a lot for your great work. The

[jira] [Comment Edited] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936693#comment-16936693 ] Dian Fu edited comment on FLINK-14178 at 9/24/19 11:36 AM: --- Hi [~wangxiyuan],

[jira] [Comment Edited] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-24 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16936693#comment-16936693 ] Dian Fu edited comment on FLINK-14178 at 9/24/19 11:35 AM: --- Hi [~wangxiyuan],

[jira] [Commented] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

2019-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940631#comment-16940631 ] Dian Fu commented on FLINK-14226: - Hi [~sunjincheng121], I'm +1 to downgrade maven-shade-plugin to

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

2019-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14288?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940591#comment-16940591 ] Dian Fu commented on FLINK-14288: - Hi [~sunjincheng121], good catch! I'd like to take this issue. Would

[jira] [Commented] (FLINK-14178) maven-shade-plugin 3.2.1 doesn't work on ARM for Flink

2019-09-29 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940626#comment-16940626 ] Dian Fu commented on FLINK-14178: - [~sunjincheng121] Downgrading the maven-shade-plugin to 3.1.0 makes

[jira] [Created] (FLINK-14222) Optimize for Python UDFs with all parameters are constant values

2019-09-25 Thread Dian Fu (Jira)
Dian Fu created FLINK-14222: --- Summary: Optimize for Python UDFs with all parameters are constant values Key: FLINK-14222 URL: https://issues.apache.org/jira/browse/FLINK-14222 Project: Flink

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

2019-09-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14208: Summary: Optimize Python UDFs with parameters of constant values (was: Support Python UDF with

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

2019-09-25 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14208?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu updated FLINK-14208: Description: We need optimize Python UDFs with parameters of constant values. For example, the constant

[jira] [Commented] (FLINK-14226) Subset of nightly tests fail due to No output has been received in the last 10m0s

2019-09-30 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16940796#comment-16940796 ] Dian Fu commented on FLINK-14226: - [~trohrmann] Thanks for the remind. The cron test is still running,

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