[jira] [Created] (FLINK-16254) Support -p/--parallelism option for StatefulFunctionsClusterEntryPoint

2020-02-23 Thread Tzu-Li (Gordon) Tai (Jira)
Tzu-Li (Gordon) Tai created FLINK-16254: --- Summary: Support -p/--parallelism option for StatefulFunctionsClusterEntryPoint Key: FLINK-16254 URL: https://issues.apache.org/jira/browse/FLINK-16254

[GitHub] [flink] flinkbot commented on issue #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-23 Thread GitBox
flinkbot commented on issue #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198#issuecomment-590196380 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Assigned] (FLINK-16161) Statistics zero should be unknown in HiveCatalog

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16161?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16161: Assignee: Jingsong Lee > Statistics zero should be unknown in HiveCatalog >

[GitHub] [flink] hequn8128 commented on issue #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-23 Thread GitBox
hequn8128 commented on issue #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198#issuecomment-590192859 @becketqin @walterddr Would be great if you can also take a look.

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

2020-02-23 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16248: --- Labels: pull-request-available (was: ) > Add interfaces for MLEnvironment and

[GitHub] [flink] hequn8128 opened a new pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory

2020-02-23 Thread GitBox
hequn8128 opened a new pull request #11198: [FLINK-16248][python][ml] Add interfaces for MLEnvironment and MLEnvironmentFactory URL: https://github.com/apache/flink/pull/11198 ## What is the purpose of the change Align interface for MLEnvironment and MLEnvironmentFactory, so

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383101507 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -23,9 +23,7 @@ specific

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383103413 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -106,17 +97,18 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383102874 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -39,24 +37,17 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383103168 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -77,13 +68,13 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383101821 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -39,24 +37,17 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383105282 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -143,22 +135,22 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383106065 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -143,22 +135,22 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383106631 ## File path: docs/dev/connectors/pubsub.zh.md ## @@ -143,22 +135,22 @@

[GitHub] [flink] PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese

2020-02-23 Thread GitBox
PatrickRen commented on a change in pull request #11151: [FLINK-16128][docs]Translate "Google Cloud PubSub" page into Chinese URL: https://github.com/apache/flink/pull/11151#discussion_r383107003 ## File path: docs/dev/connectors/pubsub.md ## @@ -143,13 +143,13 @@

[GitHub] [flink] flinkbot edited a comment on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-587035354 ## CI report: * dba261b36b56aedec766097042dbe40858e5fc8c Travis:

[GitHub] [flink] liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging

2020-02-23 Thread GitBox
liupc commented on issue #9703: [FLINK-14038]Add default GC options for flink on yarn to facilitate debugging URL: https://github.com/apache/flink/pull/9703#issuecomment-590186785 Thanks @tillrohrmann , I think your concern is right, and the docs #11165 looks good!

[GitHub] [flink] flinkbot edited a comment on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-587035354 ## CI report: * dba261b36b56aedec766097042dbe40858e5fc8c Travis:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383102059 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383102071 ## File path:

[GitHub] [flink] dianfu commented on issue #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-23 Thread GitBox
dianfu commented on issue #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#issuecomment-590184765 @hequn8128 Thanks a lot for your review. Have updated the PR accordingly.

[GitHub] [flink] dianfu commented on a change in pull request #11112: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write

2020-02-23 Thread GitBox
dianfu commented on a change in pull request #2: [FLINK-16121][python] Introduce ArrowReader and ArrowWriter for Arrow format data read and write URL: https://github.com/apache/flink/pull/2#discussion_r383100703 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090816 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090260 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090336 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383094730 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383094754 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090816 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090336 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383090260 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383088089 ## File path:

[GitHub] [flink] zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on issue #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#issuecomment-590170854 Thanks for the updates @wsry and it generally looks good to me now, just left two tiny

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383088311 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383088089 ## File path:

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11179: [FLINK-16178][FLINK-16192][checkpointing] Clean up checkpoint metadata code and remove remaining bits of "legacy state"

2020-02-23 Thread GitBox
Jiayi-Liao commented on a change in pull request #11179: [FLINK-16178][FLINK-16192][checkpointing] Clean up checkpoint metadata code and remove remaining bits of "legacy state" URL: https://github.com/apache/flink/pull/11179#discussion_r383065779 ## File path:

[GitHub] [flink] zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment.

2020-02-23 Thread GitBox
zhijiangW commented on a change in pull request #11155: [FLINK-14818][benchmark] Fix receiving InputGate setup of StreamNetworkBenchmarkEnvironment. URL: https://github.com/apache/flink/pull/11155#discussion_r383081286 ## File path:

