[GitHub] [flink] flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#issuecomment-519355742 ## CI report: * b2432f2b0e522f84bf3029dc80cf46a00d13ea54 : FAILURE

[GitHub] [flink] KurtYoung commented on issue #9417: [FLINK-13688][hive] Limit the parallelism/memory of HiveCatalogUseBlinkITCase

KurtYoung commented on issue #9417: [FLINK-13688][hive] Limit the parallelism/memory of HiveCatalogUseBlinkITCase URL: https://github.com/apache/flink/pull/9417#issuecomment-520695972 How about we use a pre configured mini cluster instead of lower the memory request? Because it's not 100%

[GitHub] [flink] flinkbot edited a comment on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

flinkbot edited a comment on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types URL: https://github.com/apache/flink/pull/9423#issuecomment-520678993 ## CI report: * 0c023712b638e15c14210e41d6a1119e3e508942 :

[GitHub] [flink] flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

flinkbot edited a comment on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#issuecomment-519355742 ## CI report: * b2432f2b0e522f84bf3029dc80cf46a00d13ea54 : FAILURE

[GitHub] [flink] lirui-apache commented on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

lirui-apache commented on issue #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#issuecomment-520683087 @xuefuz PR updated to test with non-zero-scale decimals. Please have a look. Thanks.

[GitHub] [flink] wuchong commented on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking

wuchong commented on issue #9236: [FLINK-13283][FLINK-13490][jdbc] Fix JDBC connectors with DataTypes.DATE/TIME/TIMESTAMP support and null checking URL: https://github.com/apache/flink/pull/9236#issuecomment-520682566 Commit f308edb00ca44c50fc801cfdbb7c28ee543ba1b9 looks good to me.

[GitHub] [flink] wuchong commented on issue #9418: [FLINK-13690]Fix JDBC LookupFunction getFieldFromResultSet BUG

wuchong commented on issue #9418: [FLINK-13690]Fix JDBC LookupFunction getFieldFromResultSet BUG URL: https://github.com/apache/flink/pull/9418#issuecomment-520680958 Will close this because #9236 has covered this. This is

[jira] [Closed] (FLINK-13690) Connectors/JDBC LookupFunction getFieldFromResultSet BUG

