[GitHub] [flink] zentol merged pull request #8803: [FLINK-12903][py] Remove old Python APIs

2019-06-21 Thread GitBox
zentol merged pull request #8803: [FLINK-12903][py] Remove old Python APIs URL: https://github.com/apache/flink/pull/8803 This is an automated message from the Apache Git Service. To respond to the message, please log on to G

[GitHub] [flink] JingsongLi commented on a change in pull request #8792: [FLINK-12743][table-runtime-blink] Introduce unbounded streaming anti/semi join operator

2019-06-21 Thread GitBox
JingsongLi commented on a change in pull request #8792: [FLINK-12743][table-runtime-blink] Introduce unbounded streaming anti/semi join operator URL: https://github.com/apache/flink/pull/8792#discussion_r296435562 ## File path: flink-table/flink-table-runtime-blink/src/main/java/o

[GitHub] [flink] JingsongLi commented on a change in pull request #8792: [FLINK-12743][table-runtime-blink] Introduce unbounded streaming anti/semi join operator

2019-06-21 Thread GitBox
JingsongLi commented on a change in pull request #8792: [FLINK-12743][table-runtime-blink] Introduce unbounded streaming anti/semi join operator URL: https://github.com/apache/flink/pull/8792#discussion_r296435653 ## File path: flink-table/flink-table-runtime-blink/src/main/java/o

[GitHub] [flink] xuefuz commented on a change in pull request #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl

2019-06-21 Thread GitBox
xuefuz commented on a change in pull request #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl URL: https://github.com/apache/flink/pull/8815#discussion_r296434374 ## File path: flink-table/flink-table-comm

[jira] [Created] (FLINK-12943) Translate "HDFS Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12943: --- Summary: Translate "HDFS Connector" page into Chinese Key: FLINK-12943 URL: https://issues.apache.org/jira/browse/FLINK-12943 Project: Flink Issue Type: Sub-task

[GitHub] [flink] flinkbot commented on issue #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

2019-06-21 Thread GitBox
flinkbot commented on issue #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832#issuecomment-504630062 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the c

[jira] [Updated] (FLINK-12937) Introduce join reorder planner rules in blink planner

2019-06-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12937: --- Labels: pull-request-available (was: ) > Introduce join reorder planner rules in blink plan

[GitHub] [flink] godfreyhe opened a new pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner

2019-06-21 Thread GitBox
godfreyhe opened a new pull request #8832: [FLINK-12937] [table-planner-blink] Introduce join reorder planner rules in blink planner URL: https://github.com/apache/flink/pull/8832 ## What is the purpose of the change *Introduce join reorder planner rules in blink planner*

[jira] [Created] (FLINK-12947) Translate "Twitter Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12947: --- Summary: Translate "Twitter Connector" page into Chinese Key: FLINK-12947 URL: https://issues.apache.org/jira/browse/FLINK-12947 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12945) Translate "RabbitMQ Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12945: --- Summary: Translate "RabbitMQ Connector" page into Chinese Key: FLINK-12945 URL: https://issues.apache.org/jira/browse/FLINK-12945 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12946) Translate "Apache NiFi Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12946: --- Summary: Translate "Apache NiFi Connector" page into Chinese Key: FLINK-12946 URL: https://issues.apache.org/jira/browse/FLINK-12946 Project: Flink Issue Type: Sub-tas

[jira] [Created] (FLINK-12944) Translate "Streaming File Sink" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12944: --- Summary: Translate "Streaming File Sink" page into Chinese Key: FLINK-12944 URL: https://issues.apache.org/jira/browse/FLINK-12944 Project: Flink Issue Type: Sub-task

[jira] [Updated] (FLINK-12937) Introduce join reorder planner rules in blink planner

2019-06-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12937: --- Description: This issue aims to let blink planner support join reorder. {{LoptOptimizeJoinRule}} in

[jira] [Created] (FLINK-12942) Translate "Elasticsearch Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12942: --- Summary: Translate "Elasticsearch Connector" page into Chinese Key: FLINK-12942 URL: https://issues.apache.org/jira/browse/FLINK-12942 Project: Flink Issue Type: Sub-t

