[jira] [Assigned] (FLINK-18864) Support key_by() operation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18864?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18864: --- Assignee: Shuiqiang Chen > Support key_by() operation for Python DataStream API >

[jira] [Assigned] (FLINK-18866) Support filter() operation for Python DataStream API.

[ https://issues.apache.org/jira/browse/FLINK-18866?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18866: --- Assignee: Shuiqiang Chen > Support filter() operation for Python DataStream API. >

[jira] [Assigned] (FLINK-18861) Support add_source() to get a DataStream for Python StreamExecutionEnvironment

[ https://issues.apache.org/jira/browse/FLINK-18861?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18861: --- Assignee: Shuiqiang Chen > Support add_source() to get a DataStream for Python

[jira] [Assigned] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18766: --- Assignee: Shuiqiang Chen > Support add_sink() for Python DataStream API >

[jira] [Updated] (FLINK-18766) Support add_sink() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18766: Component/s: API / Python > Support add_sink() for Python DataStream API >

[jira] [Updated] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18765: Component/s: API / Python > Support map() and flat_map() for Python DataStream API >

[jira] [Updated] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18763: Component/s: API / Python > Support basic TypeInformation for Python DataStream API >

[jira] [Updated] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18765: Fix Version/s: 1.12.0 > Support map() and flat_map() for Python DataStream API >

[jira] [Updated] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18763: Fix Version/s: 1.12.0 > Support basic TypeInformation for Python DataStream API >

[jira] [Closed] (FLINK-18764) Support from_collection for Python DataStream API

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

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18764: Component/s: API / Python > Support from_collection for Python DataStream API >

[jira] [Commented] (FLINK-18764) Support from_collection for Python DataStream API

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

[jira] [Updated] (FLINK-18764) Support from_collection for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18764: Fix Version/s: 1.12.0 > Support from_collection for Python DataStream API >

[jira] [Closed] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18763. --- Resolution: Resolved > Support basic TypeInformation for Python DataStream API >

[jira] [Commented] (FLINK-18763) Support basic TypeInformation for Python DataStream API

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

[jira] [Closed] (FLINK-18765) Support map() and flat_map() for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18765?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18765. --- Resolution: Resolved > Support map() and flat_map() for Python DataStream API >

[jira] [Commented] (FLINK-18765) Support map() and flat_map() for Python DataStream API

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

[jira] [Created] (FLINK-18817) 'Kerberized YARN per-job on Docker test' failed

Hequn Cheng created FLINK-18817: --- Summary: 'Kerberized YARN per-job on Docker test' failed Key: FLINK-18817 URL: https://issues.apache.org/jira/browse/FLINK-18817 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18763: --- Assignee: Shuiqiang Chen > Support basic TypeInformation for Python DataStream API >

[jira] [Commented] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167999#comment-17167999 ] Hequn Cheng commented on FLINK-18763: - Sure, a well-defined set of types makes sense to me. We can

[jira] [Commented] (FLINK-18763) Support basic TypeInformation for Python DataStream API

[ https://issues.apache.org/jira/browse/FLINK-18763?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17167874#comment-17167874 ] Hequn Cheng commented on FLINK-18763: - [~twalthr] Hi, thanks for your comments. We only plan to

[jira] [Created] (FLINK-18766) Support add_sink() for Python DataStream API

Hequn Cheng created FLINK-18766: --- Summary: Support add_sink() for Python DataStream API Key: FLINK-18766 URL: https://issues.apache.org/jira/browse/FLINK-18766 Project: Flink Issue Type:

[jira] [Created] (FLINK-18765) Support map() and flat_map() for Python DataStream API

Hequn Cheng created FLINK-18765: --- Summary: Support map() and flat_map() for Python DataStream API Key: FLINK-18765 URL: https://issues.apache.org/jira/browse/FLINK-18765 Project: Flink Issue

[jira] [Created] (FLINK-18764) Support from_collection for Python DataStream API

Hequn Cheng created FLINK-18764: --- Summary: Support from_collection for Python DataStream API Key: FLINK-18764 URL: https://issues.apache.org/jira/browse/FLINK-18764 Project: Flink Issue Type:

[jira] [Created] (FLINK-18763) Support basic TypeInformation for Python DataStream API

Hequn Cheng created FLINK-18763: --- Summary: Support basic TypeInformation for Python DataStream API Key: FLINK-18763 URL: https://issues.apache.org/jira/browse/FLINK-18763 Project: Flink Issue

[jira] [Created] (FLINK-18761) Support Python DataStream API (Stateless part)

Hequn Cheng created FLINK-18761: --- Summary: Support Python DataStream API (Stateless part) Key: FLINK-18761 URL: https://issues.apache.org/jira/browse/FLINK-18761 Project: Flink Issue Type: New

[jira] [Updated] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18655: Fix Version/s: 1.11.2 1.12.0 > Set failOnUnableToExtractRepoInfo to false for

[jira] [Updated] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18655: Affects Version/s: (was: 1.11.0) 1.12.0 1.11.1

[jira] [Closed] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18655. --- Resolution: Fixed > Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module

[jira] [Updated] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18655: Affects Version/s: (was: 1.12.0) > Set failOnUnableToExtractRepoInfo to false for

[jira] [Commented] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

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

[jira] [Updated] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18655: Description: Exception may be thrown when building source distribution without the .git

[jira] [Commented] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

[ https://issues.apache.org/jira/browse/FLINK-18655?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17161717#comment-17161717 ] Hequn Cheng commented on FLINK-18655: - CC [~chesnay] > Set failOnUnableToExtractRepoInfo to false

[jira] [Created] (FLINK-18655) Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime

Hequn Cheng created FLINK-18655: --- Summary: Set failOnUnableToExtractRepoInfo to false for git-commit-id-plugin in module flink-runtime Key: FLINK-18655 URL: https://issues.apache.org/jira/browse/FLINK-18655

[jira] [Closed] (FLINK-17920) Add the Python example of Interval Join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17920. --- Resolution: Resolved > Add the Python example of Interval Join in Table API doc >

[jira] [Commented] (FLINK-17920) Add the Python example of Interval Join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17147732#comment-17147732 ] Hequn Cheng commented on FLINK-17920: - Resolve in 1.11.0 via

[jira] [Updated] (FLINK-17920) Add the Python example of Interval Join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17920: Summary: Add the Python example of Interval Join in Table API doc (was: Add the Python example

[jira] [Updated] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17960: Fix Version/s: 1.12.0 1.11.0 > Improve commands in the "Common Questions"

[jira] [Commented] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

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

[jira] [Closed] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17960. --- Resolution: Resolved > Improve commands in the "Common Questions" document for PyFlink >

[jira] [Closed] (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 ] Hequn Cheng closed FLINK-18100. --- Resolution: Fixed > Test different user-defined metrics for Python UDF >

[jira] [Updated] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

[ https://issues.apache.org/jira/browse/FLINK-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18151: Fix Version/s: 1.12.0 1.11.0 > Resolve CWE22 problems in

[jira] [Updated] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

[ https://issues.apache.org/jira/browse/FLINK-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18151: Affects Version/s: (was: 1.10.1) > Resolve CWE22 problems in pyflink_gateway_server.py >

[jira] [Closed] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

[ https://issues.apache.org/jira/browse/FLINK-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18151. --- Resolution: Fixed > Resolve CWE22 problems in pyflink_gateway_server.py >

[jira] [Commented] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

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

[jira] [Updated] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

[ https://issues.apache.org/jira/browse/FLINK-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18151: Description: For example, the code `if os.path.isfile(flink_conf_path):` contains CWE22 problem

[jira] [Assigned] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

[ https://issues.apache.org/jira/browse/FLINK-18151?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18151: --- Assignee: Shuiqiang Chen > Resolve CWE22 problems in pyflink_gateway_server.py >

[jira] [Created] (FLINK-18151) Resolve CWE22 problems in pyflink_gateway_server.py

Hequn Cheng created FLINK-18151: --- Summary: Resolve CWE22 problems in pyflink_gateway_server.py Key: FLINK-18151 URL: https://issues.apache.org/jira/browse/FLINK-18151 Project: Flink Issue

[jira] [Commented] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126409#comment-17126409 ] Hequn Cheng commented on FLINK-18143: - Fixed in 1.12.0 via dcd764a8a0df788846886f2c3aa2b38828ae0e21

[jira] [Closed] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18143. --- Resolution: Fixed > Fix Python meter metric not correct problem >

[jira] [Commented] (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:comment-tabpanel=17126406#comment-17126406 ] Hequn Cheng commented on FLINK-18100: - Check different kinds of metrics. Found one bug for meter.

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

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17126405#comment-17126405 ] Hequn Cheng commented on FLINK-18101: - Done. Test Python Transformer and Estimator. Test Wrapper

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

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18101. --- Resolution: Resolved > Test Python Pipeline API including Transformer and Estimator >

[jira] [Updated] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18143: Description: We should report the diff value instead of the total ones. Code

[jira] [Assigned] (FLINK-18143) Fix Python meter metric not correct problem

[ https://issues.apache.org/jira/browse/FLINK-18143?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18143: --- Assignee: Hequn Cheng > Fix Python meter metric not correct problem >

[jira] [Created] (FLINK-18143) Fix Python meter metric not correct problem

Hequn Cheng created FLINK-18143: --- Summary: Fix Python meter metric not correct problem Key: FLINK-18143 URL: https://issues.apache.org/jira/browse/FLINK-18143 Project: Flink Issue Type: Bug

[jira] [Assigned] (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 ] Hequn Cheng reassigned FLINK-18100: --- Assignee: Hequn Cheng > Test different user-defined metrics for Python UDF >

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

[ https://issues.apache.org/jira/browse/FLINK-18101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18101: --- Assignee: Hequn Cheng > Test Python Pipeline API including Transformer and Estimator >

[jira] [Closed] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-18031. --- Resolution: Fixed > Update the copyright year in the NOTICE file in flink-shaded repo >

[jira] [Commented] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17120711#comment-17120711 ] Hequn Cheng commented on FLINK-18031: - Fixed in shaded-12.0 via 

[jira] [Assigned] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-18031: --- Assignee: Hequn Cheng > Update the copyright year in the NOTICE file in flink-shaded repo

[jira] [Updated] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18031: Fix Version/s: (was: shaded-11.0) > Update the copyright year in the NOTICE file in

[jira] [Updated] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18031: Priority: Critical (was: Major) > Update the copyright year in the NOTICE file in flink-shaded

[jira] [Updated] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

[ https://issues.apache.org/jira/browse/FLINK-18031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-18031: Priority: Major (was: Blocker) > Update the copyright year in the NOTICE file in flink-shaded

[jira] [Created] (FLINK-18031) Update the copyright year in the NOTICE file in flink-shaded repo

Hequn Cheng created FLINK-18031: --- Summary: Update the copyright year in the NOTICE file in flink-shaded repo Key: FLINK-18031 URL: https://issues.apache.org/jira/browse/FLINK-18031 Project: Flink

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

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

[jira] [Created] (FLINK-17962) Add document for how to define Python UDF with DDL

Hequn Cheng created FLINK-17962: --- Summary: Add document for how to define Python UDF with DDL Key: FLINK-17962 URL: https://issues.apache.org/jira/browse/FLINK-17962 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

[ https://issues.apache.org/jira/browse/FLINK-17960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17960: --- Assignee: Nicholas Jiang > Improve commands in the "Common Questions" document for PyFlink

[jira] [Created] (FLINK-17960) Improve commands in the "Common Questions" document for PyFlink

Hequn Cheng created FLINK-17960: --- Summary: Improve commands in the "Common Questions" document for PyFlink Key: FLINK-17960 URL: https://issues.apache.org/jira/browse/FLINK-17960 Project: Flink

[jira] [Created] (FLINK-17959) Exception: "CANCELLED: call already cancelled" is thrown when run python udf

Hequn Cheng created FLINK-17959: --- Summary: Exception: "CANCELLED: call already cancelled" is thrown when run python udf Key: FLINK-17959 URL: https://issues.apache.org/jira/browse/FLINK-17959 Project:

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17116464#comment-17116464 ] Hequn Cheng commented on FLINK-17303: - [~dian.fu] I do not have strong opinions on this. The feature

[jira] [Assigned] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17920: --- Assignee: Shuiqiang Chen > Add the Python example of Time-windowed join in Table API doc >

[jira] [Commented] (FLINK-17920) Add the Python example of Time-windowed join in Table API doc

[ https://issues.apache.org/jira/browse/FLINK-17920?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17115938#comment-17115938 ] Hequn Cheng commented on FLINK-17920: - [~csq] Hi, I have assigned this to you. > Add the Python

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17303. --- Resolution: Resolved > Return TableResult for Python TableEnvironment >

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

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

[jira] [Comment Edited] (FLINK-17879) Update Python row serializer

[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113968#comment-17113968 ] Hequn Cheng edited comment on FLINK-17879 at 5/22/20, 12:07 PM: Hi,

[jira] [Commented] (FLINK-17879) Update Python row serializer

[ https://issues.apache.org/jira/browse/FLINK-17879?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17113968#comment-17113968 ] Hequn Cheng commented on FLINK-17879: - Hi, thank you for your discussion. On the Python side, we

[jira] [Closed] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17710. --- Fix Version/s: (was: 1.11.0) Resolution: Abandoned > StreamSqlTests.test_execute_sql

[jira] [Reopened] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-17710: - > StreamSqlTests.test_execute_sql test is not stable >

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17303: Fix Version/s: (was: 1.11.0) 1.12.0 > Return TableResult for Python

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-17303: - > Return TableResult for Python TableEnvironment > -- >

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

[ https://issues.apache.org/jira/browse/FLINK-9528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17109381#comment-17109381 ] Hequn Cheng commented on FLINK-9528: [~jark] (y) > Incorrect results: Filter does not treat Upsert

[jira] [Commented] (FLINK-17720) StreamSqlTests.test_execute_sql: "AssertionError: True is not false"

[ https://issues.apache.org/jira/browse/FLINK-17720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108039#comment-17108039 ] Hequn Cheng commented on FLINK-17720: - Closed. Thanks. > StreamSqlTests.test_execute_sql:

[jira] [Closed] (FLINK-17720) StreamSqlTests.test_execute_sql: "AssertionError: True is not false"

[ https://issues.apache.org/jira/browse/FLINK-17720?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17720. --- Resolution: Duplicate > StreamSqlTests.test_execute_sql: "AssertionError: True is not false" >

[jira] [Commented] (FLINK-17720) StreamSqlTests.test_execute_sql: "AssertionError: True is not false"

[ https://issues.apache.org/jira/browse/FLINK-17720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108035#comment-17108035 ] Hequn Cheng commented on FLINK-17720: - [~rmetzger] Hi, thanks a lot for reporting the issue. This

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17108011#comment-17108011 ] Hequn Cheng commented on FLINK-17710: - [~jark] Thanks a lot for providing the info. The latest code

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107958#comment-17107958 ] Hequn Cheng commented on FLINK-17710: - Changs were reverted for now on master since the test begins

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107957#comment-17107957 ] Hequn Cheng commented on FLINK-17303: - Changes were reverted in master due to FLINK-17710 via

[jira] [Closed] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17710. --- Resolution: Fixed > StreamSqlTests.test_execute_sql test is not stable >

[jira] [Updated] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-17710: Fix Version/s: 1.11.0 > StreamSqlTests.test_execute_sql test is not stable >

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107872#comment-17107872 ] Hequn Cheng commented on FLINK-17710: - Fixed in 1.11.0 via be9779df4a817697788ed44fc618900595b248d8

[jira] [Comment Edited] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107846#comment-17107846 ] Hequn Cheng edited comment on FLINK-17710 at 5/15/20, 2:05 AM: --- CC

[jira] [Commented] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

[ https://issues.apache.org/jira/browse/FLINK-17710?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17107846#comment-17107846 ] Hequn Cheng commented on FLINK-17710: - CC [~nicholasjiang]. I think we should not assertFalse for

[jira] [Created] (FLINK-17710) StreamSqlTests.test_execute_sql test is not stable

Hequn Cheng created FLINK-17710: --- Summary: StreamSqlTests.test_execute_sql test is not stable Key: FLINK-17710 URL: https://issues.apache.org/jira/browse/FLINK-17710 Project: Flink Issue Type:

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

[ https://issues.apache.org/jira/browse/FLINK-17303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-17303. --- Resolution: Resolved > Return TableResult for Python TableEnvironment >

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17105875#comment-17105875 ] Hequn Cheng commented on FLINK-17394: - Thanks a lot for your feedback. [~aljoscha] > Add

[jira] [Assigned] (FLINK-17562) Monitoring REST API page has duplicate items

[ https://issues.apache.org/jira/browse/FLINK-17562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17562: --- Assignee: Nicholas Jiang > Monitoring REST API page has duplicate items >

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

[ https://issues.apache.org/jira/browse/FLINK-17394?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17104177#comment-17104177 ] Hequn Cheng commented on FLINK-17394: - Hi, [~aljoscha] [~kkl0u] it's a good idea to decouple the

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

[ https://issues.apache.org/jira/browse/FLINK-17423?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-17423: --- Assignee: Huang Xingbo > Support Python UDTF in blink planner under batch mode >

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