[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 012133641bb130c7c5f79c5d1f4bfede326a3961 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162221841) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

flinkbot edited a comment on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-620020496 ## CI report: * 0c1f20e60592bc804a4f6260221c96d564afa50b Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162238046) Azure:

[GitHub] [flink] zentol commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

zentol commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r416068241 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -0,0 +1,114 @@ +/* + * Licensed to

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

flinkbot edited a comment on pull request #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * dc7d6a747ef944547248143932f3cadb48ec27c8 UNKNOWN * 8c8f9565178df123f872378bc46e5388f66066ca Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11909: [FLINK-16103] Translate "Configuration" page of "Table API & SQL" int…

flinkbot edited a comment on pull request #11909: URL: https://github.com/apache/flink/pull/11909#issuecomment-619365498 ## CI report: * 47ee64e7834b5d42fcbc4cffea7688a15f42f89c UNKNOWN * 2fed25b4202034e3d9f40ed65879e793478a8e4b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * 479e2a0baeda9ff11cbd6f56b988e8b071df4b9b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162205606) Azure:

[jira] [Commented] (FLINK-17421) Backpressure new checkpoints if previous were not managed to be cleaned up yet

[ https://issues.apache.org/jira/browse/FLINK-17421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093792#comment-17093792 ] Steven Zhen Wu commented on FLINK-17421: what does "backpressure new checkpoints" mean? are we

[GitHub] [flink] flinkbot edited a comment on pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on pull request #11887: URL: https://github.com/apache/flink/pull/11887#issuecomment-618505450 ## CI report: * 5ecc88f14d8d7ebd8ad31749399e0c6d9e54ab00 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162237825) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 9ff4c1ae3a43f76ad77c77d6aa8f42c39fb1bb41 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162202248) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on pull request #11567: URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * b25ccecb183daa3d2a8aaf3a75f37ff4db183360 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162233216) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * f12169b74a4545047cca830df5006c2c9ee877ce Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162254032) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

flinkbot edited a comment on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620094263 ## CI report: * fd62e8e95b6dd361304e0af9defbc89e7cc65f78 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162261165) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

flinkbot edited a comment on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-620020496 ## CI report: * 0c1f20e60592bc804a4f6260221c96d564afa50b Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162238046) Azure:

[GitHub] [flink] dawidwys edited a comment on pull request #11904: [FLINK-17373][table] Support the NULL type for function calls

dawidwys edited a comment on pull request #11904: URL: https://github.com/apache/flink/pull/11904#issuecomment-620110133 Generally +1 for the changes. It enables new use cases without disabling any current ones. It does put some restrictions on a few cases we might want to support in the

[GitHub] [flink] dawidwys commented on pull request #11904: [FLINK-17373][table] Support the NULL type for function calls

dawidwys commented on pull request #11904: URL: https://github.com/apache/flink/pull/11904#issuecomment-620110133 Generally +1 for the changes. It enables new use cases without disabling any current ones. It does put some restrictions on a few cases we might want to support in the future.

[jira] [Commented] (FLINK-17073) Slow checkpoint cleanup causing OOMs

[ https://issues.apache.org/jira/browse/FLINK-17073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093738#comment-17093738 ] Piotr Nowojski commented on FLINK-17073: I haven't analysed the issue, so I'm not sure if indeed

[jira] [Created] (FLINK-17421) Backpressure new checkpoints if previous were not managed to be cleaned up yet

Piotr Nowojski created FLINK-17421: -- Summary: Backpressure new checkpoints if previous were not managed to be cleaned up yet Key: FLINK-17421 URL: https://issues.apache.org/jira/browse/FLINK-17421

[GitHub] [flink] flinkbot edited a comment on pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

flinkbot edited a comment on pull request #11808: URL: https://github.com/apache/flink/pull/11808#issuecomment-616081932 ## CI report: * 8fc1a7080094527a36fa1f1eb32bf4bd2c548402 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160890194) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11924: [FLINK-17182][network] Fix the unstable input channel test by recycling exclusive and floating buffer in the same thread

flinkbot edited a comment on pull request #11924: URL: https://github.com/apache/flink/pull/11924#issuecomment-620094113 ## CI report: * c9d0fc65ad8da1f3295d3fb608967ddb471bb370 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162261123) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

flinkbot edited a comment on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620094263 ## CI report: * fd62e8e95b6dd361304e0af9defbc89e7cc65f78 Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162261165) Azure:

[GitHub] [flink] flinkbot commented on pull request #11924: [FLINK-17182][network] Fix the unstable input channel test by recycling exclusive and floating buffer in the same thread

flinkbot commented on pull request #11924: URL: https://github.com/apache/flink/pull/11924#issuecomment-620094113 ## CI report: * c9d0fc65ad8da1f3295d3fb608967ddb471bb370 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

flinkbot commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620094263 ## CI report: * fd62e8e95b6dd361304e0af9defbc89e7cc65f78 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-17274) Maven: Premature end of Content-Length delimited message body

[ https://issues.apache.org/jira/browse/FLINK-17274?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093705#comment-17093705 ] Robert Metzger commented on FLINK-17274:

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * f12169b74a4545047cca830df5006c2c9ee877ce Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162254032) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN * d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 012133641bb130c7c5f79c5d1f4bfede326a3961 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162221841) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

flinkbot edited a comment on pull request #11808: URL: https://github.com/apache/flink/pull/11808#issuecomment-616081932 ## CI report: * 8fc1a7080094527a36fa1f1eb32bf4bd2c548402 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/160890194) Azure:

[GitHub] [flink] flinkbot commented on pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

flinkbot commented on pull request #11925: URL: https://github.com/apache/flink/pull/11925#issuecomment-620090772 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

[jira] [Updated] (FLINK-16996) Refactor planner and connectors to use new data structures

[ https://issues.apache.org/jira/browse/FLINK-16996?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-16996: --- Labels: pull-request-available (was: ) > Refactor planner and connectors to use new data

[GitHub] [flink] wuchong opened a new pull request #11925: [FLINK-16996][table] Refactor planner and connectors to use new data structures

wuchong opened a new pull request #11925: URL: https://github.com/apache/flink/pull/11925 ## What is the purpose of the change Refactors existing code to use the new data structures interfaces. ## Brief change log The commints in the order: - [table-common]

[jira] [Commented] (FLINK-16833) Make JDBCDialect pluggable for JDBC SQL connector

[ https://issues.apache.org/jira/browse/FLINK-16833?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093693#comment-17093693 ] Lijie Wang commented on FLINK-16833: Hi [~jark], can you assign this issue to me? It's my design:

[GitHub] [flink] gaoyunhaii commented on pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

gaoyunhaii commented on pull request #11808: URL: https://github.com/apache/flink/pull/11808#issuecomment-620085137 Hi @XBaith Very thanks for the Review! I have updated the PR according to the comments. This is an

[GitHub] [flink] gaoyunhaii commented on a change in pull request #11808: [FLINK-16155][docs-zh] Translate "Operator/Process Function" page into Chinese

gaoyunhaii commented on a change in pull request #11808: URL: https://github.com/apache/flink/pull/11808#discussion_r415950705 ## File path: docs/dev/stream/operators/process_function.zh.md ## @@ -26,66 +26,65 @@ under the License. * This will be replaced by the TOC {:toc}

[GitHub] [flink] flinkbot commented on pull request #11924: [FLINK-17182][network] Fix the unstable input channel test by recycling exclusive and floating buffer in the same thread

flinkbot commented on pull request #11924: URL: https://github.com/apache/flink/pull/11924#issuecomment-620082858 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

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 817ade5abd0b4fee7e256d8099577b69a89483ab Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162184261) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11909: [FLINK-16103] Translate "Configuration" page of "Table API & SQL" int…

flinkbot edited a comment on pull request #11909: URL: https://github.com/apache/flink/pull/11909#issuecomment-619365498 ## CI report: * 47ee64e7834b5d42fcbc4cffea7688a15f42f89c UNKNOWN * 2fed25b4202034e3d9f40ed65879e793478a8e4b Travis:

[GitHub] [flink] gaoyunhaii opened a new pull request #11924: [FLINK-17182][network] Fix the unstable input channel test by recycling exclusive and floating buffer in the same thread

gaoyunhaii opened a new pull request #11924: URL: https://github.com/apache/flink/pull/11924 ## What is the purpose of the change This PR fixes the unstable input channel test. Currently some test might be unstable with specific thread concurrency when we simulating the cases

[GitHub] [flink] flinkbot edited a comment on pull request #11920: [FLINK-17408] Introduce GPUDriver and discovery script

flinkbot edited a comment on pull request #11920: URL: https://github.com/apache/flink/pull/11920#issuecomment-619909940 ## CI report: * 479e2a0baeda9ff11cbd6f56b988e8b071df4b9b Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162205606) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 817ade5abd0b4fee7e256d8099577b69a89483ab Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162184261) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * eea4d8a7453157d0e43d64f5cd9a2c2f52c9aec6 Travis: [CANCELED](https://travis-ci.com/github/flink-ci/flink/builds/162237784) Azure:

[jira] [Created] (FLINK-17420) Cannot alias Tuple and Row fields when converting DataStream to Table

Gyula Fora created FLINK-17420: -- Summary: Cannot alias Tuple and Row fields when converting DataStream to Table Key: FLINK-17420 URL: https://issues.apache.org/jira/browse/FLINK-17420 Project: Flink

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * 117890264bbd985fdbfc4fa00ae98895c4fa6311 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162184198) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11919: [hotfix] [docs] fix state_processor_api doc, is spelling mistakes.

flinkbot edited a comment on pull request #11919: URL: https://github.com/apache/flink/pull/11919#issuecomment-619856466 ## CI report: * 26a678d1db2021904cf5bf96ecf7448f425f5d3e UNKNOWN * 14d41ad5c3dd6c319ae1f8a6c5b8dbe617bbc29c Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11918: [FLINK-17405] [sql-client] add test cases for cancel job in SQL client

flinkbot edited a comment on pull request #11918: URL: https://github.com/apache/flink/pull/11918#issuecomment-619856059 ## CI report: * 2298d820f536b24fcf6b7494b32dcccfc9216dc4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162188659) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * cbca6f0d98e1cb9e1a60086a32a9c058150fa97b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11397: [FLINK-16217] [sql-client] catch SqlExecutionException for all callXX methods

flinkbot edited a comment on pull request #11397: URL: https://github.com/apache/flink/pull/11397#issuecomment-598575354 ## CI report: * 9ff4c1ae3a43f76ad77c77d6aa8f42c39fb1bb41 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162202248) Azure:

[GitHub] [flink] GJL commented on pull request #11731: [FLINK-17130][web] Enable listing JM Logs and displaying Logs by filename

GJL commented on pull request #11731: URL: https://github.com/apache/flink/pull/11731#issuecomment-620048458 First of all, I am sorry that I did not see this problem earlier. > 1. split the taskmanager and jobmanager logs into different folders to avoid they mixed together in the

[GitHub] [flink] flinkbot edited a comment on pull request #11903: [FLINK-16661] Add support for Application Mode to YARN.

flinkbot edited a comment on pull request #11903: URL: https://github.com/apache/flink/pull/11903#issuecomment-619010246 ## CI report: * 817ade5abd0b4fee7e256d8099577b69a89483ab Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162184261) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * 117890264bbd985fdbfc4fa00ae98895c4fa6311 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162184198) Azure:

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

flinkbot edited a comment on pull request #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * dc7d6a747ef944547248143932f3cadb48ec27c8 UNKNOWN * 770410346edc268b319a541f99406610f7ed8b66 Travis:

[GitHub] [flink] echauchot commented on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

echauchot commented on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-620042169 Done, I removed the tags from commit messages. I also fixed the conflict with the docs: you removed api_concepts.md page that I was updating but you also added the comment on

[GitHub] [flink] zentol commented on pull request #11895: [FLINK-10911][scala-shell] Enable flink-scala-shell with Scala 2.12

zentol commented on pull request #11895: URL: https://github.com/apache/flink/pull/11895#issuecomment-620035991 We only use scala 2.11 on CI; this is fully independent of whether the scala-shell tests run or not. This is an

[GitHub] [flink] flinkbot edited a comment on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

flinkbot edited a comment on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-620020496 ## CI report: * 0c1f20e60592bc804a4f6260221c96d564afa50b Travis: [PENDING](https://travis-ci.com/github/flink-ci/flink/builds/162238046) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on pull request #11887: URL: https://github.com/apache/flink/pull/11887#issuecomment-618505450 ## CI report: * bc5fd415d52f54be1aec59ff86b0d1571fb88489 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834854) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * 117890264bbd985fdbfc4fa00ae98895c4fa6311 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162184198) Azure:

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

flinkbot edited a comment on pull request #11870: URL: https://github.com/apache/flink/pull/11870#issuecomment-618183162 ## CI report: * dc7d6a747ef944547248143932f3cadb48ec27c8 UNKNOWN * 770410346edc268b319a541f99406610f7ed8b66 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on pull request #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11917: [FLINK-15591][table] Support create/drop temporary table in Flink SQL

flinkbot edited a comment on pull request #11917: URL: https://github.com/apache/flink/pull/11917#issuecomment-619827493 ## CI report: * 487163f267a4f86452a7588f58182e534b5d7193 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/162180374) Azure:

[GitHub] [flink] flinkbot commented on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

flinkbot commented on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-620020496 ## CI report: * 0c1f20e60592bc804a4f6260221c96d564afa50b UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

flinkbot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-618445341 ## CI report: * 117890264bbd985fdbfc4fa00ae98895c4fa6311 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162184198) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

flinkbot edited a comment on pull request #11887: URL: https://github.com/apache/flink/pull/11887#issuecomment-618505450 ## CI report: * bc5fd415d52f54be1aec59ff86b0d1571fb88489 Travis: [SUCCESS](https://travis-ci.com/github/flink-ci/flink/builds/161834854) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11814: [FLINK-17218][tests] Adding recoverable failures and correctness chec…

flinkbot edited a comment on pull request #11814: URL: https://github.com/apache/flink/pull/11814#issuecomment-616347961 ## CI report: * 1e0c61b438830bd4d377ae16f7f8d2b1bc0ce047 UNKNOWN * cbca6f0d98e1cb9e1a60086a32a9c058150fa97b Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on pull request #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on pull request #11567: URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * d2fbea2e2b5ed1fc158d60b9a6325bb18c5189b5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161952900) Azure:

[jira] [Commented] (FLINK-17012) Expose stage of task initialization

[ https://issues.apache.org/jira/browse/FLINK-17012?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093561#comment-17093561 ] Piotr Nowojski commented on FLINK-17012: Another question came to my mind. How should this be

[jira] [Commented] (FLINK-17401) Add Labels to Mesos TM taskinfo object

[ https://issues.apache.org/jira/browse/FLINK-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093548#comment-17093548 ] chaganti spurthi commented on FLINK-17401: -- [https://github.com/apache/flink/pull/11923] Flink

[jira] [Updated] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-16947: --- Priority: Blocker (was: Critical) > ArtifactResolutionException: Could not transfer

[GitHub] [flink] flinkbot commented on pull request #11923: [FLINK-17401] Add Labels to the mesos task info

flinkbot commented on pull request #11923: URL: https://github.com/apache/flink/pull/11923#issuecomment-620007620 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

[GitHub] [flink] KarmaGYZ commented on pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

KarmaGYZ commented on pull request #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-620006407 Rebase to the latest master branch. This is an automated message from the Apache Git Service. To respond to

[jira] [Updated] (FLINK-17401) Add Labels to Mesos TM taskinfo object

[ https://issues.apache.org/jira/browse/FLINK-17401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17401: --- Labels: pull-request-available (was: ) > Add Labels to Mesos TM taskinfo object >

[GitHub] [flink] spurthicriteo opened a new pull request #11923: [FLINK-17401] Add Labels to the mesos task info

spurthicriteo opened a new pull request #11923: URL: https://github.com/apache/flink/pull/11923 ## What is the purpose of the change [FLINK-17401] Currently labels are not set in the task info object. A lot of companies can have logic specific to labels on TM. For example in criteo,

[GitHub] [flink] flinkbot edited a comment on pull request #11892: [FLINK-17112][table] Support DESCRIBE statement in Flink SQL

flinkbot edited a comment on pull request #11892: URL: https://github.com/apache/flink/pull/11892#issuecomment-618766534 ## CI report: * 196b7566be701c6c0759d08f76d7bec7148a47b3 UNKNOWN * d40ddaae8da56b1b9ebaab3693d8c04c6d6cbb43 Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11919: [hotfix] [docs] fix state_processor_api doc, is spelling mistakes.

flinkbot edited a comment on pull request #11919: URL: https://github.com/apache/flink/pull/11919#issuecomment-619856466 ## CI report: * 26a678d1db2021904cf5bf96ecf7448f425f5d3e UNKNOWN * 14d41ad5c3dd6c319ae1f8a6c5b8dbe617bbc29c Travis:

[GitHub] [flink] flinkbot edited a comment on pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on pull request #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN *

[GitHub] [flink] flinkbot edited a comment on pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

flinkbot edited a comment on pull request #11567: URL: https://github.com/apache/flink/pull/11567#issuecomment-606017854 ## CI report: * d2fbea2e2b5ed1fc158d60b9a6325bb18c5189b5 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/161952900) Azure:

[GitHub] [flink] tillrohrmann commented on pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on pull request #11887: URL: https://github.com/apache/flink/pull/11887#issuecomment-620003971 Thanks for the review @zentol. I answered all your comments. Please take another look. This is an

[jira] [Commented] (FLINK-16947) ArtifactResolutionException: Could not transfer artifact. Entry [...] has not been leased from this pool

[ https://issues.apache.org/jira/browse/FLINK-16947?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093539#comment-17093539 ] Robert Metzger commented on FLINK-16947:

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415835040 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -0,0 +1,114 @@ +/* + *

[jira] [Updated] (FLINK-17419) kafka sink json data convert issuse,type compare error

[ https://issues.apache.org/jira/browse/FLINK-17419?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] xiaodao updated FLINK-17419: Description: org.apache.flink.formats.json.JsonRowSerializationSchema#convert the param info is

[jira] [Updated] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-17315: --- Affects Version/s: (was: 1.11.0) >

[GitHub] [flink] echauchot edited a comment on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

echauchot edited a comment on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-619982481 > Thanks, I'll take a look! > > By the way, I prefer shorter commit titles, but it's up to you. Some people like putting the tags, but for example in the github

[jira] [Comment Edited] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093530#comment-17093530 ] Piotr Nowojski edited comment on FLINK-17315 at 4/27/20, 1:46 PM: --

[jira] [Commented] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093530#comment-17093530 ] Piotr Nowojski commented on FLINK-17315: time outs bumped to 5 minutes by commit c18ba69 into

[jira] [Closed] (FLINK-17315) UnalignedCheckpointITCase.shouldPerformUnalignedCheckpointMassivelyParallel failed in timeout

[ https://issues.apache.org/jira/browse/FLINK-17315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-17315. -- Resolution: Fixed >

[GitHub] [flink] sjwiesman commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

sjwiesman commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r415821336 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java ## @@ -198,6

[jira] [Created] (FLINK-17419) kafka sink json data convert issuse,type compare error

xiaodao created FLINK-17419: --- Summary: kafka sink json data convert issuse,type compare error Key: FLINK-17419 URL: https://issues.apache.org/jira/browse/FLINK-17419 Project: Flink Issue Type: Bug

[GitHub] [flink] flinkbot edited a comment on pull request #11918: [FLINK-17405] [sql-client] add test cases for cancel job in SQL client

flinkbot edited a comment on pull request #11918: URL: https://github.com/apache/flink/pull/11918#issuecomment-619856059 ## CI report: * 2298d820f536b24fcf6b7494b32dcccfc9216dc4 Travis: [FAILURE](https://travis-ci.com/github/flink-ci/flink/builds/162188659) Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #11615: [FLINK-16605] Add max limitation to the total number of slots

flinkbot edited a comment on pull request #11615: URL: https://github.com/apache/flink/pull/11615#issuecomment-607717339 ## CI report: * 2db316d977d0e790de8fa98b27dd219b68abb136 UNKNOWN * 0b0111ba893c9ecc7632394fc59e455f8d5c9db7 UNKNOWN *

[jira] [Resolved] (FLINK-17390) Container resource cannot be mapped on Hadoop 2.10+

[ https://issues.apache.org/jira/browse/FLINK-17390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-17390. --- Resolution: Fixed Fixed via 537a56441a49b67ed2d8f271e079ef6b5094f506 > Container resource

[jira] [Resolved] (FLINK-16440) Extend SlotManager metrics and status for dynamic slot allocation.

[ https://issues.apache.org/jira/browse/FLINK-16440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Till Rohrmann resolved FLINK-16440. --- Resolution: Fixed Fixed via c47ee2814aa0ef62237797626daaea95d6d52ca7

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415810380 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1012,10 +1016,34 @@ public void

[GitHub] [flink] Jiayi-Liao commented on a change in pull request #11567: [FLINK-16645] Limit the maximum backlogs in subpartitions

Jiayi-Liao commented on a change in pull request #11567: URL: https://github.com/apache/flink/pull/11567#discussion_r415810772 ## File path: flink-core/src/main/java/org/apache/flink/configuration/NettyShuffleEnvironmentOptions.java ## @@ -174,6 +173,20 @@

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415808063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1012,10 +1016,34 @@ public void

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415808063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1012,10 +1016,34 @@ public void

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415809201 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/rest/messages/taskmanager/ThreadDumpInfo.java ## @@ -0,0 +1,114 @@ +/* + *

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415808063 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/TaskExecutor.java ## @@ -1012,10 +1016,34 @@ public void

[GitHub] [flink] tillrohrmann commented on a change in pull request #11887: [FLINK-14816] Add thread dump feature for taskmanager

tillrohrmann commented on a change in pull request #11887: URL: https://github.com/apache/flink/pull/11887#discussion_r415807514 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskexecutor/FileType.java ## @@ -22,6 +22,13 @@ * Different file types to

[GitHub] [flink] echauchot commented on pull request #11886: [FLINK-17074] Deprecate key based methods that do not use KeySelector in Datastreams API

echauchot commented on pull request #11886: URL: https://github.com/apache/flink/pull/11886#issuecomment-619982481 > Thanks, I'll take a look! > > By the way, I prefer shorter commit titles, but it's up to you. Some people like putting the tags, but for example in the github view

[GitHub] [flink] KarmaGYZ commented on a change in pull request #11854: [FLINK-17407] Introduce external resource framework

KarmaGYZ commented on a change in pull request #11854: URL: https://github.com/apache/flink/pull/11854#discussion_r415807586 ## File path: flink-libraries/flink-state-processing-api/src/main/java/org/apache/flink/state/api/runtime/SavepointEnvironment.java ## @@ -198,6

[jira] [Commented] (FLINK-17290) Translate Streaming Analytics tutorial to chinese

[ https://issues.apache.org/jira/browse/FLINK-17290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17093513#comment-17093513 ] David Anderson commented on FLINK-17290: Sure, happy to have your help with that. I'll assign

<    1   2   3   4   5   6   >