[jira] [Assigned] (FLINK-15289) Run sql appear error of "Zero-length character strings have no serializable string representation".

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15289: Assignee: (was: Jingsong Lee) > Run sql appear error of "Zero-length character

[jira] [Assigned] (FLINK-14257) Integrate csv to FileSystemTableFactory

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14257: Assignee: (was: Jingsong Lee) > Integrate csv to FileSystemTableFactory >

[jira] [Assigned] (FLINK-15397) Streaming and batch has different value in the case of count function

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15397: Assignee: (was: Jingsong Lee) > Streaming and batch has different value in the case

[jira] [Closed] (FLINK-15407) Add document to explain how to write a table with PK

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-15407. Resolution: Won't Fix > Add document to explain how to write a table with PK >

[jira] [Assigned] (FLINK-14258) Integrate hive to FileSystemTableFactory

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14258?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14258: Assignee: (was: Jingsong Lee) > Integrate hive to FileSystemTableFactory >

[jira] [Assigned] (FLINK-14256) Introduce FileSystemTableFactory with partitioned support

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14256: Assignee: (was: Jingsong Lee) > Introduce FileSystemTableFactory with partitioned

[jira] [Commented] (FLINK-15407) Add document to explain how to write a table with PK

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043152#comment-17043152 ] Jingsong Lee commented on FLINK-15407: -- We should have better design with changelog support to

[jira] [Assigned] (FLINK-15960) support creating Hive tables, views, functions within Flink

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15960?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15960: Assignee: Rui Li (was: Jingsong Lee) > support creating Hive tables, views, functions

[jira] [Assigned] (FLINK-15255) document how to create Hive table from java API and DDL

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15255: Assignee: Rui Li (was: Jingsong Lee) > document how to create Hive table from java API

[jira] [Assigned] (FLINK-15809) component stack page needs to be updated for blink planner

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15809?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-15809: Assignee: (was: Jingsong Lee) > component stack page needs to be updated for blink

[jira] [Assigned] (FLINK-16027) kafka connector's 'connector.topic' property should be optional rather than required

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16027?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16027: Assignee: (was: Jingsong Lee) > kafka connector's 'connector.topic' property should

[jira] [Assigned] (FLINK-16024) support filter pushdown in jdbc connector

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-16024: Assignee: (was: Jingsong Lee) > support filter pushdown in jdbc connector >

[jira] [Assigned] (FLINK-13777) Introduce sql function wrappers and conversion to ExpressionConverter

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13777: Assignee: (was: Jingsong Lee) > Introduce sql function wrappers and conversion to

[jira] [Assigned] (FLINK-13113) Introduce range partition in blink

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13113?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13113: Assignee: (was: Jingsong Lee) > Introduce range partition in blink >

[jira] [Assigned] (FLINK-14676) Introduce parallelism inference for source

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14676?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-14676: Assignee: (was: Jingsong Lee) > Introduce parallelism inference for source >

[jira] [Assigned] (FLINK-13786) Implement type inference for other functions

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13786: Assignee: (was: Jingsong Lee) > Implement type inference for other functions >

[jira] [Assigned] (FLINK-13782) Implement type inference for logic functions

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13782?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13782: Assignee: (was: Jingsong Lee) > Implement type inference for logic functions >

[jira] [Assigned] (FLINK-13783) Implement type inference for string functions

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13783?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13783: Assignee: (was: Jingsong Lee) > Implement type inference for string functions >

[jira] [Assigned] (FLINK-13780) Introduce ExpressionConverter to legacy planner

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13780?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13780: Assignee: (was: Jingsong Lee) > Introduce ExpressionConverter to legacy planner >

[jira] [Assigned] (FLINK-13781) Use new Expression in RexNodeToExpressionConverter

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13781?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13781: Assignee: (was: Jingsong Lee) > Use new Expression in RexNodeToExpressionConverter >

[jira] [Assigned] (FLINK-13785) Implement type inference for time functions

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13785?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13785: Assignee: (was: Jingsong Lee) > Implement type inference for time functions >

[jira] [Assigned] (FLINK-13784) Implement type inference for math functions

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13784?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13784: Assignee: (was: Jingsong Lee) > Implement type inference for math functions >

[jira] [Assigned] (FLINK-13773) Rework of the Expression Design

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-13773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-13773: Assignee: (was: Jingsong Lee) > Rework of the Expression Design >

[jira] [Commented] (FLINK-16253) Switch to Log4j 2 by default for flink-kubernetes submodule

