[GitHub] [flink] flinkbot edited a comment on issue #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11871: URL: https://github.com/apache/flink/pull/11871#issuecomment-618188399 ## CI report: * ac40522a46f3f22f747e1196d45d91543cc6a87a Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161564583) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11872: URL: https://github.com/apache/flink/pull/11872#issuecomment-618188449 ## CI report: * 6ee34138baa74abb4b7c1f71ea98e360340a2b8c Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161564598) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11749: [FLINK-16669][python][table] Support Python UDF in SQL function DDL.

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11749: URL: https://github.com/apache/flink/pull/11749#issuecomment-613901508 ## CI report: * e3255e2c9750fa3c457bc853849c5c02ad463c2d Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161384844) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 5f91592c6f010dbb52511c54568c5d3c82082433 UNKNOWN * 13dab75e74ed139bb8802dcf2de0ef87464f046b Travis:

[jira] [Updated] (FLINK-17335) JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1

2020-04-22 Thread yutao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] yutao updated FLINK-17335: -- Description: JDBCUpsertTableSink build = JDBCUpsertTableSink.builder()   .setTableSchema(results.getSchema())

[jira] [Created] (FLINK-17335) JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1

2020-04-22 Thread yutao (Jira)
yutao created FLINK-17335: - Summary: JDBCUpsertTableSink Upsert mysql exception No value specified for parameter 1 Key: FLINK-17335 URL: https://issues.apache.org/jira/browse/FLINK-17335 Project: Flink

[GitHub] [flink] flinkbot commented on issue #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

2020-04-22 Thread GitBox
flinkbot commented on issue #11872: URL: https://github.com/apache/flink/pull/11872#issuecomment-618188449 ## CI report: * 6ee34138baa74abb4b7c1f71ea98e360340a2b8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * c4c6356dfbd46e26171b6128482eecab13fe7d96 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161563127) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b0730cb05f9d77f9d34ab7221020931ef5d2532d Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * 28223e277ee06677a7c973300e3e1c85902874fd Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161563117) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11766: URL: https://github.com/apache/flink/pull/11766#issuecomment-614431072 ## CI report: * 3d58ff0f0f2f4caac54b5bc38dac153ae4f4ecf2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160495187) Azure:

[GitHub] [flink] flinkbot commented on issue #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

2020-04-22 Thread GitBox
flinkbot commented on issue #11871: URL: https://github.com/apache/flink/pull/11871#issuecomment-618188399 ## CI report: * ac40522a46f3f22f747e1196d45d91543cc6a87a UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * d7d37b26b6dc41871ee56900f8e9b6ed16b3fcf6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161549162) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 9c3d9347f989a84184f598190271f5e0b4703ba0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161547778) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] flinkbot commented on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

2020-04-22 Thread GitBox
flinkbot commented on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * c4c6356dfbd46e26171b6128482eecab13fe7d96 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] flinkbot commented on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

2020-04-22 Thread GitBox
flinkbot commented on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618183108 ## CI report: * 28223e277ee06677a7c973300e3e1c85902874fd UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot run

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * d7d37b26b6dc41871ee56900f8e9b6ed16b3fcf6 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161549162) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11766: URL: https://github.com/apache/flink/pull/11766#issuecomment-614431072 ## CI report: * 3d58ff0f0f2f4caac54b5bc38dac153ae4f4ecf2 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160495187) Azure:

[GitHub] [flink] flinkbot commented on issue #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

2020-04-22 Thread GitBox
flinkbot commented on issue #11871: URL: https://github.com/apache/flink/pull/11871#issuecomment-618182406 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 will use this comment to track the progress

[jira] [Assigned] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17289: Assignee: Li Ying > Translate tutorials/etl.md to chinese >

[GitHub] [flink] flinkbot commented on issue #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

2020-04-22 Thread GitBox
flinkbot commented on issue #11872: URL: https://github.com/apache/flink/pull/11872#issuecomment-618182391 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 will use this comment to track the progress

[jira] [Commented] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090254#comment-17090254 ] Jingsong Lee commented on FLINK-17289: -- [~lyee] Assigned. > Translate tutorials/etl.md to chinese

