[jira] [Created] (FLINK-16673) Support Counter, Gauge, Meter, Distribution metric type for Python UDTF

Hequn Cheng created FLINK-16673: --- Summary: Support Counter, Gauge, Meter, Distribution metric type for Python UDTF Key: FLINK-16673 URL: https://issues.apache.org/jira/browse/FLINK-16673 Project: Flink

[jira] [Created] (FLINK-16672) Support Counter, Gauge, Meter, Distribution metric type for Python UDF

Hequn Cheng created FLINK-16672: --- Summary: Support Counter, Gauge, Meter, Distribution metric type for Python UDF Key: FLINK-16672 URL: https://issues.apache.org/jira/browse/FLINK-16672 Project: Flink

[jira] [Created] (FLINK-16671) Support define scopes and variables on Python metric group

Hequn Cheng created FLINK-16671: --- Summary: Support define scopes and variables on Python metric group Key: FLINK-16671 URL: https://issues.apache.org/jira/browse/FLINK-16671 Project: Flink

[jira] [Created] (FLINK-16670) Support User-Defined Metrics in Python UDF

Hequn Cheng created FLINK-16670: --- Summary: Support User-Defined Metrics in Python UDF Key: FLINK-16670 URL: https://issues.apache.org/jira/browse/FLINK-16670 Project: Flink Issue Type: New

[jira] [Closed] (FLINK-16187) Support Python ML Pipeline API

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

[jira] [Updated] (FLINK-16187) Support Python ML Pipeline API

