[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 StreamExecut

[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&focusedCommentId=17173738#comment-17173738 ] Hequn Cheng commented on FLINK-18764: - Resolved in 1.12.0 via c966182ee051e4f21d8490

[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&focusedCommentId=17173737#comment-17173737 ] Hequn Cheng commented on FLINK-18763: - Resolved in 1.12.0 via ea9f44985ab387f1a234f2

[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&focusedCommentId=17173735#comment-17173735 ] Hequn Cheng commented on FLINK-18765: - Resolved in 1.12.0 via 862c9eb0f48f57f8f420d0

[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: Tes

[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&focusedCommentId=17167999#comment-17167999 ] Hequn Cheng commented on FLINK-18763: - Sure, a well-defined set of types makes sense

[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&focusedCommentId=17167874#comment-17167874 ] Hequn Cheng commented on FLINK-18763: - [~twalthr] Hi, thanks for your comments. We o

[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: Sub-ta

[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 Ty

[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: S

[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 T

[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 g

[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 git-commit-i

[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&focusedCommentId=17164521#comment-17164521 ] Hequn Cheng commented on FLINK-18655: - Resolved in 1.12.0 via 09f1674cb3e6cb536a67f

[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 folder(fo

[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&focusedCommentId=17161717#comment-17161717 ] Hequn Cheng commented on FLINK-18655: - CC [~chesnay] > Set failOnUnableToExtractRep

[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&focusedCommentId=17147732#comment-17147732 ] Hequn Cheng commented on FLINK-17920: - Resolve in 1.11.0 via 87eb508835871b4dc2ddf4

[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 of

[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" docum

[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&focusedCommentId=17135412#comment-17135412 ] Hequn Cheng commented on FLINK-17960: - Resolved in 1.12.0 via 35f95f5ac02c6014cdc8e

[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 pyflink_gateway_server

[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&focusedCommentId=17127843#comment-17127843 ] Hequn Cheng commented on FLINK-18151: - Resolved in 1.12.0 via c27a7a6f73ac7a082b0c94

[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 t

[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 Type

[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&focusedCommentId=17126409#comment-17126409 ] Hequn Cheng commented on FLINK-18143: - Fixed in 1.12.0 via dcd764a8a0df788846886f2c

[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&focusedCommentId=17126406#comment-17126406 ] Hequn Cheng commented on FLINK-18100: - Check different kinds of metrics. Found one b

[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&focusedCommentId=17126405#comment-17126405 ] Hequn Cheng commented on FLINK-18101: - Done. Test Python Transformer and Estimator.

[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 `meter.markEvent(upda

[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] [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&focusedCommentId=17120711#comment-17120711 ] Hequn Cheng commented on FLINK-18031: - Fixed in shaded-12.0 via 1be30c795cdda467cf07

[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] [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 flink-shad

[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 re

[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 rep

[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&focusedCommentId=17119287#comment-17119287 ] Hequn Cheng commented on FLINK-17303: - Resolved in 1.11.0 via 386cea7beccf10fd5893ab

[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: F

[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&focusedCommentId=17116464#comment-17116464 ] Hequn Cheng commented on FLINK-17303: - [~dian.fu] I do not have strong opinions on t

[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&focusedCommentId=17115938#comment-17115938 ] Hequn Cheng commented on FLINK-17920: - [~csq] Hi, I have assigned this to you. > A

[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&focusedCommentId=17114639#comment-17114639 ] Hequn Cheng commented on FLINK-17303: - Resolved in 1.12.0 via 6186069e22dd6075794296

[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&focusedCommentId=17113968#comment-17113968 ] Hequn Cheng edited comment on FLINK-17879 at 5/22/20, 12:07 PM: --

[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&focusedCommentId=17113968#comment-17113968 ] Hequn Cheng commented on FLINK-17879: - Hi, thank you for your discussion. On the Pyt

[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 test

[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 TableEn

[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&focusedCommentId=17109381#comment-17109381 ] Hequn Cheng commented on FLINK-9528: [~jark] (y) > Incorrect results: Filter does no

[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&focusedCommentId=17108039#comment-17108039 ] Hequn Cheng commented on FLINK-17720: - Closed. Thanks. > StreamSqlTests.test_execu

[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&focusedCommentId=17108035#comment-17108035 ] Hequn Cheng commented on FLINK-17720: - [~rmetzger] Hi, thanks a lot for reporting t

[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&focusedCommentId=17108011#comment-17108011 ] Hequn Cheng commented on FLINK-17710: - [~jark] Thanks a lot for providing the info.

[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&focusedCommentId=17107958#comment-17107958 ] Hequn Cheng commented on FLINK-17710: - Changs were reverted for now on master since

[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&focusedCommentId=17107957#comment-17107957 ] Hequn Cheng commented on FLINK-17303: - Changes were reverted in master due to FLINK-

[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&focusedCommentId=17107872#comment-17107872 ] Hequn Cheng commented on FLINK-17710: - Fixed in 1.11.0 via be9779df4a817697788ed44fc

[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&focusedCommentId=17107846#comment-17107846 ] Hequn Cheng edited comment on FLINK-17710 at 5/15/20, 2:05 AM: ---

[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&focusedCommentId=17107846#comment-17107846 ] Hequn Cheng commented on FLINK-17710: - CC [~nicholasjiang]. I think we should not as

[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&focusedCommentId=17107326#comment-17107326 ] Hequn Cheng commented on FLINK-17303: - Resolved in 1.11.0 via 381131a785700a7d07b822

[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&focusedCommentId=17105875#comment-17105875 ] Hequn Cheng commented on FLINK-17394: - Thanks a lot for your feedback. [~aljoscha]

[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&focusedCommentId=17104177#comment-17104177 ] Hequn Cheng commented on FLINK-17394: - Hi, [~aljoscha] [~kkl0u] it's a good idea to

[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   >