[jira] [Created] (FLINK-12941) Translate "Amazon AWS Kinesis Streams Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12941: --- Summary: Translate "Amazon AWS Kinesis Streams Connector" page into Chinese Key: FLINK-12941 URL: https://issues.apache.org/jira/browse/FLINK-12941 Project: Flink Iss

[jira] [Updated] (FLINK-12937) Introduce join reorder planner rules in blink planner

2019-06-21 Thread godfrey he (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12937?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] godfrey he updated FLINK-12937: --- Description: This issue aims to let blink planner support join reorder. {{LoptOptimizeJoinRule}} in

[jira] [Created] (FLINK-12940) Translate "Apache Cassandra Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12940: --- Summary: Translate "Apache Cassandra Connector" page into Chinese Key: FLINK-12940 URL: https://issues.apache.org/jira/browse/FLINK-12940 Project: Flink Issue Type: Su

[jira] [Created] (FLINK-12939) Translate "Apache Kafka Connector" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12939: --- Summary: Translate "Apache Kafka Connector" page into Chinese Key: FLINK-12939 URL: https://issues.apache.org/jira/browse/FLINK-12939 Project: Flink Issue Type: Sub-ta

[jira] [Created] (FLINK-12938) Translate "Streaming Connectors" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
Jark Wu created FLINK-12938: --- Summary: Translate "Streaming Connectors" page into Chinese Key: FLINK-12938 URL: https://issues.apache.org/jira/browse/FLINK-12938 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-12937) Introduce join reorder planner rules in blink planner

2019-06-21 Thread godfrey he (JIRA)
godfrey he created FLINK-12937: -- Summary: Introduce join reorder planner rules in blink planner Key: FLINK-12937 URL: https://issues.apache.org/jira/browse/FLINK-12937 Project: Flink Issue Type:

[GitHub] [flink] xuefuz commented on a change in pull request #8814: [FLINK-12917][hive] support complex type of array, map, struct for Hive functions

2019-06-21 Thread GitBox
xuefuz commented on a change in pull request #8814: [FLINK-12917][hive] support complex type of array, map, struct for Hive functions URL: https://github.com/apache/flink/pull/8814#discussion_r296433764 ## File path: flink-connectors/flink-connector-hive/src/main/java/org/apache/fl

[GitHub] [flink] asfgit closed pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje…

2019-06-21 Thread GitBox
asfgit closed pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje… URL: https://github.com/apache/flink/pull/8799 This is an automated message from the Apache Git Service. To respond to

[jira] [Closed] (FLINK-11612) Translate the "Project Template for Java" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-11612. --- Resolution: Fixed Fix Version/s: 1.9.0 Fixed in 1.9.0: 9ef4b74bbc770113344bb17ac9b74accc1d14e1d > Tr

[GitHub] [flink] flinkbot commented on issue #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution

2019-06-21 Thread GitBox
flinkbot commented on issue #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution URL: https://github.com/apache/flink/pull/8831#issuecomment-504626652 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to re

[jira] [Updated] (FLINK-12935) package flink-connector-hive into flink distribution

2019-06-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12935: --- Labels: pull-request-available (was: ) > package flink-connector-hive into flink distributi

[GitHub] [flink] bowenli86 opened a new pull request #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution

2019-06-21 Thread GitBox
bowenli86 opened a new pull request #8831: [FLINK-12935][hive] package flink-connector-hive into flink distribution URL: https://github.com/apache/flink/pull/8831 ## What is the purpose of the change This PR adds `flink-connector-hive` jar into Flink distribution to `/opt` dir.

[GitHub] [flink] wuchong commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

2019-06-21 Thread GitBox
wuchong commented on a change in pull request #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#discussion_r296433176 ## File path: docs/concepts/runtime.zh.md ## @@ -26,102 +26,74 @@ unde

[GitHub] [flink] wuchong commented on issue #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese

2019-06-21 Thread GitBox
wuchong commented on issue #8750: [FLINK-11606] Translate the "Distributed Runtime Environment" page in to Chinese URL: https://github.com/apache/flink/pull/8750#issuecomment-504626395 Thanks @Flyangz for the impressive translation. It looks pretty good to me. And also thanks to @klion26

[jira] [Updated] (FLINK-12935) package flink-connector-hive into flink distribution

2019-06-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12935?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12935: - Summary: package flink-connector-hive into flink distribution (was: package flink-connector-hive and so

[jira] [Commented] (FLINK-12936) Support intersect all and minus all to blink planner

2019-06-21 Thread Jingsong Lee (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870046#comment-16870046 ] Jingsong Lee commented on FLINK-12936: -- CC: [~ykt836] [~godfreyhe] > Support inter

[GitHub] [flink] dianfu commented on issue #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl

2019-06-21 Thread GitBox
dianfu commented on issue #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl URL: https://github.com/apache/flink/pull/8815#issuecomment-504625842 @bowenli86 Thanks a lot for the PR. The changes related to the Python

[jira] [Created] (FLINK-12936) Support intersect all and minus all to blink planner

2019-06-21 Thread Jingsong Lee (JIRA)
Jingsong Lee created FLINK-12936: Summary: Support intersect all and minus all to blink planner Key: FLINK-12936 URL: https://issues.apache.org/jira/browse/FLINK-12936 Project: Flink Issue Ty

[jira] [Updated] (FLINK-12933) support "use catalog" and "use database" in SQL CLI

2019-06-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12933: --- Labels: pull-request-available (was: ) > support "use catalog" and "use database" in SQL CL

[GitHub] [flink] flinkbot commented on issue #8830: [FLINK-12933][sql client] support 'use catalog' and 'use database' in SQL CLI

2019-06-21 Thread GitBox
flinkbot commented on issue #8830: [FLINK-12933][sql client] support 'use catalog' and 'use database' in SQL CLI URL: https://github.com/apache/flink/pull/8830#issuecomment-504625682 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community

[GitHub] [flink] bowenli86 opened a new pull request #8830: [FLINK-12933][sql client] support 'use catalog' and 'use database' in SQL CLI

2019-06-21 Thread GitBox
bowenli86 opened a new pull request #8830: [FLINK-12933][sql client] support 'use catalog' and 'use database' in SQL CLI URL: https://github.com/apache/flink/pull/8830 ## What is the purpose of the change This PR adds `USE CATALOG` and `USE DATABASE` commands to SQL CLI. ## Br

[GitHub] [flink] bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

2019-06-21 Thread GitBox
bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#issuecomment-504625422 ``` 01:04:18.649 [ERROR] src/test/java/org/apache/flink/table/catalog/AbstractCatalogTableTest.java:[23,8] (i

[GitHub] [flink] wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje…

2019-06-21 Thread GitBox
wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje… URL: https://github.com/apache/flink/pull/8799#discussion_r296431996 ## File path: docs/dev/projectsetup/java_api_quickstart.zh.md ## @@ -304,51 +297

[GitHub] [flink] wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje…

2019-06-21 Thread GitBox
wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje… URL: https://github.com/apache/flink/pull/8799#discussion_r296431945 ## File path: docs/dev/projectsetup/java_api_quickstart.zh.md ## @@ -101,45 +102

[GitHub] [flink] wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje…

2019-06-21 Thread GitBox
wuchong commented on a change in pull request #8799: [FLINK-11612][chinese-translation,Documentation] Translate the "Proje… URL: https://github.com/apache/flink/pull/8799#discussion_r296432004 ## File path: docs/dev/projectsetup/java_api_quickstart.zh.md ## @@ -304,51 +297

[GitHub] [flink] wuchong commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableT

2019-06-21 Thread GitBox
wuchong commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink URL: https://github.com/apache/flink/pull/8695#discussion_r296431878 ## File path: flink-

[jira] [Commented] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2019-06-21 Thread Jark Wu (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16870018#comment-16870018 ] Jark Wu commented on FLINK-11622: - Hi [~nicholasjiang], I think if you have done this, w

[GitHub] [flink] bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-21 Thread GitBox
bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#issuecomment-504608318 @zjuwangg can you rebase the PR? This is

[GitHub] [flink] bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog

2019-06-21 Thread GitBox
bowenli86 commented on issue #8636: [FLINK-12237][hive]Support Hive table stats related operations in HiveCatalog URL: https://github.com/apache/flink/pull/8636#issuecomment-504608292 @zjuwangg can you rebase the PR? This is

[GitHub] [flink] bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#discussion_r296422285 ## File path: flink-connectors/flink-connector-hive/src/main/java/

[GitHub] [flink] xuefuz commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
xuefuz commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#discussion_r29646 ## File path: flink-connectors/flink-connector-hive/src/main/java/org

[GitHub] [flink] asfgit closed pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
asfgit closed pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813 This is an automated message from the Apache Git Se

[GitHub] [flink] bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#discussion_r296406715 ## File path: flink-connectors/flink-connector-hive/src/main/java/

[GitHub] [flink] bowenli86 commented on issue #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
bowenli86 commented on issue #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#issuecomment-504586395 @xuefuz Thanks for your review! Merging -

[GitHub] [flink] bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
bowenli86 commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#discussion_r296406715 ## File path: flink-connectors/flink-connector-hive/src/main/java/

[jira] [Created] (FLINK-12935) package flink-connector-hive and some flink dependencies into /opt of flink distribution

2019-06-21 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12935: Summary: package flink-connector-hive and some flink dependencies into /opt of flink distribution Key: FLINK-12935 URL: https://issues.apache.org/jira/browse/FLINK-12935 Proj

[jira] [Created] (FLINK-12934) add additional dependencies for flink-connector-hive to connect to standalone hive metastore

2019-06-21 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12934: Summary: add additional dependencies for flink-connector-hive to connect to standalone hive metastore Key: FLINK-12934 URL: https://issues.apache.org/jira/browse/FLINK-12934

[GitHub] [flink] xuefuz commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread GitBox
xuefuz commented on a change in pull request #8813: [FLINK-12891][hive] remove hadoop/hive writable from boundaries of Hive functions and Flink URL: https://github.com/apache/flink/pull/8813#discussion_r296391921 ## File path: flink-connectors/flink-connector-hive/src/main/java/org

[GitHub] [flink] flinkbot commented on issue #8829: [FLINK-12932][table][sql client] support 'show catalogs' and 'show databases' end-2-end in TableEnvironment and SQL CLI

2019-06-21 Thread GitBox
flinkbot commented on issue #8829: [FLINK-12932][table][sql client] support 'show catalogs' and 'show databases' end-2-end in TableEnvironment and SQL CLI URL: https://github.com/apache/flink/pull/8829#issuecomment-504564006 Thanks a lot for your contribution to the Apache Flink project. I'

[jira] [Updated] (FLINK-12932) support 'show catalogs' and 'show databases' functionalities end-2-end in TableEnvironment and SQL CLI

2019-06-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12932: --- Labels: pull-request-available (was: ) > support 'show catalogs' and 'show databases' funct

[GitHub] [flink] bowenli86 opened a new pull request #8829: [FLINK-12932][table][sql client] support 'show catalogs' and 'show databases' end-2-end in TableEnvironment and SQL CLI

2019-06-21 Thread GitBox
bowenli86 opened a new pull request #8829: [FLINK-12932][table][sql client] support 'show catalogs' and 'show databases' end-2-end in TableEnvironment and SQL CLI URL: https://github.com/apache/flink/pull/8829 ## What is the purpose of the change This PR adds 'show catalogs' and 'sh

[jira] [Updated] (FLINK-12932) support 'show catalogs' and 'show databases' functionalities end-2-end in TableEnvironment and SQL CLI

2019-06-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12932: - Summary: support 'show catalogs' and 'show databases' functionalities end-2-end in TableEnvironment and

[jira] [Created] (FLINK-12933) support "use catalog" and "use database" in SQL CLI

2019-06-21 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12933: Summary: support "use catalog" and "use database" in SQL CLI Key: FLINK-12933 URL: https://issues.apache.org/jira/browse/FLINK-12933 Project: Flink Issue Type: Sub-t

[GitHub] [flink] bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

2019-06-21 Thread GitBox
bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#issuecomment-504559623 LGTM, will merge once the build passes This is a

[jira] [Updated] (FLINK-12932) support show catalogs and show databases in TableEnvironment and SQL CLI

2019-06-21 Thread Bowen Li (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12932?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-12932: - Summary: support show catalogs and show databases in TableEnvironment and SQL CLI (was: support show ca

[jira] [Created] (FLINK-12932) support show catalogs and show databases in SQL CLI

2019-06-21 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12932: Summary: support show catalogs and show databases in SQL CLI Key: FLINK-12932 URL: https://issues.apache.org/jira/browse/FLINK-12932 Project: Flink Issue Type: Sub-t

[GitHub] [flink] bowenli86 commented on issue #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl

2019-06-21 Thread GitBox
bowenli86 commented on issue #8815: [FLINK-12918][table][hive] unify GenericCatalogTable, HiveCatalogTable and AbstractCatalogTable into CatalogTableImpl URL: https://github.com/apache/flink/pull/8815#issuecomment-504503047 cc @xuefuz @lirui-apache @zjuwangg @sunjincheng121 @dianfu

[jira] [Created] (FLINK-12931) lint-python.sh cannot find flake8

2019-06-21 Thread Bowen Li (JIRA)
Bowen Li created FLINK-12931: Summary: lint-python.sh cannot find flake8 Key: FLINK-12931 URL: https://issues.apache.org/jira/browse/FLINK-12931 Project: Flink Issue Type: Bug Component

[jira] [Commented] (FLINK-12782) Show formatted timestamp in Watermark Tab of JM Web UI

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12782?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869683#comment-16869683 ] Robert Metzger commented on FLINK-12782: Thanks for this suggestion. The problem

[jira] [Commented] (FLINK-12783) A K8S CRD to manage job lifecycle

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12783?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869681#comment-16869681 ] Robert Metzger commented on FLINK-12783: Thanks a lot for opening a ticket here.

[GitHub] [flink] 1u0 commented on issue #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788

2019-06-21 Thread GitBox
1u0 commented on issue #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788 URL: https://github.com/apache/flink/pull/8828#issuecomment-504493919 CC @tillrohrmann, @sunjincheng121. @knaufk, I've cherry-picked yo

[GitHub] [flink] flinkbot commented on issue #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788

2019-06-21 Thread GitBox
flinkbot commented on issue #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788 URL: https://github.com/apache/flink/pull/8828#issuecomment-504493254 Thanks a lot for your contribution to the Apache Flink project. I'm

[GitHub] [flink] 1u0 opened a new pull request #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788

2019-06-21 Thread GitBox
1u0 opened a new pull request #8828: [hotfix] [end-to-end-tests] fix test_kubernetes_embedded_job.sh and test_docker_embedded_job.sh broken by FLINK-12788 URL: https://github.com/apache/flink/pull/8828 ## What is the purpose of the change Fix test_kubernetes_embedded_job.sh and test

[GitHub] [flink] bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

2019-06-21 Thread GitBox
bowenli86 commented on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#issuecomment-504489764 there are some failures in flink-python's table API tests and flink-table-api-java. Can you fix them? --

[GitHub] [flink] bowenli86 edited a comment on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/…

2019-06-21 Thread GitBox
bowenli86 edited a comment on issue #8785: [FLINK-11480][hive] Create HiveTableFactory that creates TableSource/… URL: https://github.com/apache/flink/pull/8785#issuecomment-504489764 there are some failures in flink-python's table API tests and flink-table-api-java. Can you fix them? @xue

[GitHub] [flink] bowenli86 commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and Overwritabl

2019-06-21 Thread GitBox
bowenli86 commented on a change in pull request #8695: [FLINK-12805][FLINK-12808][FLINK-12809][table-api] Introduce PartitionableTableSource and PartitionableTableSink and OverwritableTableSink URL: https://github.com/apache/flink/pull/8695#discussion_r296308282 ## File path: flin

[jira] [Commented] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

2019-06-21 Thread vinoyang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869639#comment-16869639 ] vinoyang commented on FLINK-12848: -- Hi [~rmetzger] , [~aloyszhang] assigned to me. He i

[GitHub] [flink] mans2singh edited a comment on issue #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics …

2019-06-21 Thread GitBox
mans2singh edited a comment on issue #8668: [FLINK-12784][metrics] Support retention policy for InfluxDB metrics … URL: https://github.com/apache/flink/pull/8668#issuecomment-504250711 @zentol @rmetzger - Please let me know if you can review this request or point me to someone who can advi

[jira] [Updated] (FLINK-12891) remove hadoop/hive writable from boundaries of Hive functions and Flink

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12891?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12891: --- Component/s: Connectors / Hive > remove hadoop/hive writable from boundaries of Hive functio

[jira] [Commented] (FLINK-12909) add try catch when find a unique file name for the spilling channel

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12909?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869619#comment-16869619 ] Robert Metzger commented on FLINK-12909: Thanks a lot for opening a JIRA ticket

[jira] [Updated] (FLINK-12917) support complex type of array, map, struct for Hive functions

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12917: --- Component/s: Connectors / Hive > support complex type of array, map, struct for Hive functio

[jira] [Commented] (FLINK-12917) support complex type of array, map, struct for Hive functions

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869617#comment-16869617 ] Robert Metzger commented on FLINK-12917: Hey [~phoenixjiangnan], thanks a lot fo

[jira] [Updated] (FLINK-12777) Support CheckpointBarrierHandler in StreamTwoInputSelectableProcessor

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12777: --- Component/s: Runtime / Task > Support CheckpointBarrierHandler in StreamTwoInputSelectablePr

[jira] [Commented] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869616#comment-16869616 ] Robert Metzger commented on FLINK-12848: [~yanghua] why are you assigned to this

[jira] [Updated] (FLINK-12848) Method equals() in RowTypeInfo should consider fieldsNames

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12848: --- Component/s: Table SQL / Planner > Method equals() in RowTypeInfo should consider fieldsName

[jira] [Updated] (FLINK-12733) Expose Rest API for TERMINATE/SUSPEND Job with Checkpoint

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12733: --- Component/s: Runtime / Coordination > Expose Rest API for TERMINATE/SUSPEND Job with Checkpo

[jira] [Updated] (FLINK-12744) ML common parameters

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12744?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12744: --- Component/s: Library / Machine Learning > ML common parameters > > >

[jira] [Commented] (FLINK-12731) Load shuffle service implementations from plugin manager

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869598#comment-16869598 ] Robert Metzger commented on FLINK-12731: Hey [~azagrebin], thanks a lot for open

[jira] [Updated] (FLINK-12731) Load shuffle service implementations from plugin manager

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12731: --- Component/s: Runtime / Coordination > Load shuffle service implementations from plugin manag

[jira] [Updated] (FLINK-12881) Add more functionalities for ML Params and ParamInfo class

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12881?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12881: --- Component/s: Library / Machine Learning > Add more functionalities for ML Params and ParamIn

[jira] [Updated] (FLINK-12745) Sparse and dense vector class, and dense matrix class with basic operations.

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12745?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12745: --- Component/s: Library / Machine Learning > Sparse and dense vector class, and dense matrix cl

[jira] [Commented] (FLINK-12745) Sparse and dense vector class, and dense matrix class with basic operations.

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869596#comment-16869596 ] Robert Metzger commented on FLINK-12745: Hey [~xuyang1706], thanks a lot for ope

[jira] [Updated] (FLINK-12929) scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12929?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-12929: --- Component/s: API / Type Serialization System API / Scala > scala.StreamExec

[jira] [Created] (FLINK-12930) Update Chinese "how to contribute" pages

2019-06-21 Thread Robert Metzger (JIRA)
Robert Metzger created FLINK-12930: -- Summary: Update Chinese "how to contribute" pages Key: FLINK-12930 URL: https://issues.apache.org/jira/browse/FLINK-12930 Project: Flink Issue Type: Task

[GitHub] [flink] flinkbot commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs

2019-06-21 Thread GitBox
flinkbot commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs URL: https://github.com/apache/flink/pull/8827#issuecomment-504463580 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review your pull request. We wi

[jira] [Created] (FLINK-12929) scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation

2019-06-21 Thread Fabio Lombardelli (JIRA)
Fabio Lombardelli created FLINK-12929: - Summary: scala.StreamExecutionEnvironment.addSource does not propagate TypeInformation Key: FLINK-12929 URL: https://issues.apache.org/jira/browse/FLINK-12929

[jira] [Updated] (FLINK-12928) Remove old Flink ML docs

2019-06-21 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12928?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-12928: --- Labels: pull-request-available (was: ) > Remove old Flink ML docs > ---

[GitHub] [flink] sjwiesman commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs

2019-06-21 Thread GitBox
sjwiesman commented on issue #8827: [FLINK-12928][docs] Remove old Flink ML docs URL: https://github.com/apache/flink/pull/8827#issuecomment-504462842 cc @rmetzger This is an automated message from the Apache Git Service. To

[GitHub] [flink] sjwiesman opened a new pull request #8827: [FLINK-12928][docs] Remove old Flink ML docs

2019-06-21 Thread GitBox
sjwiesman opened a new pull request #8827: [FLINK-12928][docs] Remove old Flink ML docs URL: https://github.com/apache/flink/pull/8827 ## What is the purpose of the change The old Flink ML library has been removed so we should also remove the documentation. Existing users can use do

[GitHub] [flink] dawidwys closed pull request #8764: [FLINK-12798][table-planner][table-api-java] Port TableEnvironment to table-api-java module

2019-06-21 Thread GitBox
dawidwys closed pull request #8764: [FLINK-12798][table-planner][table-api-java] Port TableEnvironment to table-api-java module URL: https://github.com/apache/flink/pull/8764 This is an automated message from the Apache Gi

[jira] [Created] (FLINK-12928) Remove old Flink ML docs

2019-06-21 Thread Seth Wiesman (JIRA)
Seth Wiesman created FLINK-12928: Summary: Remove old Flink ML docs Key: FLINK-12928 URL: https://issues.apache.org/jira/browse/FLINK-12928 Project: Flink Issue Type: Improvement Co

[jira] [Resolved] (FLINK-12605) Describe new contribution process

2019-06-21 Thread Robert Metzger (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12605?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger resolved FLINK-12605. Resolution: Fixed Merged in https://github.com/apache/flink-web/commit/ff4c6dc0d560ada8b7

[jira] [Assigned] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2019-06-21 Thread Nicholas Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Nicholas Jiang reassigned FLINK-11622: -- Assignee: Jasper Yue (was: Nicholas Jiang) > Translate the "Command-Line Interface"

[jira] [Commented] (FLINK-11622) Translate the "Command-Line Interface" page into Chinese

2019-06-21 Thread Nicholas Jiang (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-11622?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16869506#comment-16869506 ] Nicholas Jiang commented on FLINK-11622: [~jark]Yes,I have already translated th

[jira] [Closed] (FLINK-12868) Yarn and Mesos clusters can not be deployed if plugins dir does not exist

2019-06-21 Thread Piotr Nowojski (JIRA)
[ https://issues.apache.org/jira/browse/FLINK-12868?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-12868. -- Resolution: Fixed > Yarn and Mesos clusters can not be deployed if plugins dir does not exist

[GitHub] [flink] pnowojski merged pull request #8759: [FLINK-12868][yarn] Fix yarn cluster can not be deployed if plugins dir does not exist

2019-06-21 Thread GitBox
pnowojski merged pull request #8759: [FLINK-12868][yarn] Fix yarn cluster can not be deployed if plugins dir does not exist URL: https://github.com/apache/flink/pull/8759 This is an automated message from the Apache Git Serv

  1   2   3   >