[ https://issues.apache.org/jira/browse/FLINK-16187?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16187: Fix Version/s: 1.11.0 > Support Python ML Pipeline API > -- > >

[jira] [Updated] (FLINK-16606) Throw exceptions for the data types which are not currently supported

[ https://issues.apache.org/jira/browse/FLINK-16606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16606: Release Note: Currently, DataTypes can be configured with some parameters, e.g., precision.

[jira] [Closed] (FLINK-16606) Throw exceptions for the data types which are not currently supported

[ https://issues.apache.org/jira/browse/FLINK-16606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16606. --- Resolution: Resolved > Throw exceptions for the data types which are not currently supported >

[jira] [Updated] (FLINK-16606) Throw exceptions for the data types which are not currently supported

[ https://issues.apache.org/jira/browse/FLINK-16606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16606: Release Note: Currently, DataTypes can be configured with some parameters, e.g., precision.

[jira] [Updated] (FLINK-16606) Throw exceptions for the data types which are not currently supported

[ https://issues.apache.org/jira/browse/FLINK-16606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16606: Fix Version/s: (was: 1.10.1) > Throw exceptions for the data types which are not currently

[jira] [Commented] (FLINK-16606) Throw exceptions for the data types which are not currently supported

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

[jira] [Commented] (FLINK-16482) Flink Job throw CloseException when call the FlinkKafkaConsumer cancel function

[ https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17061639#comment-17061639 ] Hequn Cheng commented on FLINK-16482: - [~rmetzger] Thank you very much for the notice and providing

[jira] [Closed] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

[ https://issues.apache.org/jira/browse/FLINK-16607?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16607. --- Resolution: Resolved > Update flink-fn-execution.proto adding more schema information >

[jira] [Commented] (FLINK-16607) Update flink-fn-execution.proto adding more schema information

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

[jira] [Commented] (FLINK-16583) SQLClientKafkaITCase.testKafka failed with SqlClientException

[ https://issues.apache.org/jira/browse/FLINK-16583?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17059148#comment-17059148 ] Hequn Cheng commented on FLINK-16583: - Another instance:

[jira] [Closed] (FLINK-16538) Restructure Python Table API documentation

[ https://issues.apache.org/jira/browse/FLINK-16538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16538. --- Resolution: Resolved > Restructure Python Table API documentation >

[jira] [Commented] (FLINK-16538) Restructure Python Table API documentation

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

[jira] [Closed] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

[ https://issues.apache.org/jira/browse/FLINK-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16008. --- Resolution: Resolved > Add rules to transpose the join condition of Python Correlate node >

[jira] [Commented] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

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

[jira] [Assigned] (FLINK-16008) Add rules to transpose the join condition of Python Correlate node

[ https://issues.apache.org/jira/browse/FLINK-16008?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16008: --- Assignee: Huang Xingbo > Add rules to transpose the join condition of Python Correlate

[jira] [Created] (FLINK-16565) Make Pipeline Json compitable between Java and Python if all Pipelinestage are Java ones

Hequn Cheng created FLINK-16565: --- Summary: Make Pipeline Json compitable between Java and Python if all Pipelinestage are Java ones Key: FLINK-16565 URL: https://issues.apache.org/jira/browse/FLINK-16565

[jira] [Closed] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16477. --- Resolution: Fixed > CorrelateTest.testCorrelatePythonTableFunction test fails >

[jira] [Assigned] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16477: --- Assignee: Hequn Cheng > CorrelateTest.testCorrelatePythonTableFunction test fails >

[jira] [Updated] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16477: Fix Version/s: 1.11.0 > CorrelateTest.testCorrelatePythonTableFunction test fails >

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

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

[jira] [Comment Edited] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056918#comment-17056918 ] Hequn Cheng edited comment on FLINK-16477 at 3/11/20, 11:48 AM: I think

[jira] [Commented] (FLINK-16477) CorrelateTest.testCorrelatePythonTableFunction test fails

[ https://issues.apache.org/jira/browse/FLINK-16477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17056918#comment-17056918 ] Hequn Cheng commented on FLINK-16477: - I think it is the same problem as it is described in

[jira] [Commented] (FLINK-16454) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055985#comment-17055985 ] Hequn Cheng commented on FLINK-16454: - I have added 1.10.1 and 1.9.3 to the fix version as I think

[jira] [Closed] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

[ https://issues.apache.org/jira/browse/FLINK-16483?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16483. --- Resolution: Resolved > Add Python building blocks to make sure the basic functionality of

[jira] [Commented] (FLINK-16483) Add Python building blocks to make sure the basic functionality of vectorized Python UDF could work

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

[jira] [Commented] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055733#comment-17055733 ] Hequn Cheng commented on FLINK-16241: - Fixed in 1.10.1 via d969226cd7ac4bf572a05b9d6b04f650a62faf29

[jira] [Closed] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16241. --- Resolution: Fixed > Remove the license and notice file in flink-ml-lib module on release-1.10 >

[jira] [Closed] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16167. --- Resolution: Resolved > update python_shell document execution >

[jira] [Updated] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16167: Fix Version/s: 1.9.3 > update python_shell document execution >

[jira] [Comment Edited] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055578#comment-17055578 ] Hequn Cheng edited comment on FLINK-16167 at 3/10/20, 5:12 AM: --- Resolved

[jira] [Commented] (FLINK-16167) update python_shell document execution

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

[jira] [Updated] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16167: Fix Version/s: 1.11.0 1.10.1 > update python_shell document execution >

[jira] [Commented] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17055574#comment-17055574 ] Hequn Cheng commented on FLINK-16167: - [~yuwenbing] Thanks a lot for the contribution. > update

[jira] [Closed] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

[ https://issues.apache.org/jira/browse/FLINK-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16273. --- Resolution: Fixed > Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not >

[jira] [Commented] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

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

[jira] [Updated] (FLINK-16250) Add interfaces for PipelineStage and Pipeline

[ https://issues.apache.org/jira/browse/FLINK-16250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16250: Fix Version/s: 1.11.0 > Add interfaces for PipelineStage and Pipeline >

[jira] [Commented] (FLINK-16482) Flink任务的kafkaSource因为cancel导致任务失败而重启

[ https://issues.apache.org/jira/browse/FLINK-16482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17053951#comment-17053951 ] Hequn Cheng commented on FLINK-16482: - [~kangzai] Hi, thanks a lot for reporting the bug! Could you

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

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

[jira] [Updated] (FLINK-16454) Update the copyright year in NOTICE files

[ https://issues.apache.org/jira/browse/FLINK-16454?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16454: Fix Version/s: 1.10.1 1.9.3 > Update the copyright year in NOTICE files >

[jira] [Closed] (FLINK-16248) Add interfaces for MLEnvironment and MLEnvironmentFactory

[ https://issues.apache.org/jira/browse/FLINK-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16248. --- Resolution: Resolved > Add interfaces for MLEnvironment and MLEnvironmentFactory >

[jira] [Updated] (FLINK-16248) Add interfaces for MLEnvironment and MLEnvironmentFactory

[ https://issues.apache.org/jira/browse/FLINK-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16248: Fix Version/s: 1.11.0 > Add interfaces for MLEnvironment and MLEnvironmentFactory >

[jira] [Commented] (FLINK-16248) Add interfaces for MLEnvironment and MLEnvironmentFactory

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

[jira] [Closed] (FLINK-16337) Add RelNodes and Rules for vectorized Python UDF execution

[ https://issues.apache.org/jira/browse/FLINK-16337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16337. --- Resolution: Resolved > Add RelNodes and Rules for vectorized Python UDF execution >

[jira] [Commented] (FLINK-16337) Add RelNodes and Rules for vectorized Python UDF execution

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

[jira] [Closed] (FLINK-16007) Add rules to push down the Java Calls contained in Python Correlate node

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

[jira] [Commented] (FLINK-16007) Add rules to push down the Java Calls contained in Python Correlate node

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

[jira] [Assigned] (FLINK-16007) Add rules to push down the Java Calls contained in Python Correlate node

[ https://issues.apache.org/jira/browse/FLINK-16007?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16007: --- Assignee: Huang Xingbo > Add rules to push down the Java Calls contained in Python

[jira] [Closed] (FLINK-15972) Add Python building blocks to make sure the basic functionality of Python TableFunction could work

[ https://issues.apache.org/jira/browse/FLINK-15972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15972. --- Resolution: Resolved > Add Python building blocks to make sure the basic functionality of Python >

[jira] [Commented] (FLINK-15972) Add Python building blocks to make sure the basic functionality of Python TableFunction could work

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

[jira] [Assigned] (FLINK-15972) Add Python building blocks to make sure the basic functionality of Python TableFunction could work

[ https://issues.apache.org/jira/browse/FLINK-15972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15972: --- Assignee: Huang Xingbo > Add Python building blocks to make sure the basic functionality

[jira] [Closed] (FLINK-16263) BaseRowArrowReaderWriterTest/RowArrowReaderWriterTest sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

[ https://issues.apache.org/jira/browse/FLINK-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16263. --- Resolution: Fixed > BaseRowArrowReaderWriterTest/RowArrowReaderWriterTest sun.misc.Unsafe or >

[jira] [Commented] (FLINK-16263) BaseRowArrowReaderWriterTest/RowArrowReaderWriterTest sun.misc.Unsafe or java.nio.DirectByteBuffer.(long, int) not available

[ https://issues.apache.org/jira/browse/FLINK-16263?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17044282#comment-17044282 ] Hequn Cheng commented on FLINK-16263: - Fixed in master via 93da5ecf096657e22e2692da73346b5ddaf5feba

[jira] [Created] (FLINK-16273) Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users

Hequn Cheng created FLINK-16273: --- Summary: Solve "sun.misc.Unseafe or java.nio.DirectByteBuffer.(long, int) not available" problem for users Key: FLINK-16273 URL: https://issues.apache.org/jira/browse/FLINK-16273

[jira] [Updated] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16241: Priority: Blocker (was: Major) > Remove the license and notice file in flink-ml-lib module on

[jira] [Closed] (FLINK-16121) Introduce ArrowReader and ArrowWriter for Arrow format data read and write

[ https://issues.apache.org/jira/browse/FLINK-16121?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16121. --- Resolution: Resolved > Introduce ArrowReader and ArrowWriter for Arrow format data read and write >

[jira] [Commented] (FLINK-16121) Introduce ArrowReader and ArrowWriter for Arrow format data read and write

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

[jira] [Closed] (FLINK-16031) Improve the description in the README file of PyFlink 1.9.x

[ https://issues.apache.org/jira/browse/FLINK-16031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16031. --- Resolution: Resolved > Improve the description in the README file of PyFlink 1.9.x >

[jira] [Commented] (FLINK-16031) Improve the description in the README file of PyFlink 1.9.x

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

[jira] [Updated] (FLINK-16031) Improve the description in the README file of PyFlink 1.9.x

[ https://issues.apache.org/jira/browse/FLINK-16031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16031: Fix Version/s: (was: 1.9.2) > Improve the description in the README file of PyFlink 1.9.x >

[jira] [Created] (FLINK-16250) Add interfaces for PipelineStage and Pipeline

Hequn Cheng created FLINK-16250: --- Summary: Add interfaces for PipelineStage and Pipeline Key: FLINK-16250 URL: https://issues.apache.org/jira/browse/FLINK-16250 Project: Flink Issue Type:

[jira] [Created] (FLINK-16249) Add interfaces for Params, ParamInfo and WithParams

Hequn Cheng created FLINK-16249: --- Summary: Add interfaces for Params, ParamInfo and WithParams Key: FLINK-16249 URL: https://issues.apache.org/jira/browse/FLINK-16249 Project: Flink Issue

[jira] [Created] (FLINK-16248) Add interfaces for MLEnvironment and MLEnvironmentFactory

Hequn Cheng created FLINK-16248: --- Summary: Add interfaces for MLEnvironment and MLEnvironmentFactory Key: FLINK-16248 URL: https://issues.apache.org/jira/browse/FLINK-16248 Project: Flink

[jira] [Commented] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17042811#comment-17042811 ] Hequn Cheng commented on FLINK-16241: - There are two options to solve this problem: 1. Bundle the

[jira] [Updated] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

[ https://issues.apache.org/jira/browse/FLINK-16241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16241: Description: The jar of flink-ml-lib should not contain the license and notice file as it

[jira] [Created] (FLINK-16241) Remove the license and notice file in flink-ml-lib module on release-1.10 branch

Hequn Cheng created FLINK-16241: --- Summary: Remove the license and notice file in flink-ml-lib module on release-1.10 branch Key: FLINK-16241 URL: https://issues.apache.org/jira/browse/FLINK-16241

[jira] [Created] (FLINK-16187) Support Python ML Pipeline API

Hequn Cheng created FLINK-16187: --- Summary: Support Python ML Pipeline API Key: FLINK-16187 URL: https://issues.apache.org/jira/browse/FLINK-16187 Project: Flink Issue Type: New Feature

[jira] [Assigned] (FLINK-16167) update python_shell document execution

[ https://issues.apache.org/jira/browse/FLINK-16167?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-16167: --- Assignee: yuwenbing > update python_shell document execution >

[jira] [Closed] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

[ https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15961. --- Resolution: Resolved > Introduce Python Physical Correlate RelNodes which are containers for

[jira] [Commented] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

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

[jira] [Created] (FLINK-16119) Port base RelNode classes from Scala to Java

Hequn Cheng created FLINK-16119: --- Summary: Port base RelNode classes from Scala to Java Key: FLINK-16119 URL: https://issues.apache.org/jira/browse/FLINK-16119 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-15961) Introduce Python Physical Correlate RelNodes which are containers for Python TableFunction

[ https://issues.apache.org/jira/browse/FLINK-15961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15961: --- Assignee: Huang Xingbo > Introduce Python Physical Correlate RelNodes which are

[jira] [Assigned] (FLINK-15913) Add Python Table Function Runner And Operator

[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15913: --- Assignee: Huang Xingbo > Add Python Table Function Runner And Operator >

[jira] [Closed] (FLINK-15913) Add Python Table Function Runner And Operator

[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15913. --- Resolution: Resolved > Add Python Table Function Runner And Operator >

[jira] [Comment Edited] (FLINK-15913) Add Python Table Function Runner And Operator

[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036638#comment-17036638 ] Hequn Cheng edited comment on FLINK-15913 at 2/14/20 2:10 AM: -- Resolved in

[jira] [Commented] (FLINK-15913) Add Python Table Function Runner And Operator

[ https://issues.apache.org/jira/browse/FLINK-15913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17036638#comment-17036638 ] Hequn Cheng commented on FLINK-15913: - Resolved in #11044: d36d97c84a365d1aee8101dbb1db61374348d024

[jira] [Closed] (FLINK-15909) Add PyPI release process into the subsequent release of 1.9.x

[ https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15909. --- Resolution: Resolved > Add PyPI release process into the subsequent release of 1.9.x >

[jira] [Commented] (FLINK-15909) Add PyPI release process into the subsequent release of 1.9.x

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

[jira] [Updated] (FLINK-15909) Add PyPI release process into the subsequent release of 1.9.x

[ https://issues.apache.org/jira/browse/FLINK-15909?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15909: Issue Type: Improvement (was: Bug) > Add PyPI release process into the subsequent release of

[jira] [Updated] (FLINK-15908) Add description of support 'pip install' to 1.9.x documents

[ https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15908: Issue Type: Improvement (was: Bug) > Add description of support 'pip install' to 1.9.x documents

[jira] [Commented] (FLINK-15908) Add description of support 'pip install' to 1.9.x documents

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

[jira] [Closed] (FLINK-15908) Add description of support 'pip install' to 1.9.x documents

[ https://issues.apache.org/jira/browse/FLINK-15908?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15908. --- Resolution: Resolved > Add description of support 'pip install' to 1.9.x documents >

[jira] [Commented] (FLINK-15897) Defer the deserialization of the Python UDF execution results

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

[jira] [Closed] (FLINK-15897) Defer the deserialization of the Python UDF execution results

[ https://issues.apache.org/jira/browse/FLINK-15897?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15897. --- Resolution: Resolved > Defer the deserialization of the Python UDF execution results >

[jira] [Comment Edited] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17018475#comment-17018475 ] Hequn Cheng edited comment on FLINK-15638 at 2/4/20 8:44 AM: - Fixed in

[jira] [Updated] (FLINK-15638) releasing/create_release_branch.sh does not set version in flink-python/pyflink/version.py

[ https://issues.apache.org/jira/browse/FLINK-15638?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15638: Fix Version/s: 1.9.3 > releasing/create_release_branch.sh does not set version in >

[jira] [Updated] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15847: Affects Version/s: (was: 1.9.2) (was: 1.10.0) > Include

[jira] [Updated] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15847: Affects Version/s: 1.10.0 1.9.2 > Include flink-ml-api and flink-ml-lib in

[jira] [Commented] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17028715#comment-17028715 ] Hequn Cheng commented on FLINK-15847: - We can add `maven-shade-plugin` in the pom of flink-ml-lib

[jira] [Updated] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

[ https://issues.apache.org/jira/browse/FLINK-15847?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-15847: Fix Version/s: 1.11.0 > Include flink-ml-api and flink-ml-lib in opt >

[jira] [Created] (FLINK-15847) Include flink-ml-api and flink-ml-lib in opt

Hequn Cheng created FLINK-15847: --- Summary: Include flink-ml-api and flink-ml-lib in opt Key: FLINK-15847 URL: https://issues.apache.org/jira/browse/FLINK-15847 Project: Flink Issue Type:

[jira] [Closed] (FLINK-15823) Sync download page translation

[ https://issues.apache.org/jira/browse/FLINK-15823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-15823. --- Resolution: Resolved > Sync download page translation > -- > >

[jira] [Commented] (FLINK-15823) Sync download page translation

[ https://issues.apache.org/jira/browse/FLINK-15823?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17027290#comment-17027290 ] Hequn Cheng commented on FLINK-15823: - asf-site: d8767dec8f9d438c2ef3c60caa68fca5d4d829f4 > Sync

[jira] [Assigned] (FLINK-15823) Sync download page translation

[ https://issues.apache.org/jira/browse/FLINK-15823?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng reassigned FLINK-15823: --- Assignee: Hequn Cheng > Sync download page translation > -- >

[jira] [Commented] (FLINK-15800) Refactor download page to make hadoop less prominant

[ https://issues.apache.org/jira/browse/FLINK-15800?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17026765#comment-17026765 ] Hequn Cheng commented on FLINK-15800: - I can help to cover the Chinese part. > Refactor download

[jira] [Updated] (FLINK-13747) Remove some TODOs in Hive connector

[ https://issues.apache.org/jira/browse/FLINK-13747?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-13747: Fix Version/s: (was: 1.9.2) > Remove some TODOs in Hive connector >

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