[jira] [Updated] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent

[ https://issues.apache.org/jira/browse/FLINK-19913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19913: Description: The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are

[jira] [Created] (FLINK-19913) The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent

sunjincheng created FLINK-19913: --- Summary: The precision in document and code of `INTERVAL DAY(p1) TO SECOND(p2)` are inconsistent Key: FLINK-19913 URL: https://issues.apache.org/jira/browse/FLINK-19913

[jira] [Closed] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name.

[ https://issues.apache.org/jira/browse/FLINK-19337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-19337. --- Resolution: Fixed > Make a little bit improvement for PyFlink package structure and class name. >

[jira] [Created] (FLINK-19337) Make a little bit improvement for PyFlink package structure and class name.

sunjincheng created FLINK-19337: --- Summary: Make a little bit improvement for PyFlink package structure and class name. Key: FLINK-19337 URL: https://issues.apache.org/jira/browse/FLINK-19337 Project:

[jira] [Closed] (FLINK-17877) Add support for Python 3.8

[ https://issues.apache.org/jira/browse/FLINK-17877?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-17877. --- Fix Version/s: 1.12.0 Assignee: sunjincheng Resolution: Fixed > Add support for

[jira] [Closed] (FLINK-9786) Publish Python libraries to pypi

[ https://issues.apache.org/jira/browse/FLINK-9786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-9786. -- Fix Version/s: 1.10.0 Resolution: Done We can install pyflink by "pip install apache-flink"

[jira] [Updated] (FLINK-19131) Add py38 support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19131: Labels: pull-request-available (was: ) > Add py38 support in PyFlink >

[jira] [Updated] (FLINK-19131) Add py38 support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19131: Labels: (was: python) > Add py38 support in PyFlink > --- > >

[jira] [Updated] (FLINK-19131) Add py38 support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19131: Labels: python (was: pull-request-available) > Add py38 support in PyFlink >

[jira] [Updated] (FLINK-19131) Add py38 support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19131: Environment: (was: At present, py39 has been released, and many open source projects have

[jira] [Updated] (FLINK-19131) Add py38 support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-19131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-19131: Description: At present, py39 has been released, and many open source projects have supported

[jira] [Closed] (FLINK-19118) Support Expression in the operations of the Python Table API

[ https://issues.apache.org/jira/browse/FLINK-19118?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-19118. --- Resolution: Fixed Fixed in Master: a8cc62a901dabe6c4d877b97db6024715b68174a > Support Expression

[jira] [Created] (FLINK-19131) Add py38 support in PyFlink

sunjincheng created FLINK-19131: --- Summary: Add py38 support in PyFlink Key: FLINK-19131 URL: https://issues.apache.org/jira/browse/FLINK-19131 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-18910) Create the new document structure for Python documentation according to FLIP-133

[ https://issues.apache.org/jira/browse/FLINK-18910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18910: --- Assignee: Wei Zhong > Create the new document structure for Python documentation according

[jira] [Assigned] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18775: --- Assignee: Wei Zhong (was: sunjincheng) > Rework PyFlink Documentation >

[jira] [Closed] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-18816. --- Fix Version/s: 1.11.2 1.12.0 Resolution: Fixed Fixed in Master:

[jira] [Commented] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17171240#comment-17171240 ] sunjincheng commented on FLINK-18816: - Thanks for the PR [~huaouo] > Correct API usage in Pyflink

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: Zhenhua Yang > Correct API usage in Pyflink Dependency Management page >

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: (was: sunjincheng) > Correct API usage in Pyflink Dependency Management page

[jira] [Assigned] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18816: --- Assignee: sunjincheng > Correct API usage in Pyflink Dependency Management page >

[jira] [Updated] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

[ https://issues.apache.org/jira/browse/FLINK-18816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18816: Labels: beginner (was: ) > Correct API usage in Pyflink Dependency Management page >

[jira] [Created] (FLINK-18816) Correct API usage in Pyflink Dependency Management page

sunjincheng created FLINK-18816: --- Summary: Correct API usage in Pyflink Dependency Management page Key: FLINK-18816 URL: https://issues.apache.org/jira/browse/FLINK-18816 Project: Flink Issue

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18775: Description: Since the release of Flink 1.11, users of PyFlink have continued to grow. According

[jira] [Updated] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18775: Description: Since the release of Flink 1.11, users of PyFlink have continued to grow. According

[jira] [Assigned] (FLINK-18775) Rework PyFlink Documentation

[ https://issues.apache.org/jira/browse/FLINK-18775?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18775: --- Assignee: sunjincheng > Rework PyFlink Documentation > > >

[jira] [Created] (FLINK-18775) Rework PyFlink Documentation

sunjincheng created FLINK-18775: --- Summary: Rework PyFlink Documentation Key: FLINK-18775 URL: https://issues.apache.org/jira/browse/FLINK-18775 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17139150#comment-17139150 ] sunjincheng commented on FLINK-18356: - It seems that there is a shortage of resources. It may be

[jira] [Updated] (FLINK-18356) Exit code 137 returned from process when testing pyflink

[ https://issues.apache.org/jira/browse/FLINK-18356?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18356: Component/s: Build System / Azure Pipelines > Exit code 137 returned from process when testing

[jira] [Closed] (FLINK-18099) Release guard for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-18099. --- Resolution: Fixed > Release guard for PyFlink > - > > Key:

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126642#comment-17126642 ] sunjincheng commented on FLINK-16497: - Thank you for active discussion！My original intention

[jira] [Assigned] (FLINK-18105) Test submitting Java SQL job with Python UDF

[ https://issues.apache.org/jira/browse/FLINK-18105?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18105: --- Assignee: Wei Zhong > Test submitting Java SQL job with Python UDF >

[jira] [Assigned] (FLINK-18104) Test pyflink on windows

[ https://issues.apache.org/jira/browse/FLINK-18104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-18104: --- Assignee: Wei Zhong > Test pyflink on windows > --- > >

[jira] [Created] (FLINK-18108) Wheel package consistency checks

sunjincheng created FLINK-18108: --- Summary: Wheel package consistency checks Key: FLINK-18108 URL: https://issues.apache.org/jira/browse/FLINK-18108 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-18107) Performance tests for PyFlink UDFs

[ https://issues.apache.org/jira/browse/FLINK-18107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18107: Description: Check items as follows: * Performance tests for Python UDF * Performance tests for

[jira] [Created] (FLINK-18107) Performance tests for PyFlink UDFs

sunjincheng created FLINK-18107: --- Summary: Performance tests for PyFlink UDFs Key: FLINK-18107 URL: https://issues.apache.org/jira/browse/FLINK-18107 Project: Flink Issue Type: Test

[jira] [Updated] (FLINK-18107) Performance tests for PyFlink UDFs

[ https://issues.apache.org/jira/browse/FLINK-18107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18107: Priority: Blocker (was: Major) > Performance tests for PyFlink UDFs >

[jira] [Created] (FLINK-18106) Tests Python UDTF support

sunjincheng created FLINK-18106: --- Summary: Tests Python UDTF support Key: FLINK-18106 URL: https://issues.apache.org/jira/browse/FLINK-18106 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-18105) Test submitting Java SQL job with Python UDF

sunjincheng created FLINK-18105: --- Summary: Test submitting Java SQL job with Python UDF Key: FLINK-18105 URL: https://issues.apache.org/jira/browse/FLINK-18105 Project: Flink Issue Type: Test

[jira] [Created] (FLINK-18104) Test pyflink on windows

sunjincheng created FLINK-18104: --- Summary: Test pyflink on windows Key: FLINK-18104 URL: https://issues.apache.org/jira/browse/FLINK-18104 Project: Flink Issue Type: Test Components:

[jira] [Created] (FLINK-18103) Test Pandas DataFrame and Flink Table conversion

sunjincheng created FLINK-18103: --- Summary: Test Pandas DataFrame and Flink Table conversion Key: FLINK-18103 URL: https://issues.apache.org/jira/browse/FLINK-18103 Project: Flink Issue Type:

[jira] [Created] (FLINK-18102) Test Pandas UDF support

sunjincheng created FLINK-18102: --- Summary: Test Pandas UDF support Key: FLINK-18102 URL: https://issues.apache.org/jira/browse/FLINK-18102 Project: Flink Issue Type: Test Components:

[jira] [Created] (FLINK-18101) Test Python Pipeline API including Transformer and Estimator

sunjincheng created FLINK-18101: --- Summary: Test Python Pipeline API including Transformer and Estimator Key: FLINK-18101 URL: https://issues.apache.org/jira/browse/FLINK-18101 Project: Flink

[jira] [Updated] (FLINK-18099) Release guard for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18099: Labels: release-testing (was: ) > Release guard for PyFlink > - > >

[jira] [Updated] (FLINK-18099) Release guard for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18099: Fix Version/s: 1.11.0 > Release guard for PyFlink > - > >

[jira] [Updated] (FLINK-18099) Release guard for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18099: Priority: Blocker (was: Major) > Release guard for PyFlink > - > >

[jira] [Updated] (FLINK-18100) Test different user-defined metrics for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-18100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18100: Labels: release-testing (was: ) > Test different user-defined metrics for Python UDF >

[jira] [Updated] (FLINK-18100) Test different user-defined metrics for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-18100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18100: Priority: Blocker (was: Major) > Test different user-defined metrics for Python UDF >

[jira] [Updated] (FLINK-18100) Test different user-defined metrics for Python UDF

[ https://issues.apache.org/jira/browse/FLINK-18100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18100: Fix Version/s: 1.11.0 > Test different user-defined metrics for Python UDF >

[jira] [Created] (FLINK-18100) Test different user-defined metrics for Python UDF

sunjincheng created FLINK-18100: --- Summary: Test different user-defined metrics for Python UDF Key: FLINK-18100 URL: https://issues.apache.org/jira/browse/FLINK-18100 Project: Flink Issue Type:

[jira] [Updated] (FLINK-18099) Release guard for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-18099?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18099: Description: We will add all of the check items(sub jiars) for ensure successful release of

[jira] [Created] (FLINK-18099) Release guard for PyFlink

sunjincheng created FLINK-18099: --- Summary: Release guard for PyFlink Key: FLINK-18099 URL: https://issues.apache.org/jira/browse/FLINK-18099 Project: Flink Issue Type: Sub-task

[jira] [Comment Edited] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120927#comment-17120927 ] sunjincheng edited comment on FLINK-16497 at 6/1/20, 11:00 AM: --- Hi

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120927#comment-17120927 ] sunjincheng commented on FLINK-16497: - Hi [~libenchao] , Thanks for your reply! I think is is

[jira] [Commented] (FLINK-16497) Improve default flush strategy for JDBC sink to make it work out-of-box

[ https://issues.apache.org/jira/browse/FLINK-16497?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120532#comment-17120532 ] sunjincheng commented on FLINK-16497: - +1 for thi,s as I mentioned in FLINK-18041, and I prefer 1

[jira] [Updated] (FLINK-18041) Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE and DEFAULT_FLUSH_INTERVAL_MILLS of AbstractJdbcOutputFormat

[ https://issues.apache.org/jira/browse/FLINK-18041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-18041: Affects Version/s: 1.11.0 > Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE and >

[jira] [Created] (FLINK-18041) Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE and DEFAULT_FLUSH_INTERVAL_MILLS of AbstractJdbcOutputFormat

sunjincheng created FLINK-18041: --- Summary: Make a little bit improvement for DEFAULT_FLUSH_MAX_SIZE and DEFAULT_FLUSH_INTERVAL_MILLS of AbstractJdbcOutputFormat Key: FLINK-18041 URL:

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119453#comment-17119453 ] sunjincheng commented on FLINK-17923: - +1 from my points of view.  > It will throw

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17119209#comment-17119209 ] sunjincheng commented on FLINK-17923: - We can have another way to manage the resource for docker and

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17118341#comment-17118341 ] sunjincheng commented on FLINK-17923: - Thanks for the PR Dian Fu.  Overall, It's looks good. If

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17117629#comment-17117629 ] sunjincheng commented on FLINK-17923: - Our consensus is that The final solution is both Python and

[jira] [Comment Edited] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116772#comment-17116772 ] sunjincheng edited comment on FLINK-17923 at 5/26/20, 2:20 PM: --- At

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116772#comment-17116772 ] sunjincheng commented on FLINK-17923: - At present, users can't start jobs as long as they use

[jira] [Commented] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116614#comment-17116614 ] sunjincheng commented on FLINK-17923: - It's a pity that we do not find this issue earlier(We also

[jira] [Comment Edited] (FLINK-17923) It will throw MemoryAllocationException if rocksdb statebackend and Python UDF are used in the same slot

[ https://issues.apache.org/jira/browse/FLINK-17923?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116614#comment-17116614 ] sunjincheng edited comment on FLINK-17923 at 5/26/20, 10:40 AM: It's a

[jira] [Updated] (FLINK-17856) Adds the feature of monitoring directory changes for FileSystem table source connector

[ https://issues.apache.org/jira/browse/FLINK-17856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17856: Description: Great thanks to Violeta for report this issue.

[jira] [Created] (FLINK-17856) Adds the feature of monitoring directory changes for FileSystem table source connector

sunjincheng created FLINK-17856: --- Summary: Adds the feature of monitoring directory changes for FileSystem table source connector Key: FLINK-17856 URL: https://issues.apache.org/jira/browse/FLINK-17856

[jira] [Updated] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17454: Release Note: (was: [FLINK-17454][python] Specify a port number for gateway callback server

[jira] [Closed] (FLINK-17454) test_configuration.py ConfigurationTests::test_add_all failed on travis

[ https://issues.apache.org/jira/browse/FLINK-17454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-17454. --- Release Note: [FLINK-17454][python] Specify a port number for gateway callback server from python

[jira] [Updated] (FLINK-17146) Support conversion between PyFlink Table and Pandas DataFrame

[ https://issues.apache.org/jira/browse/FLINK-17146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17146: Priority: Blocker (was: Major) > Support conversion between PyFlink Table and Pandas DataFrame >

[jira] [Assigned] (FLINK-17255) Add HBase connector descriptor support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-17255: --- Assignee: shuiqiangchen > Add HBase connector descriptor support in PyFlink >

[jira] [Updated] (FLINK-17256) Suppport keyword arguments in the PyFlink Descriptor API

[ https://issues.apache.org/jira/browse/FLINK-17256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17256: Labels: beginners (was: ) > Suppport keyword arguments in the PyFlink Descriptor API >

[jira] [Updated] (FLINK-17255) Add HBase connector descriptor support in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17255: Labels: beginners (was: ) > Add HBase connector descriptor support in PyFlink >

[jira] [Updated] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

[ https://issues.apache.org/jira/browse/FLINK-17254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17254: Labels: beginners (was: ) > Improve the PyFlink documentation and examples to use SQL DDL for

[jira] [Commented] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17091144#comment-17091144 ] sunjincheng commented on FLINK-17308: - Reset the fix version as 1.9.3 was released. >

[jira] [Updated] (FLINK-17308) ExecutionGraphCache cachedExecutionGraphs not cleanup cause OOM Bug

[ https://issues.apache.org/jira/browse/FLINK-17308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-17308: Fix Version/s: (was: 1.9.3) 1.9.4 > ExecutionGraphCache

[jira] [Commented] (FLINK-12717) Add windows support for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087401#comment-17087401 ] sunjincheng commented on FLINK-12717: - Hi [~zhongwei] I have update the description of this issue

[jira] [Updated] (FLINK-12717) Add windows support for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12717: Summary: Add windows support for PyFlink (was: Add windows support for the Python shell script)

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

[ https://issues.apache.org/jira/browse/FLINK-12717?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-12717: Description: The aim of this JIRA is to allow Python users to develop PyFlink programs in

[jira] [Created] (FLINK-17256) Suppport keyword arguments in the PyFlink Descriptor API

sunjincheng created FLINK-17256: --- Summary: Suppport keyword arguments in the PyFlink Descriptor API Key: FLINK-17256 URL: https://issues.apache.org/jira/browse/FLINK-17256 Project: Flink Issue

[jira] [Created] (FLINK-17255) Add HBase connector descriptor support in PyFlink

sunjincheng created FLINK-17255: --- Summary: Add HBase connector descriptor support in PyFlink Key: FLINK-17255 URL: https://issues.apache.org/jira/browse/FLINK-17255 Project: Flink Issue Type:

[jira] [Created] (FLINK-17254) Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition

sunjincheng created FLINK-17254: --- Summary: Improve the PyFlink documentation and examples to use SQL DDL for source/sink definition Key: FLINK-17254 URL: https://issues.apache.org/jira/browse/FLINK-17254

[jira] [Commented] (FLINK-14071) [for Documents Improvement] Add explicit path where jars files should be put for pyflink development

[ https://issues.apache.org/jira/browse/FLINK-14071?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17087346#comment-17087346 ] sunjincheng commented on FLINK-14071: - Thanks for mention that issue [~coldmoon777] . This

[jira] [Closed] (FLINK-13471) Add FlatAggregate support to stream Table API(blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-13471. --- Resolution: Fixed > Add FlatAggregate support to stream Table API(blink planner) >

[jira] [Assigned] (FLINK-13471) Add FlatAggregate support to stream Table API(blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-13471: --- Assignee: sunjincheng > Add FlatAggregate support to stream Table API(blink planner) >

[jira] [Assigned] (FLINK-13471) Add FlatAggregate support to stream Table API(blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reassigned FLINK-13471: --- Assignee: (was: sunjincheng) > Add FlatAggregate support to stream Table API(blink

[jira] [Reopened] (FLINK-13471) Add FlatAggregate support to stream Table API(blink planner)

[ https://issues.apache.org/jira/browse/FLINK-13471?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng reopened FLINK-13471: - > Add FlatAggregate support to stream Table API(blink planner) >

[jira] [Commented] (FLINK-16666) Support new Python dependency configuration options in flink-java, flink-streaming-java and flink-table

[ https://issues.apache.org/jira/browse/FLINK-1?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17074446#comment-17074446 ] sunjincheng commented on FLINK-1: - I agree with [~aljoscha] that we should be careful when

[jira] [Comment Edited] (FLINK-16943) Support adding jars in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073559#comment-17073559 ] sunjincheng edited comment on FLINK-16943 at 4/2/20, 9:48 AM: -- I think the

[jira] [Commented] (FLINK-16943) Support adding jars in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073559#comment-17073559 ] sunjincheng commented on FLINK-16943: - I think the best situation is that Java also supports job

[jira] [Comment Edited] (FLINK-16943) Support adding jars in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073553#comment-17073553 ] sunjincheng edited comment on FLINK-16943 at 4/2/20, 9:38 AM: -- Thanks for

[jira] [Commented] (FLINK-16943) Support adding jars in PyFlink

[ https://issues.apache.org/jira/browse/FLINK-16943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17073553#comment-17073553 ] sunjincheng commented on FLINK-16943: - Thanks for report this issue, I think this is very important

[jira] [Created] (FLINK-16762) Relocation Beam dependency of PyFlink

sunjincheng created FLINK-16762: --- Summary: Relocation Beam dependency of PyFlink Key: FLINK-16762 URL: https://issues.apache.org/jira/browse/FLINK-16762 Project: Flink Issue Type: Improvement

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

[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036088#comment-17036088 ] sunjincheng edited comment on FLINK-16026 at 2/13/20 9:54 AM: -- Thanks for

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

[ https://issues.apache.org/jira/browse/FLINK-16026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036088#comment-17036088 ] sunjincheng commented on FLINK-16026: - Thanks for the reminder [~chesnay]. We have discussed about

[jira] [Commented] (FLINK-15253) Accumulators are not checkpointed

[ https://issues.apache.org/jira/browse/FLINK-15253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17033426#comment-17033426 ] sunjincheng commented on FLINK-15253: - Yes, [~mxm] , from the points of my view, anyway, I think

[jira] [Commented] (FLINK-15937) Correct the Development Status for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17032093#comment-17032093 ] sunjincheng commented on FLINK-15937: - Sounds good! Thanks [~gjy]! > Correct the Development Status

[jira] [Comment Edited] (FLINK-15937) Correct the Development Status for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15937?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17031481#comment-17031481 ] sunjincheng edited comment on FLINK-15937 at 2/6/20 11:20 AM: -- Hi [~gary] ,

[jira] [Updated] (FLINK-15937) Correct the Development Status for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-15937: Attachment: (was: image-2020-02-06-19-14-00-631.png) > Correct the Development Status for

[jira] [Updated] (FLINK-15937) Correct the Development Status for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-15937: Description: Correct the  `Development Status` value.  >From `'Development Status :: 1 -

[jira] [Updated] (FLINK-15937) Correct the Development Status for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-15937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng updated FLINK-15937: Attachment: image-2020-02-06-19-17-28-672.png > Correct the Development Status for PyFlink >

  1   2   3   4   5   6   7   8   9   10   >