2020-02-23 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043148#comment-17043148 ] Canbin Zheng commented on FLINK-16253: -- cc [~chesnay] > Switch to Log4j 2 by default for

[jira] [Created] (FLINK-16253) Switch to Log4j 2 by default for flink-kubernetes submodule

2020-02-23 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-16253: Summary: Switch to Log4j 2 by default for flink-kubernetes submodule Key: FLINK-16253 URL: https://issues.apache.org/jira/browse/FLINK-16253 Project: Flink

[jira] [Commented] (FLINK-15786) Load connector code with separate classloader

2020-02-23 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15786?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043146#comment-17043146 ] Yang Wang commented on FLINK-15786: --- [~maguowei] Since the filesystem could be well supported via 

[GitHub] [flink] flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176#issuecomment-589671142 ## CI report: * 754693bae424353bac4cdd6d0db556ed8f6234f9 Travis:

[GitHub] [flink] KarmaGYZ commented on issue #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the…

2020-02-23 Thread GitBox
KarmaGYZ commented on issue #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the… URL: https://github.com/apache/flink/pull/11197#issuecomment-590157417 Travis link https://travis-ci.org/KarmaGYZ/flink/jobs/654212375. I don't know why the "e2e - container -

[GitHub] [flink] lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition …

2020-02-23 Thread GitBox
lirui-apache commented on issue #11175: [FLINK-16197][hive] Failed to query partitioned table when partition … URL: https://github.com/apache/flink/pull/11175#issuecomment-590155149 Hi @bowenli86 , could you elaborate why it's not a good longterm strategy? IMHO, it should be up to each

[GitHub] [flink] wangyang0918 commented on issue #11117: [FLINK-16115][filesystem] Make aliyun oss filesystem could work with plugin mechanism

2020-02-23 Thread GitBox
wangyang0918 commented on issue #7: [FLINK-16115][filesystem] Make aliyun oss filesystem could work with plugin mechanism URL: https://github.com/apache/flink/pull/7#issuecomment-590153300 @zentol Could you have another look and help with merging?

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

2020-02-23 Thread Xintong Song (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043137#comment-17043137 ] Xintong Song commented on FLINK-16215: -- I share [~trohrmann]'s concern. On Yarn deployment,

[jira] [Commented] (FLINK-16215) Start redundant TaskExecutor when JM failed

2020-02-23 Thread Yang Wang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17043134#comment-17043134 ] Yang Wang commented on FLINK-16215: --- I think even we make {{recoverWokerNode}} as interface and do the

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11179: [FLINK-16178][FLINK-16192][checkpointing] Clean up checkpoint metadata code and remove remaining bits of "legacy state"

2020-02-23 Thread GitBox
Jiayi-Liao commented on a change in pull request #11179: [FLINK-16178][FLINK-16192][checkpointing] Clean up checkpoint metadata code and remove remaining bits of "legacy state" URL: https://github.com/apache/flink/pull/11179#discussion_r383065779 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176#issuecomment-589671142 ## CI report: * adb2e9e62190ba505ee86554a97452984fbc2de4 Travis:

[GitHub] [flink] danny0405 commented on issue #11190: [FLINK-16089][docs] Translate "Data Type" page of "Table API & SQL" into Chinese

2020-02-23 Thread GitBox
danny0405 commented on issue #11190: [FLINK-16089][docs] Translate "Data Type" page of "Table API & SQL" into Chinese URL: https://github.com/apache/flink/pull/11190#issuecomment-590146367 @wuchong , sure, let me take the review work.

[GitHub] [flink] danny0405 commented on a change in pull request #11116: [FLINK-15349] add 'create catalog' DDL to blink planner

2020-02-23 Thread GitBox
danny0405 commented on a change in pull request #6: [FLINK-15349] add 'create catalog' DDL to blink planner URL: https://github.com/apache/flink/pull/6#discussion_r383064990 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

2020-02-23 Thread GitBox
xintongsong commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176#discussion_r383064789 ## File path:

[GitHub] [flink] xintongsong commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

2020-02-23 Thread GitBox
xintongsong commented on a change in pull request #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176#discussion_r383064879 ## File path:

[jira] [Assigned] (FLINK-16252) Optimize the progress of the process_outputs in Python UDF

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16252: --- Assignee: Huang Xingbo > Optimize the progress of the process_outputs in Python UDF >

[jira] [Assigned] (FLINK-16251) Optimize the cost of function call in ScalarFunctionOpertation

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16251?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16251: --- Assignee: Huang Xingbo > Optimize the cost of function call in ScalarFunctionOpertation >

[jira] [Created] (FLINK-16252) Optimize the progress of the process_outputs in Python UDF

2020-02-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16252: Summary: Optimize the progress of the process_outputs in Python UDF Key: FLINK-16252 URL: https://issues.apache.org/jira/browse/FLINK-16252 Project: Flink

[GitHub] [flink] danny0405 commented on a change in pull request #11116: [FLINK-15349] add 'create catalog' DDL to blink planner

2020-02-23 Thread GitBox
danny0405 commented on a change in pull request #6: [FLINK-15349] add 'create catalog' DDL to blink planner URL: https://github.com/apache/flink/pull/6#discussion_r383064486 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #11176: [FLINK-15948][yarn] Enrich the warning log for YARN minimum allocation memory URL: https://github.com/apache/flink/pull/11176#issuecomment-589671142 ## CI report: * adb2e9e62190ba505ee86554a97452984fbc2de4 Travis:

[jira] [Created] (FLINK-16251) Optimize the cost of function call in ScalarFunctionOpertation

2020-02-23 Thread Huang Xingbo (Jira)
Huang Xingbo created FLINK-16251: Summary: Optimize the cost of function call in ScalarFunctionOpertation Key: FLINK-16251 URL: https://issues.apache.org/jira/browse/FLINK-16251 Project: Flink

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

2020-02-23 Thread Hequn Cheng (Jira)
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] [Resolved] (FLINK-15172) Optimize the operator algorithm to lazily allocate memory

