[jira] [Commented] (FLINK-18634) FlinkKafkaProducerITCase.testRecoverCommittedTransaction failed with "Timeout expired after 60000milliseconds while awaiting InitProducerId"

[ https://issues.apache.org/jira/browse/FLINK-18634?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286388#comment-17286388 ] Jiangjie Qin commented on FLINK-18634: -- [~lindong]  Thanks for digging into this. Good finding.

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14928: [FLINK-21360][coordination] Make resource timeout configurable

flinkbot edited a comment on pull request #14928: URL: https://github.com/apache/flink/pull/14928#issuecomment-14828 ## CI report: * fa4a474ab1addab8caafd64686a1a9d029843556 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14897: [FLINK-21221][runtime] Deduplication for multiple ResourceCounters

flinkbot edited a comment on pull request #14897: URL: https://github.com/apache/flink/pull/14897#issuecomment-775050448 ## CI report: * fe7422b9c37e9abb89069a3dc6beedf817034f9f Azure:

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286381#comment-17286381 ] Roman Khachatryan commented on FLINK-17510: ---

[jira] [Commented] (FLINK-21133) FLIP-27 Source does not work with synchronous savepoint

[ https://issues.apache.org/jira/browse/FLINK-21133?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286380#comment-17286380 ] Jiangjie Qin commented on FLINK-21133: -- It looks that we are aiming to get a long term solution

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578256434 ## File path:

[GitHub] [flink] dannycranmer commented on a change in pull request #14737: [FLINK-19667] Add AWS Glue Schema Registry integration

dannycranmer commented on a change in pull request #14737: URL: https://github.com/apache/flink/pull/14737#discussion_r578255800 ## File path:

[jira] [Closed] (FLINK-21100) Add DeclarativeScheduler skeleton

[ https://issues.apache.org/jira/browse/FLINK-21100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-21100. Resolution: Fixed master:

[jira] [Updated] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17510: - Affects Version/s: (was: 1.13.0) 1.11.3 >

[GitHub] [flink] zentol merged pull request #14921: [FLINK-21100][coordination] Add DeclarativeScheduler

zentol merged pull request #14921: URL: https://github.com/apache/flink/pull/14921 This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14944: [FLINK-21297] Support 'LOAD/UNLOAD MODULE' syntax

flinkbot edited a comment on pull request #14944: URL: https://github.com/apache/flink/pull/14944#issuecomment-779315396 ## CI report: * e265855ee20db57e62a53be0f80486ff2feaef29 Azure:

[jira] [Updated] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-17510: - Affects Version/s: 1.13.0 > StreamingKafkaITCase. testKafka timeouts on downloading

[jira] [Commented] (FLINK-17510) StreamingKafkaITCase. testKafka timeouts on downloading Kafka

[ https://issues.apache.org/jira/browse/FLINK-17510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286363#comment-17286363 ] Dawid Wysakowicz commented on FLINK-17510: --

[GitHub] [flink] flinkbot edited a comment on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

flinkbot edited a comment on pull request #14958: URL: https://github.com/apache/flink/pull/14958#issuecomment-781106758 ## CI report: * 23715c1def6387cab08ccf963203538fa9074228 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

flinkbot edited a comment on pull request #14950: URL: https://github.com/apache/flink/pull/14950#issuecomment-780431068 ## CI report: * bee61356ebeb5f99c96ce3193b3bd8205e61e44d Azure:

[GitHub] [flink] rmetzger commented on pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

rmetzger commented on pull request #14950: URL: https://github.com/apache/flink/pull/14950#issuecomment-781149460 This PR is ready to review again! This is an automated message from the Apache Git Service. To respond to the

[GitHub] [flink] flinkbot edited a comment on pull request #14958: [FLINK-18550][sql-client] use TableResult#collect to get select result for sql client

flinkbot edited a comment on pull request #14958: URL: https://github.com/apache/flink/pull/14958#issuecomment-781106758 ## CI report: * 23715c1def6387cab08ccf963203538fa9074228 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

flinkbot edited a comment on pull request #14950: URL: https://github.com/apache/flink/pull/14950#issuecomment-780431068 ## CI report: * bee61356ebeb5f99c96ce3193b3bd8205e61e44d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

flinkbot edited a comment on pull request #14822: URL: https://github.com/apache/flink/pull/14822#issuecomment-770394744 ## CI report: * 9512bc3eb5db31416c4f9c8fcd424a4be25c4143 Azure:

[GitHub] [flink] rmetzger commented on a change in pull request #14950: [FLINK-21347][coordination] Extract interface from ExecutionGraph

rmetzger commented on a change in pull request #14950: URL: https://github.com/apache/flink/pull/14950#discussion_r578216296 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/DefaultExecutionGraph.java ## @@ -0,0 +1,1454 @@ +/* + * Licensed to

[GitHub] [flink] flinkbot edited a comment on pull request #14740: [FLINK-21067][runtime][checkpoint] Modify the logic of computing which tasks to trigger/ack/commit to support finished tasks

flinkbot edited a comment on pull request #14740: URL: https://github.com/apache/flink/pull/14740#issuecomment-766340750 ## CI report: * c7e6b28b249f85cf52740d5201a769e0982a60aa UNKNOWN * bebd298009b12a9d5ac6518902f5534f8e00ff32 UNKNOWN *

[GitHub] [flink] xintongsong commented on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

xintongsong commented on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781144201 Thanks for the review, @zhuzhurk. Comments addressed. This is an automated message from the Apache Git

[jira] [Commented] (FLINK-21319) hadoop-mapreduce jars are not loaded into classpath when submiting flink on yarn jobs.

[ https://issues.apache.org/jira/browse/FLINK-21319?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17286335#comment-17286335 ] Tang Yan commented on FLINK-21319: -- I just doubt any impacts to other yarn jobs (e.g. spark jobs) if I

[GitHub] [flink] flinkbot edited a comment on pull request #14955: [FLINK-14869][core] Discard zero-valued extended resources in ResourceSpec/ResourceProfile

flinkbot edited a comment on pull request #14955: URL: https://github.com/apache/flink/pull/14955#issuecomment-781090588 ## CI report: * d30e5867cdac76e93c1c04cc9df434f66494c107 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #14822: [FLINK-21005][table-api] Introduce new provider for unified Sink API and implement in planner

flinkbot edited a comment on pull request #14822: URL: https://github.com/apache/flink/pull/14822#issuecomment-770394744 ## CI report: * 9512bc3eb5db31416c4f9c8fcd424a4be25c4143 Azure:

<    1   2   3   4   5