[ https://issues.apache.org/jira/browse/FLINK-13690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu closed FLINK-13690. --- Resolution: Duplicate hi [~molsion], there is already an issue to track this problem FLINK-13490 and a

[GitHub] [flink] wuchong closed pull request #9418: [FLINK-13690]Fix JDBC LookupFunction getFieldFromResultSet BUG

wuchong closed pull request #9418: [FLINK-13690]Fix JDBC LookupFunction getFieldFromResultSet BUG URL: https://github.com/apache/flink/pull/9418 This is an automated message from the Apache Git Service. To respond to the

[jira] [Commented] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905793#comment-16905793 ] Jark Wu commented on FLINK-13663: - +1 to cache distributions. Even to share the distribution across

[GitHub] [flink] flinkbot commented on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

flinkbot commented on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types URL: https://github.com/apache/flink/pull/9423#issuecomment-520678993 ## CI report: * 0c023712b638e15c14210e41d6a1119e3e508942 : PENDING

[GitHub] [flink] flinkbot commented on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

flinkbot commented on issue #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types URL: https://github.com/apache/flink/pull/9423#issuecomment-520678269 Thanks a lot for your contribution to the Apache Flink project. I'm the

[jira] [Updated] (FLINK-13699) Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

[ https://issues.apache.org/jira/browse/FLINK-13699?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13699: --- Labels: pull-request-available (was: ) > Fix TableFactory doesn't work with DDL when

[GitHub] [flink] wuchong opened a new pull request #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

wuchong opened a new pull request #9423: [FLINK-13699][table-api] Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types URL: https://github.com/apache/flink/pull/9423 The solution is encode DataTypes.TIMESTAMP() as "TIMESTAMP" when translating to properties.

[jira] [Created] (FLINK-13699) Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types

Jark Wu created FLINK-13699: --- Summary: Fix TableFactory doesn't work with DDL when containing TIMESTAMP/DATE/TIME types Key: FLINK-13699 URL: https://issues.apache.org/jira/browse/FLINK-13699 Project:

[jira] [Commented] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905758#comment-16905758 ] Kurt Young commented on FLINK-13663: +1 to find a way to cache downloaded distributions. Not only

[jira] [Commented] (FLINK-9412) Add a REST-based SQL Client Gateway

[ https://issues.apache.org/jira/browse/FLINK-9412?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905739#comment-16905739 ] Simon Su commented on FLINK-9412: - Hi Timo, where is the design document link for this Jira ?  > Add a

[GitHub] [flink] yiduwangkai commented on issue #9164: [FLINK-12894][doc][Chinese-translation]add Chinese documentation of how to configure and use catalogs in SQL CLI

yiduwangkai commented on issue #9164: [FLINK-12894][doc][Chinese-translation]add Chinese documentation of how to configure and use catalogs in SQL CLI URL: https://github.com/apache/flink/pull/9164#issuecomment-520654288 > Hi @yiduwangkai , can you rebase this PR? Ok

[GitHub] [flink] yiduwangkai commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs

yiduwangkai commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs URL: https://github.com/apache/flink/pull/9163#issuecomment-520654102 > can you rebase this PR? oK This is an automated message

[GitHub] [flink] yiduwangkai commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs

yiduwangkai commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs URL: https://github.com/apache/flink/pull/9163#issuecomment-520654217 OK Bowen L 于2019年8月13日周二 上午2:36写道： > Hi @yiduwangkai , can you rebase this PR?

[GitHub] [flink] bowenli86 closed pull request #9137: [FLINK-13276][hive][doc] write documentation and quickstart for Flink-Hive integration

bowenli86 closed pull request #9137: [FLINK-13276][hive][doc] write documentation and quickstart for Flink-Hive integration URL: https://github.com/apache/flink/pull/9137 This is an automated message from the Apache Git

[GitHub] [flink] bowenli86 commented on issue #9137: [FLINK-13276][hive][doc] write documentation and quickstart for Flink-Hive integration

bowenli86 commented on issue #9137: [FLINK-13276][hive][doc] write documentation and quickstart for Flink-Hive integration URL: https://github.com/apache/flink/pull/9137#issuecomment-520634335 merged in 1.10.0: 73c4e107fcec2ff1ed4a75735b79405571afd525 1.9.0:

[GitHub] [flink] bowenli86 commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

bowenli86 commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422#issuecomment-520634020 as you may guess, I'm so in favor of this PR! just to double check - should classes be deleted after one

[GitHub] [flink] bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217#discussion_r313169738 ## File path: docs/dev/batch/connectors.md ## @@ -217,4 +217,21 @@ The example shows how

[GitHub] [flink] bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217#discussion_r313169335 ## File path: docs/dev/batch/connectors.md ## @@ -217,4 +217,21 @@ The example shows how

[GitHub] [flink] bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217#discussion_r313169515 ## File path: docs/dev/batch/connectors.md ## @@ -217,4 +217,21 @@ The example shows how

[GitHub] [flink] bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217#discussion_r313169335 ## File path: docs/dev/batch/connectors.md ## @@ -217,4 +217,21 @@ The example shows how

[GitHub] [flink] bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink

bowenli86 commented on a change in pull request #9217: [FLINK-13277][hive] add documentation of Hive source/sink URL: https://github.com/apache/flink/pull/9217#discussion_r313169738 ## File path: docs/dev/batch/connectors.md ## @@ -217,4 +217,21 @@ The example shows how

[jira] [Updated] (FLINK-13643) Document the workaround for users with a different minor Hive version

[ https://issues.apache.org/jira/browse/FLINK-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13643: - Component/s: (was: Table SQL / API) > Document the workaround for users with a different minor Hive

[jira] [Assigned] (FLINK-13643) Document the workaround for users with a different minor Hive version

[ https://issues.apache.org/jira/browse/FLINK-13643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13643: Assignee: Terry Wang > Document the workaround for users with a different minor Hive version >

[jira] [Assigned] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13534: Assignee: Rui Li > Unable to query Hive table with decimal column >

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13534: - Fix Version/s: 1.9.0 > Unable to query Hive table with decimal column >

[jira] [Updated] (FLINK-13534) Unable to query Hive table with decimal column

[ https://issues.apache.org/jira/browse/FLINK-13534?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13534: - Affects Version/s: 1.9.0 > Unable to query Hive table with decimal column >

[GitHub] [flink] bowenli86 commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs

bowenli86 commented on issue #9163: [FLINK-13086]add Chinese documentation for catalogs URL: https://github.com/apache/flink/pull/9163#issuecomment-520544198 Hi @yiduwangkai , can you rebase this PR? This is an automated

[GitHub] [flink] bowenli86 commented on issue #9164: [FLINK-12894][doc][Chinese-translation]add Chinese documentation of how to configure and use catalogs in SQL CLI

bowenli86 commented on issue #9164: [FLINK-12894][doc][Chinese-translation]add Chinese documentation of how to configure and use catalogs in SQL CLI URL: https://github.com/apache/flink/pull/9164#issuecomment-520544159 Hi @yiduwangkai , can you rebase this PR?

[jira] [Commented] (FLINK-7289) Memory allocation of RocksDB can be problematic in container environments

[ https://issues.apache.org/jira/browse/FLINK-7289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905473#comment-16905473 ] Mike Kaplinskiy commented on FLINK-7289: [~aiyangar] I was testing on an unreleased build of 1.9

[jira] [Closed] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13517. Resolution: Fixed merged in master: 6a63b34463ce9fd1f66b0a26a599423d6500ee17 in 1.9.0:

[GitHub] [flink] asfgit closed pull request #9308: [FLINK-13517][docs][hive] Restructure Hive Catalog documentation

asfgit closed pull request #9308: [FLINK-13517][docs][hive] Restructure Hive Catalog documentation URL: https://github.com/apache/flink/pull/9308 This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-13517) Restructure Hive Catalog documentation

[ https://issues.apache.org/jira/browse/FLINK-13517?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13517: - Fix Version/s: 1.9.0 > Restructure Hive Catalog documentation > --

[jira] [Updated] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13653: - Fix Version/s: 1.9.0 > ResultStore should avoid using RowTypeInfo when creating a result >

[jira] [Closed] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li closed FLINK-13526. Resolution: Fixed merged in master: a8fb572054c5f2294b46200d64729bc3e20c301b 1.9.0:

[jira] [Assigned] (FLINK-13653) ResultStore should avoid using RowTypeInfo when creating a result

[ https://issues.apache.org/jira/browse/FLINK-13653?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13653: Assignee: Rui Li > ResultStore should avoid using RowTypeInfo when creating a result >

[GitHub] [flink] asfgit closed pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data…

asfgit closed pull request #9399: [FLINK-13526][sql-client] Switching to a non existing catalog or data… URL: https://github.com/apache/flink/pull/9399 This is an automated message from the Apache Git Service. To respond to

[jira] [Assigned] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li reassigned FLINK-13526: Assignee: Rui Li > Switching to a non existing catalog or database crashes sql-client >

[jira] [Updated] (FLINK-13526) Switching to a non existing catalog or database crashes sql-client

[ https://issues.apache.org/jira/browse/FLINK-13526?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-13526: - Fix Version/s: 1.9.0 > Switching to a non existing catalog or database crashes sql-client >

[jira] [Commented] (FLINK-13663) SQL Client end-to-end test for modern Kafka failed on Travis

[ https://issues.apache.org/jira/browse/FLINK-13663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905441#comment-16905441 ] Alex commented on FLINK-13663: -- FYI, the {{curl}} retries were added as an attempt to address the issue

[GitHub] [flink] walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

walterddr commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r313047545 ## File path:

[GitHub] [flink] xuefuz commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column

xuefuz commented on a change in pull request #9390: [FLINK-13534][hive] Unable to query Hive table with decimal column URL: https://github.com/apache/flink/pull/9390#discussion_r313047538 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

flinkbot edited a comment on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422#issuecomment-520477677 ## CI report: * 355a7706b108371f31efe68f181c3dbeceed06d5 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields

flinkbot edited a comment on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields URL: https://github.com/apache/flink/pull/9421#issuecomment-520459678 ## CI report: * 780d837db46ccdfccd428c16334e81802208179a : FAILURE

[GitHub] [flink] ex00 commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

ex00 commented on issue #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#issuecomment-520487910 > Do you have any benchmark or performance tests? it would be helpful for understanding

[jira] [Commented] (FLINK-13417) Bump Zookeeper to 3.5.5

[ https://issues.apache.org/jira/browse/FLINK-13417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905334#comment-16905334 ] Stephan Ewen commented on FLINK-13417: -- The {{flink-jepsen}} readme has some pointers to get

[GitHub] [flink] flinkbot edited a comment on issue #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li…

flinkbot edited a comment on issue #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li… URL: https://github.com/apache/flink/pull/9387#issuecomment-519258700 ## CI report: * 1bb228a80349e46677aa07d880a2fab436384ee3 : SUCCESS

[GitHub] [flink] ex00 commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

ex00 commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r312994051 ## File path:

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE

[GitHub] [flink] flinkbot commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

flinkbot commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422#issuecomment-520477677 ## CI report: * 355a7706b108371f31efe68f181c3dbeceed06d5 : PENDING

[GitHub] [flink] flinkbot commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

flinkbot commented on issue #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422#issuecomment-520473723 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to review

[jira] [Updated] (FLINK-13697) Drop deprecated ExternalCatalog API

[ https://issues.apache.org/jira/browse/FLINK-13697?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13697: --- Labels: pull-request-available (was: ) > Drop deprecated ExternalCatalog API >

[GitHub] [flink] dawidwys opened a new pull request #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API

dawidwys opened a new pull request #9422: [FLINK-13697][table-api] Removed deprecated ExternalCatalog API URL: https://github.com/apache/flink/pull/9422 ## What is the purpose of the change Drop the deprecated ExternalCatalog API and simplify the calls that can be simplified due

[jira] [Comment Edited] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904794#comment-16904794 ] Jark Wu edited comment on FLINK-13562 at 8/12/19 3:03 PM: -- master:

[jira] [Updated] (FLINK-13562) throws exception when FlinkRelMdColumnInterval meets two stage stream group aggregate

[ https://issues.apache.org/jira/browse/FLINK-13562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13562: Fix Version/s: (was: 1.9.0) 1.9.1 > throws exception when FlinkRelMdColumnInterval

[jira] [Updated] (FLINK-13563) TumblingGroupWindow should implement toString method

[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-13563: Fix Version/s: (was: 1.9.0) 1.9.1 > TumblingGroupWindow should implement toString

[jira] [Comment Edited] (FLINK-13563) TumblingGroupWindow should implement toString method

[ https://issues.apache.org/jira/browse/FLINK-13563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16904809#comment-16904809 ] Jark Wu edited comment on FLINK-13563 at 8/12/19 3:02 PM: -- master:

[GitHub] [flink] flinkbot commented on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields

flinkbot commented on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields URL: https://github.com/apache/flink/pull/9421#issuecomment-520459678 ## CI report: * 780d837db46ccdfccd428c16334e81802208179a : PENDING

[GitHub] [flink] flinkbot commented on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields

flinkbot commented on issue #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields URL: https://github.com/apache/flink/pull/9421#issuecomment-520456633 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the

[jira] [Updated] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13083: - Fix Version/s: 1.9.1 > Various improvements PubSub Connector >

[jira] [Updated] (FLINK-13230) Retry acknowledgement calls

[ https://issues.apache.org/jira/browse/FLINK-13230?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13230: - Fix Version/s: 1.9.1 > Retry acknowledgement calls > --- > >

[jira] [Updated] (FLINK-13231) Add a ratelimiter to pubsub source

[ https://issues.apache.org/jira/browse/FLINK-13231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jiangjie Qin updated FLINK-13231: - Fix Version/s: 1.9.1 > Add a ratelimiter to pubsub source > --

[jira] [Updated] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

[ https://issues.apache.org/jira/browse/FLINK-13539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-13539: --- Labels: pull-request-available (was: ) > DDL do not support CSV tableFactory because CSV

[GitHub] [flink] wuchong opened a new pull request #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields

wuchong opened a new pull request #9421: [FLINK-13539][table-api] Improve CSV table factory doesn't need to require format.fields URL: https://github.com/apache/flink/pull/9421 ## What is the purpose of the change Currently, the CSV table factory requires

[jira] [Closed] (FLINK-13473) Add GroupWindowed FlatAggregate support to stream Table API(blink planner), i.e, align with flink planner

[ https://issues.apache.org/jira/browse/FLINK-13473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] sunjincheng closed FLINK-13473. --- Resolution: Fixed Fix Version/s: 1.10.0 Fixed in master: 

[GitHub] [flink] asfgit closed pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

asfgit closed pull request #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396 This is an automated message from the Apache Git

[jira] [Updated] (FLINK-13588) StreamTask.handleAsyncException throws away the exception cause

[ https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Robert Metzger updated FLINK-13588: --- Component/s: Runtime / Task > StreamTask.handleAsyncException throws away the exception

[jira] [Commented] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

[ https://issues.apache.org/jira/browse/FLINK-13539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905260#comment-16905260 ] Jark Wu commented on FLINK-13539: - As discussed with [~godfreyhe], I will take this issue. > DDL do

[jira] [Assigned] (FLINK-13539) DDL do not support CSV tableFactory because CSV require format.fields

[ https://issues.apache.org/jira/browse/FLINK-13539?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu reassigned FLINK-13539: --- Assignee: Jark Wu (was: godfrey he) > DDL do not support CSV tableFactory because CSV require

[GitHub] [flink] JingsongLi commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

JingsongLi commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-520449856 LGTM This is an automated

[GitHub] [flink] sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-520449470 Thanks for the review @JingsongLi @wuchong @aljoscha @flinkbot approve all Merging...

[GitHub] [flink] flinkbot edited a comment on issue #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li…

flinkbot edited a comment on issue #9387: [FLINK-13231] [pubsub] Replace Max outstanding acknowledgement ids li… URL: https://github.com/apache/flink/pull/9387#issuecomment-519258700 ## CI report: * 1bb228a80349e46677aa07d880a2fab436384ee3 : SUCCESS

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE

[jira] [Commented] (FLINK-12122) Spread out tasks evenly across all available registered TaskManagers

[ https://issues.apache.org/jira/browse/FLINK-12122?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905243#comment-16905243 ] Ben La Monica commented on FLINK-12122: --- [~till.rohrmann], I realize that you're busy, is there

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE

[GitHub] [flink] flinkbot edited a comment on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc

flinkbot edited a comment on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc URL: https://github.com/apache/flink/pull/9420#issuecomment-520400032 ## CI report: * bd7d3b7b96f659c18fff2d18cccdedec3e0789f6 : SUCCESS

[GitHub] [flink] 1u0 commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

1u0 commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r312910804 ## File path: flink-end-to-end-tests/test-scripts/common.sh

[GitHub] [flink] pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#discussion_r312896295 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#discussion_r312896295 ## File path:

[GitHub] [flink] pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

pnowojski commented on a change in pull request #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#discussion_r312903521 ## File path:

[GitHub] [flink] pnowojski removed a comment on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

pnowojski removed a comment on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#issuecomment-520410398 Thanks for the contribution @sunhaibotb. I really liked how did you structure the

[GitHub] [flink] pnowojski commented on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one

pnowojski commented on issue #9252: [FLINK-13051][runtime] Replace the non-selectable stream task with the input-selectable one URL: https://github.com/apache/flink/pull/9252#issuecomment-520410398 Thanks for the contribution @sunhaibotb. I really liked how did you structure the PR, it

[GitHub] [flink] flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

flinkbot edited a comment on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-519562054 ## CI report: * 9a5651f1dee8a7d5da17bc4e54831af55d7002c4 : FAILURE

[GitHub] [flink] ex00 commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations.

ex00 commented on a change in pull request #8631: [FLINK-12745][ml] add sparse and dense vector class, and dense matrix class with basic operations. URL: https://github.com/apache/flink/pull/8631#discussion_r312903021 ## File path:

[GitHub] [flink] sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner

sunjincheng121 commented on issue #9396: [FLINK-13473][table-blink] Add stream Windowed FlatAggregate support for blink planner URL: https://github.com/apache/flink/pull/9396#issuecomment-520408075 Hi @wuchong and @aljoscha, thanks a lot for your nice review.  Glad to see the nice

[GitHub] [flink] GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r312885872 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r312899650 ## File path:

[GitHub] [flink] GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r312893665 ## File path: flink-end-to-end-tests/test-scripts/common.sh

[GitHub] [flink] GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r31282 ## File path: flink-end-to-end-tests/test-scripts/common.sh

[GitHub] [flink] GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries

GJL commented on a change in pull request #9419: [FLINK-13599][e2e tests] Harden test_streaming_kinesis with kinesalite docker image download/run retries URL: https://github.com/apache/flink/pull/9419#discussion_r312887523 ## File path:

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905133#comment-16905133 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] I've assigned you the two tickets. Can you please

[jira] [Commented] (FLINK-13083) Various improvements PubSub Connector

[ https://issues.apache.org/jira/browse/FLINK-13083?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16905130#comment-16905130 ] Jiangjie Qin commented on FLINK-13083: -- [~Xeli] Thanks for submitting the patch. I think we should

[GitHub] [flink] flinkbot commented on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc

flinkbot commented on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc URL: https://github.com/apache/flink/pull/9420#issuecomment-520400032 ## CI report: * bd7d3b7b96f659c18fff2d18cccdedec3e0789f6 : PENDING

[GitHub] [flink] flinkbot commented on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc

flinkbot commented on issue #9420: [FLINK-13444][doc] Add BucketingSink deprecation note in Chinese doc URL: https://github.com/apache/flink/pull/9420#issuecomment-520398306 Thanks a lot for your contribution to the Apache Flink project. I'm the @flinkbot. I help the community to

  1   2   3   >