[jira] [Comment Edited] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-22 Thread Li Ying (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090188#comment-17090188 ] Li Ying edited comment on FLINK-17289 at 4/23/20, 5:11 AM: --- Hi David, I'd like

[jira] [Commented] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090249#comment-17090249 ] Jingsong Lee commented on FLINK-17334: -- Hi [~royruan] thanks for reporting. Can you provide more

[jira] [Updated] (FLINK-17333) add doc for "create ddl"

2020-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17333: --- Labels: pull-request-available (was: ) > add doc for "create ddl" >

[jira] [Updated] (FLINK-17333) add doc for 'create catalog' ddl

2020-04-22 Thread Bowen Li (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bowen Li updated FLINK-17333: - Summary: add doc for 'create catalog' ddl (was: add doc for "create ddl") > add doc for 'create

[jira] [Closed] (FLINK-17209) Allow users to specify dialect in sql-client yaml

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee closed FLINK-17209. Resolution: Fixed master: aa489269a1429f25136765af94b05d10ef5b7fd3 > Allow users to specify

[jira] [Assigned] (FLINK-17198) DDL and DML compatibility for Hive connector

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17198?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17198: Assignee: Rui Li > DDL and DML compatibility for Hive connector >

[jira] [Updated] (FLINK-17227) Remove Datadog relocations

2020-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17227: --- Labels: pull-request-available (was: ) > Remove Datadog relocations >

[jira] [Updated] (FLINK-17209) Allow users to specify dialect in sql-client yaml

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee updated FLINK-17209: - Fix Version/s: 1.11.0 > Allow users to specify dialect in sql-client yaml >

[GitHub] [flink] molsionmo opened a new pull request #11872: [FLINK-17227][metrics]Remove Datadog shade-plugin relocations

2020-04-22 Thread GitBox
molsionmo opened a new pull request #11872: URL: https://github.com/apache/flink/pull/11872 ## What is the purpose of the change *Now that we load the Datadog reporters as plugins we should remove the shade-plugin configuration/relocations.* ## Verifying this change

[jira] [Assigned] (FLINK-17209) Allow users to specify dialect in sql-client yaml

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17209?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee reassigned FLINK-17209: Assignee: Rui Li > Allow users to specify dialect in sql-client yaml >

[GitHub] [flink] bowenli86 opened a new pull request #11871: [FLINK-17333][doc] add doc for 'create catalog' ddl

2020-04-22 Thread GitBox
bowenli86 opened a new pull request #11871: URL: https://github.com/apache/flink/pull/11871 ## What is the purpose of the change add doc for "create catalog" ddl ## Brief change log ## Verifying this change This change is a trivial rework / code cleanup without

[GitHub] [flink] bowenli86 commented on issue #11766: [FLINK-16812][jdbc] support array types in PostgresRowConverter

2020-04-22 Thread GitBox
bowenli86 commented on issue #11766: URL: https://github.com/apache/flink/pull/11766#issuecomment-618180474 @wuchong addressed comments. pls take another look This is an automated message from the Apache Git Service. To

[GitHub] [flink] bowenli86 commented on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
bowenli86 commented on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-618180336 @wuchong can you take another look? This is an automated message from the Apache Git Service. To respond to the

[jira] [Updated] (FLINK-17334) Flink does not support HIVE UDFs with primitive return types

2020-04-22 Thread xin.ruan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17334?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xin.ruan updated FLINK-17334: - Summary: Flink does not support HIVE UDFs with primitive return types (was: Flink does not support

[jira] [Created] (FLINK-17334) Flink does not support UDFs with primitive return types

2020-04-22 Thread xin.ruan (Jira)
xin.ruan created FLINK-17334: Summary: Flink does not support UDFs with primitive return types Key: FLINK-17334 URL: https://issues.apache.org/jira/browse/FLINK-17334 Project: Flink Issue Type:

[jira] [Resolved] (FLINK-17138) LocalExecutorITCase.testParameterizedTypes failed on travis

2020-04-22 Thread Jingsong Lee (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17138?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jingsong Lee resolved FLINK-17138. -- Resolution: Fixed master: 27d1a48cc5c1ef7baf506d7c0db4d01ebdca6b70 Feel free to re-open if

[GitHub] [flink] flinkbot commented on issue #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

2020-04-22 Thread GitBox
flinkbot commented on issue #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618179221 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 will use this comment to track the progress

[jira] [Created] (FLINK-17333) add doc for "create ddl"

2020-04-22 Thread Bowen Li (Jira)
Bowen Li created FLINK-17333: Summary: add doc for "create ddl" Key: FLINK-17333 URL: https://issues.apache.org/jira/browse/FLINK-17333 Project: Flink Issue Type: Improvement

[GitHub] [flink] hehuiyuan opened a new pull request #11870: [FLINK-17117][SQL-Blink]Remove useless cast class code for processElement method in SourceCon…

2020-04-22 Thread GitBox
hehuiyuan opened a new pull request #11870: URL: https://github.com/apache/flink/pull/11870 ![image](https://user-images.githubusercontent.com/18002496/80060767-f1024080-8561-11ea-9dcb-8925001577c1.png) This method `generateOneInputStreamOperator` when

[jira] [Updated] (FLINK-17117) There are an useless cast operation for sql on blink when generate code

2020-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17117: --- Labels: pull-request-available (was: ) > There are an useless cast operation for sql on

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 5f91592c6f010dbb52511c54568c5d3c82082433 UNKNOWN * 13dab75e74ed139bb8802dcf2de0ef87464f046b Travis:

[GitHub] [flink] flinkbot commented on issue #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

2020-04-22 Thread GitBox
flinkbot commented on issue #11869: URL: https://github.com/apache/flink/pull/11869#issuecomment-618175194 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 will use this comment to track the progress

[jira] [Updated] (FLINK-17111) Support SHOW VIEWS in Flink SQL

2020-04-22 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17111: --- Labels: pull-request-available (was: ) > Support SHOW VIEWS in Flink SQL >

[GitHub] [flink] docete opened a new pull request #11869: [FLINK-17111][table] Support SHOW VIEWS in Flink SQL

2020-04-22 Thread GitBox
docete opened a new pull request #11869: URL: https://github.com/apache/flink/pull/11869 ## What is the purpose of the change FLINK-17106 introduces create/drop view in Flink SQL. But we can't list views from TableEnvironment or SQL. This PR supports SHOW VIEWS in Flink SQL. BTW:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 9c3d9347f989a84184f598190271f5e0b4703ba0 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161547778) Azure:

[jira] [Created] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

2020-04-22 Thread Canbin Zheng (Jira)
Canbin Zheng created FLINK-17332: Summary: Fix restart policy not equals to Never for native task manager pods Key: FLINK-17332 URL: https://issues.apache.org/jira/browse/FLINK-17332 Project: Flink

[jira] [Updated] (FLINK-17332) Fix restart policy not equals to Never for native task manager pods

2020-04-22 Thread Canbin Zheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Canbin Zheng updated FLINK-17332: - Description: Currently, we do not explicitly set the {{RestartPolicy}} for the task manager

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * b0730cb05f9d77f9d34ab7221020931ef5d2532d Travis:

[jira] [Created] (FLINK-17331) Add NettyMessageContent interface for all the class which could be write to NettyMessage

2020-04-22 Thread Yangze Guo (Jira)
Yangze Guo created FLINK-17331: -- Summary: Add NettyMessageContent interface for all the class which could be write to NettyMessage Key: FLINK-17331 URL: https://issues.apache.org/jira/browse/FLINK-17331

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Commented] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090210#comment-17090210 ] Zhu Zhu commented on FLINK-17330: - cc [~gjy] [~trohrmann] Sorry this case was neglected. What do you

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Updated] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhu Zhu updated FLINK-17330: Description: Imagine a job like this: A -- (pipelined FORWARD) --> B -- (blocking ALL-to-ALL) --> D A --

[jira] [Created] (FLINK-17330) Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges

2020-04-22 Thread Zhu Zhu (Jira)
Zhu Zhu created FLINK-17330: --- Summary: Avoid scheduling deadlocks caused by intra-logical-region ALL-to-ALL blocking edges Key: FLINK-17330 URL: https://issues.apache.org/jira/browse/FLINK-17330 Project:

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[jira] [Comment Edited] (FLINK-17328) Expose network metric for job vertex in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090203#comment-17090203 ] lining edited comment on FLINK-17328 at 4/23/20, 3:40 AM: -- [Gary

[jira] [Commented] (FLINK-17328) Expose network metric for job vertex in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090203#comment-17090203 ] lining commented on FLINK-17328: [~gary] could you assign it to me? > Expose network metric for job

[jira] [Updated] (FLINK-14815) Expose network metric for sub task in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14815: --- Description: * SubTask **  pool usage: outPoolUsage, inputExclusiveBuffersUsage, 

[jira] [Commented] (FLINK-17173) Supports query hint to config "IdleStateRetentionTime" per operator in SQL

2020-04-22 Thread Jiahui Jiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090202#comment-17090202 ] Jiahui Jiang commented on FLINK-17173: -- [~danny0405] I just saw your [design

[jira] [Created] (FLINK-17329) Quickstarts Scala nightly e2e test failed on travis

2020-04-22 Thread Yu Li (Jira)
Yu Li created FLINK-17329: - Summary: Quickstarts Scala nightly e2e test failed on travis Key: FLINK-17329 URL: https://issues.apache.org/jira/browse/FLINK-17329 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-17328) Expose network metric for job vertex in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-17328: --- Description: JobVertexDetailsHandler * pool usage: outPoolUsageAvg, inputExclusiveBuffersUsageAvg, 

[GitHub] [flink] wuchong commented on a change in pull request #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
wuchong commented on a change in pull request #11804: URL: https://github.com/apache/flink/pull/11804#discussion_r413482942 ## File path: docs/dev/table/catalogs.md ## @@ -37,6 +41,97 @@ Or permanent metadata, like that in a Hive Metastore. Catalogs provide a unified The

[jira] [Updated] (FLINK-14815) Expose network metric for sub task in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-14815: --- Summary: Expose network metric for sub task in rest api (was: Expose network metric in rest api) > Expose

[jira] [Updated] (FLINK-17328) Expose network metric for job vertex in rest api

2020-04-22 Thread lining (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] lining updated FLINK-17328: --- Parent: FLINK-14712 Issue Type: Sub-task (was: Improvement) > Expose network metric for job vertex

[jira] [Created] (FLINK-17328) Expose network metric for job vertex in rest api

2020-04-22 Thread lining (Jira)
lining created FLINK-17328: -- Summary: Expose network metric for job vertex in rest api Key: FLINK-17328 URL: https://issues.apache.org/jira/browse/FLINK-17328 Project: Flink Issue Type: Improvement

[GitHub] [flink] wuchong commented on a change in pull request #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

2020-04-22 Thread GitBox
wuchong commented on a change in pull request #11837: URL: https://github.com/apache/flink/pull/11837#discussion_r413470860 ## File path: flink-table/flink-table-planner-blink/src/main/java/org/apache/flink/table/planner/catalog/CatalogSchemaTable.java ## @@ -153,6 +166,27 @@

[jira] [Commented] (FLINK-17289) Translate tutorials/etl.md to chinese

2020-04-22 Thread Li Ying (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17289?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090188#comment-17090188 ] Li Ying commented on FLINK-17289: - Hi David, I'd like to do the translation. Could you please assigh

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * 6bfb3f29fa88ad7314ccd9bd3a9eb0568d63c9c9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161400110) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 91c3f6c3986386cd4f5c914029b807ecd979e50c Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161448300) Azure:

[jira] [Closed] (FLINK-17323) ChannelStateReader rejects requests about unkown channels (Unaligned checkpoints)

2020-04-22 Thread Zhijiang (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zhijiang closed FLINK-17323. Resolution: Fixed Merged in master: 07667d29181be2cd4281d36c8cdfbd9a6c4e704a > ChannelStateReader

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * f4560ce97f1b94b5d3ffa9c280879f227fc4211a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11859: [FLINK-16485][python] Support vectorized Python UDF in batch mode of old planner

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11859: URL: https://github.com/apache/flink/pull/11859#issuecomment-617655293 ## CI report: * 6bfb3f29fa88ad7314ccd9bd3a9eb0568d63c9c9 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161400110) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #10059: [FLINK-14543][FLINK-15901][table] Support partition for temporary table and HiveCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #10059: URL: https://github.com/apache/flink/pull/10059#issuecomment-548289939 ## CI report: * 91c3f6c3986386cd4f5c914029b807ecd979e50c Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/161448300) Azure:

[GitHub] [flink] wuchong commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

2020-04-22 Thread GitBox
wuchong commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-618137477 Hi @kl0u , we refactored `BatchTableEnviroment` to use `executor` to submit the Pipline. That's why we need an executor for `CollectionEnvironment` because tests are using

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11797: [FLINK-17169][table-blink] Refactor BaseRow to use RowKind instead of byte header

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11797: URL: https://github.com/apache/flink/pull/11797#issuecomment-615294694 ## CI report: * 85f40e3041783b1dbda1eb3b812f23e77936f7b3 UNKNOWN * f4560ce97f1b94b5d3ffa9c280879f227fc4211a Travis:

[GitHub] [flink] flinkbot edited a comment on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-617596227 ## CI report: * 77720a95c9fb8163487dbec5bc82681f1e7f9fde Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/161400024) Azure:

[GitHub] [flink] godfreyhe commented on issue #11794: [FLINK-17126] [table-planner] Correct the execution behavior of BatchTableEnvironment

2020-04-22 Thread GitBox
godfreyhe commented on issue #11794: URL: https://github.com/apache/flink/pull/11794#issuecomment-618133036 hi @kl0u `CollectionEnvironment` is used in flink-table-planner for testing, e.g. `org.apache.flink.table.runtime.batch.sql.TableEnvironmentITCase#testInsertIntoMemoryTable` and

[GitHub] [flink] KarmaGYZ commented on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

2020-04-22 Thread GitBox
KarmaGYZ commented on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-618130733 @flinkbot run travis This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] KarmaGYZ commented on issue #11855: [FLINK-13639] Refactor the IntermediateResultPartitionID to consist o…

2020-04-22 Thread GitBox
KarmaGYZ commented on issue #11855: URL: https://github.com/apache/flink/pull/11855#issuecomment-618130670 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please log

[GitHub] [flink] leonardBang commented on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
leonardBang commented on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-618130592 @flinkbot run azure This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11838: [FLINK-16965] Convert Graphite reporter to plugin

2020-04-22 Thread GitBox
KarmaGYZ commented on a change in pull request #11838: URL: https://github.com/apache/flink/pull/11838#discussion_r413450999 ## File path: flink-metrics/flink-metrics-graphite/pom.xml ## @@ -65,31 +65,4 @@ under the License. ${dropwizard.version}

[jira] [Closed] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng closed FLINK-16766. --- Resolution: Resolved > Support create StreamTableEnvironment without passing >

[jira] [Updated] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hequn Cheng updated FLINK-16766: Fix Version/s: (was: 1.9.4) (was: 1.10.1) > Support create

[jira] [Commented] (FLINK-16766) Support create StreamTableEnvironment without passing StreamExecutionEnvironment

2020-04-22 Thread Hequn Cheng (Jira)
[ https://issues.apache.org/jira/browse/FLINK-16766?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17090151#comment-17090151 ] Hequn Cheng commented on FLINK-16766: - Resolved in 1.11.0 via

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

[GitHub] [flink] docete commented on issue #11837: [FLINK-16160][table-planner-blink] Fix proctime()/rowtime() doesn't w…

2020-04-22 Thread GitBox
docete commented on issue #11837: URL: https://github.com/apache/flink/pull/11837#issuecomment-618122640 @wuchong pls have a look This is an automated message from the Apache Git Service. To respond to the message, please

[GitHub] [flink] flinkbot edited a comment on issue #11867: [FLINK-17309][e2e tests][WIP]TPC-DS fail to run data generator

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11867: URL: https://github.com/apache/flink/pull/11867#issuecomment-617863974 ## CI report: * 51571402e16bb71237a68a153191ba3a7d97bbf8 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161468937) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11865: Revert "[FLINK-14499][metric] MetricRegistry#getMetricQueryServiceGatewayRpcAddress is Nonnull"

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11865: URL: https://github.com/apache/flink/pull/11865#issuecomment-617839769 ## CI report: * 7a81c3644e88e09b2a88c1737c495a83f8fbde6c Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461284) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11853: [FLINK-15006][table-planner] Add option to shuffle-by-partition when dynamic inserting

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11853: URL: https://github.com/apache/flink/pull/11853#issuecomment-617586421 ## CI report: * 99b58fba1e22bdbba0896f0aba181eafc6a28e7f Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161461206) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11863: [FLINK-17048][mesos] Add memory related JVM args to Mesos JM startup scripts

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11863: URL: https://github.com/apache/flink/pull/11863#issuecomment-617687609 ## CI report: * d559c7119084b47c163dd4e1523b3f9487d88e82 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161452814) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11864: [FLINK-17301] Set BIND_HOST to localhost in TaskManagerRunnerStartupTest

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11864: URL: https://github.com/apache/flink/pull/11864#issuecomment-617827070 ## CI report: * e0907be73cf672f719d282a4e80a99a1e4cb7e13 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161456797) Azure:

[GitHub] [flink] flinkbot edited a comment on issue #11804: [FLINK-16473][doc][jdbc] add documentation for JDBCCatalog and PostgresCatalog

2020-04-22 Thread GitBox
flinkbot edited a comment on issue #11804: URL: https://github.com/apache/flink/pull/11804#issuecomment-615960634 ## CI report: * d467bd31393f9dc171b6625f9053360b73bfd64d Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161487842) Azure:

  1   2   3   4   5   6   >