[jira] [Reopened] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reopened FLINK-15001: - Also need backport to release-1.9 branch > The digest of sub-plan reuse should contain retraction

[jira] [Closed] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15001. --- Resolution: Fixed > The digest of sub-plan reuse should contain retraction traits for stream >

[jira] [Commented] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

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

[jira] [Updated] (FLINK-15001) The digest of sub-plan reuse should contain retraction traits for stream physical nodes

[ https://issues.apache.org/jira/browse/FLINK-15001?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15001: Fix Version/s: 1.11.0 > The digest of sub-plan reuse should contain retraction traits for stream

[jira] [Commented] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

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

[jira] [Closed] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14007. --- Resolution: Resolved > Add doc for how to using Java user-defined source/sink in Python API >

[jira] [Updated] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14007: Fix Version/s: 1.11.0 > Add doc for how to using Java user-defined source/sink in Python API >

[jira] [Assigned] (FLINK-14007) Add doc for how to using Java user-defined source/sink in Python API

[ https://issues.apache.org/jira/browse/FLINK-14007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14007: --- Assignee: Hequn Cheng > Add doc for how to using Java user-defined source/sink in Python

[jira] [Closed] (FLINK-14006) Add doc for how to using Java UDFs in Python API

[ https://issues.apache.org/jira/browse/FLINK-14006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14006. --- Resolution: Resolved > Add doc for how to using Java UDFs in Python API >

[jira] [Updated] (FLINK-14006) Add doc for how to using Java UDFs in Python API

[ https://issues.apache.org/jira/browse/FLINK-14006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14006: Fix Version/s: 1.10.0 > Add doc for how to using Java UDFs in Python API >

[jira] [Commented] (FLINK-14006) Add doc for how to using Java UDFs in Python API

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

[jira] [Assigned] (FLINK-14006) Add doc for how to using Java UDFs in Python API

[ https://issues.apache.org/jira/browse/FLINK-14006?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14006: --- Assignee: Hequn Cheng > Add doc for how to using Java UDFs in Python API >

[jira] [Closed] (FLINK-15096) Do not use GlobalJobParameters to pass system configuration

[ https://issues.apache.org/jira/browse/FLINK-15096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15096. --- Resolution: Fixed > Do not use GlobalJobParameters to pass system configuration >

[jira] [Commented] (FLINK-15096) Do not use GlobalJobParameters to pass system configuration

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

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

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16990350#comment-16990350 ] Hequn Cheng commented on FLINK-14019: - Add command line support, resolved in 1.10.0 via

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14026?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14026. --- Resolution: Resolved > Manage the resource of Python worker properly >

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

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

[jira] [Closed] (FLINK-14584) Support complex data types in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14584?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14584. --- Resolution: Resolved > Support complex data types in Python user-defined functions >

[jira] [Commented] (FLINK-14584) Support complex data types in Python user-defined functions

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

[jira] [Assigned] (FLINK-14584) Support complex data types in Python user-defined functions

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

[jira] [Closed] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14590. --- Resolution: Resolved > Unify the working directory of Java process and Python process when >

[jira] [Updated] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14590: Fix Version/s: 1.10.0 > Unify the working directory of Java process and Python process when >

[jira] [Commented] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

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

[jira] [Closed] (FLINK-14573) Support time data types in Python user-defined functions

[ https://issues.apache.org/jira/browse/FLINK-14573?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14573. --- Resolution: Resolved > Support time data types in Python user-defined functions >

[jira] [Commented] (FLINK-14573) Support time data types in Python user-defined functions

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

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

[ https://issues.apache.org/jira/browse/FLINK-14019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16988373#comment-16988373 ] Hequn Cheng edited comment on FLINK-14019 at 12/5/19 1:34 AM: -- Resolved in

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

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

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

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

[jira] [Updated] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15036: Priority: Blocker (was: Critical) > Container startup error will be handled out side of the

[jira] [Commented] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987719#comment-16987719 ] Hequn Cheng commented on FLINK-15036: - [~trohrmann] [~fly_in_gis] OK, let's make the fix in 1.8.3.

[jira] [Commented] (FLINK-15036) Container startup error will be handled out side of the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-15036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16987408#comment-16987408 ] Hequn Cheng commented on FLINK-15036: - Hi [~trohrmann][~fly_in_gis] The 1.8.3-rc2 is under voting.

[jira] [Closed] (FLINK-14891) PythonScalarFunctionOperator should be chained with upstream operators by default

[ https://issues.apache.org/jira/browse/FLINK-14891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14891. --- Resolution: Fixed > PythonScalarFunctionOperator should be chained with upstream operators by >

[jira] [Assigned] (FLINK-14891) PythonScalarFunctionOperator should be chained with upstream operators by default

[ https://issues.apache.org/jira/browse/FLINK-14891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14891: --- Assignee: Dian Fu > PythonScalarFunctionOperator should be chained with upstream operators

[jira] [Commented] (FLINK-14891) PythonScalarFunctionOperator should be chained with upstream operators by default

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

[jira] [Assigned] (FLINK-14888) Move the Python SqlDialect to module table

[ https://issues.apache.org/jira/browse/FLINK-14888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14888: --- Assignee: Huang Xingbo > Move the Python SqlDialect to module table >

[jira] [Commented] (FLINK-14888) Move the Python SqlDialect to module table

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

[jira] [Closed] (FLINK-14888) Move the Python SqlDialect to module table

[ https://issues.apache.org/jira/browse/FLINK-14888?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14888. --- Resolution: Resolved > Move the Python SqlDialect to module table >

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

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

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

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

[jira] [Updated] (FLINK-10377) Remove precondition in TwoPhaseCommitSinkFunction.notifyCheckpointComplete

[ https://issues.apache.org/jira/browse/FLINK-10377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-10377: Fix Version/s: (was: 1.8.3) 1.8.4 > Remove precondition in

[jira] [Comment Edited] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16984795#comment-16984795 ] Hequn Cheng edited comment on FLINK-14235 at 11/29/19 8:00 AM: --- Resolved

[jira] [Updated] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

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

[jira] [Updated] (FLINK-14370) KafkaProducerAtLeastOnceITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink fails on Travis

[ https://issues.apache.org/jira/browse/FLINK-14370?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14370: Fix Version/s: (was: 1.8.2) 1.8.3 >

[jira] [Updated] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14235: Fix Version/s: 1.8.3 >

[jira] [Commented] (FLINK-14235) Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceCustomOperator fails on travis

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

[jira] [Updated] (FLINK-13925) ClassLoader in BlobLibraryCacheManager is not using context class loader

[ https://issues.apache.org/jira/browse/FLINK-13925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13925: Fix Version/s: (was: 1.8.3) 1.8.4 > ClassLoader in BlobLibraryCacheManager

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

[ https://issues.apache.org/jira/browse/FLINK-14385?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14385: Fix Version/s: (was: 1.8.3) 1.8.4 > There are ClassNotFoundException when

[jira] [Updated] (FLINK-13689) Rest High Level Client for Elasticsearch6.x connector leaks threads if no connection could be established

[ https://issues.apache.org/jira/browse/FLINK-13689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13689: Fix Version/s: (was: 1.8.3) 1.8.4 > Rest High Level Client for

[jira] [Updated] (FLINK-11958) flink on windows yarn deploy failed

[ https://issues.apache.org/jira/browse/FLINK-11958?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-11958: Fix Version/s: (was: 1.8.3) 1.8.4 > flink on windows yarn deploy failed >

[jira] [Assigned] (FLINK-14512) Introduce listPartitionsByFilter to Catalog

[ https://issues.apache.org/jira/browse/FLINK-14512?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14512: --- Assignee: Jingsong Lee > Introduce listPartitionsByFilter to Catalog >

[jira] [Closed] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14865. --- Resolution: Fixed > Unstable tests >

[jira] [Commented] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

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

[jira] [Assigned] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14865: --- Assignee: Wei Zhong > Unstable tests >

[jira] [Closed] (FLINK-14506) Improve the release script for Python API release package

[ https://issues.apache.org/jira/browse/FLINK-14506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14506. --- Resolution: Resolved > Improve the release script for Python API release package >

[jira] [Commented] (FLINK-14506) Improve the release script for Python API release package

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

[jira] [Assigned] (FLINK-14506) Improve the release script for Python API release package

[ https://issues.apache.org/jira/browse/FLINK-14506?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14506: --- Assignee: Huang Xingbo > Improve the release script for Python API release package >

[jira] [Assigned] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14590: --- Assignee: Hequn Cheng > Unify the working directory of Java process and Python process

[jira] [Assigned] (FLINK-14590) Unify the working directory of Java process and Python process when submitting python jobs via "flink run -py"

[ https://issues.apache.org/jira/browse/FLINK-14590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14590: --- Assignee: Wei Zhong (was: Hequn Cheng) > Unify the working directory of Java process and

[jira] [Commented] (FLINK-13995) Fix shading of the licence information of netty

[ https://issues.apache.org/jira/browse/FLINK-13995?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16981282#comment-16981282 ] Hequn Cheng commented on FLINK-13995: - [~chesnay] Hi, as legal problems are always important, so I

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

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14066. --- Resolution: Fixed > Pyflink building failure in master and 1.9.0 version >

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

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14066: Fix Version/s: 1.9.2 > Pyflink building failure in master and 1.9.0 version >

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

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14066: Fix Version/s: 1.10.0 > Pyflink building failure in master and 1.9.0 version >

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

[ https://issues.apache.org/jira/browse/FLINK-14066?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978032#comment-16978032 ] Hequn Cheng commented on FLINK-14066: - Fixed in 1.9.2 via 8fb54e5a3a69ea3250c1cba01bc1d2504acd968d

[jira] [Commented] (FLINK-14865) Unstable tests PyFlinkBlinkStreamUserDefinedFunctionTests#test_udf_in_join_condition_2

[ https://issues.apache.org/jira/browse/FLINK-14865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16978002#comment-16978002 ] Hequn Cheng commented on FLINK-14865: - [~dian.fu] [~zhongwei] Not sure if this is a bug of JDK. see

[jira] [Closed] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14581. --- Resolution: Resolved > Support to run Python UDF jobs in a YARN cluster >

[jira] [Commented] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

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

[jira] [Assigned] (FLINK-14581) Support to run Python UDF jobs in a YARN cluster

[ https://issues.apache.org/jira/browse/FLINK-14581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14581: --- Assignee: Wei Zhong > Support to run Python UDF jobs in a YARN cluster >

[jira] [Assigned] (FLINK-14693) python tox checks fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14693: --- Assignee: Huang Xingbo > python tox checks fails on travis >

[jira] [Closed] (FLINK-14693) python tox checks fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14693. --- Resolution: Fixed > python tox checks fails on travis > - > >

[jira] [Updated] (FLINK-14693) python tox checks fails on travis

[ https://issues.apache.org/jira/browse/FLINK-14693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14693: Fix Version/s: 1.10.0 > python tox checks fails on travis > - > >

[jira] [Commented] (FLINK-14693) python tox checks fails on travis

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

[jira] [Comment Edited] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972049#comment-16972049 ] Hequn Cheng edited comment on FLINK-13184 at 11/12/19 4:09 AM: --- Hi

[jira] [Commented] (FLINK-13184) Starting a TaskExecutor blocks the YarnResourceManager's main thread

[ https://issues.apache.org/jira/browse/FLINK-13184?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16972049#comment-16972049 ] Hequn Cheng commented on FLINK-13184: - Hi [~trohrmann] Do you think it is a blocker for 1.8.3?

[jira] [Created] (FLINK-14684) Add Pinterest to Chinese Powered By page

Hequn Cheng created FLINK-14684: --- Summary: Add Pinterest to Chinese Powered By page Key: FLINK-14684 URL: https://issues.apache.org/jira/browse/FLINK-14684 Project: Flink Issue Type: New

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-14022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14022. --- Resolution: Resolved > Add validation check for places where Python ScalarFunction cannot be used >

[jira] [Closed] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

[ https://issues.apache.org/jira/browse/FLINK-14558?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14558. --- Resolution: Fixed > Fix the ClassNotFoundException issue for run python job in standalone mode >

[jira] [Commented] (FLINK-14558) Fix the ClassNotFoundException issue for run python job in standalone mode

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

[jira] [Closed] (FLINK-14557) Clean up the package of py4j

[ https://issues.apache.org/jira/browse/FLINK-14557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14557. --- Resolution: Resolved > Clean up the package of py4j > > >

[jira] [Commented] (FLINK-14557) Clean up the package of py4j

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

[jira] [Assigned] (FLINK-9559) The type of a union of CHAR columns of different lengths should be VARCHAR

[ https://issues.apache.org/jira/browse/FLINK-9559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-9559: -- Assignee: Zhenghua Gao (was: Hequn Cheng) > The type of a union of CHAR columns of different

[jira] [Assigned] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10257: --- Assignee: Zhenghua Gao (was: huang zheng) > Incorrect CHAR type support in Flink SQL and

[jira] [Assigned] (FLINK-10257) Incorrect CHAR type support in Flink SQL and Table API

[ https://issues.apache.org/jira/browse/FLINK-10257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-10257: --- Assignee: huang zheng (was: Hequn Cheng) > Incorrect CHAR type support in Flink SQL and

[jira] [Commented] (FLINK-14556) Correct the package of cloud pickle

[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963701#comment-16963701 ] Hequn Cheng commented on FLINK-14556: - Fix in 1.10.0 via 6c6ada5b36577490fde74fc8d34b784a6e0dc25a >

[jira] [Closed] (FLINK-14556) Correct the package of cloud pickle

[ https://issues.apache.org/jira/browse/FLINK-14556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14556. --- Resolution: Fixed > Correct the package of cloud pickle > --- > >

[jira] [Closed] (FLINK-14547) UDF cannot be in the join condition in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14547. --- Resolution: Fixed > UDF cannot be in the join condition in blink planner >

[jira] [Commented] (FLINK-14547) UDF cannot be in the join condition in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16963661#comment-16963661 ] Hequn Cheng commented on FLINK-14547: - Fixed in 1.9.2 via 4368f1da8598f993523dd18edef4b90f88eab4a1

[jira] [Assigned] (FLINK-14573) Support time data types in Python user-defined functions

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

[jira] [Updated] (FLINK-14547) UDF cannot be in the join condition in blink planner

[ https://issues.apache.org/jira/browse/FLINK-14547?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14547: Fix Version/s: 1.9.2 1.10.0 > UDF cannot be in the join condition in blink

[jira] [Commented] (FLINK-14478) The python test on travis consumes too much time

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

[jira] [Closed] (FLINK-14478) The python test on travis consumes too much time

[ https://issues.apache.org/jira/browse/FLINK-14478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14478. --- Resolution: Resolved > The python test on travis consumes too much time >

[jira] [Updated] (FLINK-14478) The python test on travis consumes too much time

[ https://issues.apache.org/jira/browse/FLINK-14478?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-14478: Fix Version/s: 1.10.0 > The python test on travis consumes too much time >

[jira] [Commented] (FLINK-14509) Improve the README.md in pyflink to prepare for PyPI release

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

[jira] [Closed] (FLINK-14509) Improve the README.md in pyflink to prepare for PyPI release

[ https://issues.apache.org/jira/browse/FLINK-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14509. --- Resolution: Resolved > Improve the README.md in pyflink to prepare for PyPI release >

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

[ https://issues.apache.org/jira/browse/FLINK-14497?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-14497. --- Resolution: Resolved > Support primitive data types in Python user-defined functions >

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

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

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

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

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

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

[jira] [Assigned] (FLINK-14509) Improve the README.md in pyflink to prepare for PyPI release

[ https://issues.apache.org/jira/browse/FLINK-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-14509: --- Assignee: Wei Zhong > Improve the README.md in pyflink to prepare for PyPI release >

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