2020-02-23 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-15172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-15172. -- Resolution: Fixed Merged in Master: c11c696cca3b6ecafab605cceb36b7541444993f

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

2020-02-23 Thread Hequn Cheng (Jira)
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

[GitHub] [flink] JingsongLi commented on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-02-23 Thread GitBox
JingsongLi commented on issue #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797#issuecomment-590144331 Thanks @TsReaper for the reviewing. Merged.

[GitHub] [flink] JingsongLi closed pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory

2020-02-23 Thread GitBox
JingsongLi closed pull request #10797: [FLINK-15172][table-blink] Optimize the operator algorithm to lazily allocate memory URL: https://github.com/apache/flink/pull/10797 This is an automated message from the Apache Git

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

2020-02-23 Thread Hequn Cheng (Jira)
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] [Assigned] (FLINK-14509) Improve the README.md in pyflink to prepare for PyPI release

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-14509: --- Assignee: Wei Zhong (was: Weizhong) > Improve the README.md in pyflink to prepare for PyPI

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh…

2020-02-23 Thread GitBox
KarmaGYZ commented on a change in pull request #11100: [FLINK-15562][docs] Add Example settings.xml for maven archetype command wh… URL: https://github.com/apache/flink/pull/11100#discussion_r383061588 ## File path: docs/dev/projectsetup/scala_api_quickstart.md ## @@

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

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16031: --- Assignee: Wei Zhong (was: Weizhong) > Improve the description in the README file of PyFlink

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

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16031?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-16031: --- Assignee: Weizhong > Improve the description in the README file of PyFlink 1.9.x >

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

2020-02-23 Thread Dian Fu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14509?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dian Fu reassigned FLINK-14509: --- Assignee: Weizhong (was: Wei Zhong (old)) > Improve the README.md in pyflink to prepare for PyPI

[GitHub] [flink] flinkbot edited a comment on issue #11192: [FLINK-16237][build] Add Log4j2 configuration properties

2020-02-23 Thread GitBox
flinkbot edited a comment on issue #11192: [FLINK-16237][build] Add Log4j2 configuration properties URL: https://github.com/apache/flink/pull/11192#issuecomment-590057592 ## CI report: * 6500c5170375b837320f00a032d64a7eec69135d Travis:

[GitHub] [flink] flinkbot commented on issue #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the…

2020-02-23 Thread GitBox
flinkbot commented on issue #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the… URL: https://github.com/apache/flink/pull/11197#issuecomment-590137926 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

[GitHub] [flink] KarmaGYZ opened a new pull request #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the…

2020-02-23 Thread GitBox
KarmaGYZ opened a new pull request #11197: [FLINK-16288][travis] Remove redundant double-quote at the end of the… URL: https://github.com/apache/flink/pull/11197 … env field ## What is the purpose of the change Remove redundant double-quote at the end of the env

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055795 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055217 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055205 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055079 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055067 ## File path:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode

2020-02-23 Thread GitBox
gaoyunhaii commented on a change in pull request #7368: [FLINK-10742][network] Let Netty use Flink's buffers directly in credit-based mode URL: https://github.com/apache/flink/pull/7368#discussion_r383055157 ## File path:

  1   2   3   4   5   >