[GitHub] [flink] flinkbot edited a comment on pull request #16449: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16449: URL: https://github.com/apache/flink/pull/16449#issuecomment-877558429 ## CI report: * 25bbf9aa1dbe47ca4098ef9d362fd17b70c2ccec Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16450: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16450: URL: https://github.com/apache/flink/pull/16450#issuecomment-877558451 ## CI report: * f78e120eb3c35ccdc65031adb4372396997cf242 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * efb7a931424fb31d3a7dce6369af829b136ece8c Azure:

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16437: [FLINK-23021] Check for illegal job graph modifications with finished operators

2021-07-09 Thread GitBox
gaoyunhaii commented on a change in pull request #16437: URL: https://github.com/apache/flink/pull/16437#discussion_r667282368 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/checkpoint/CheckpointCoordinator.java ## @@ -1600,6 +1605,85 @@ private

[GitHub] [flink] flinkbot commented on pull request #16450: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot commented on pull request #16450: URL: https://github.com/apache/flink/pull/16450#issuecomment-877558451 ## CI report: * f78e120eb3c35ccdc65031adb4372396997cf242 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16449: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot commented on pull request #16449: URL: https://github.com/apache/flink/pull/16449#issuecomment-877558429 ## CI report: * 25bbf9aa1dbe47ca4098ef9d362fd17b70c2ccec UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-14621) Do not generate watermark assigner operator if no time attribute operations on rowtime

2021-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14621: Priority: Major (was: Minor) > Do not generate watermark assigner operator if no time attribute

[jira] [Updated] (FLINK-14621) Do not generate watermark assigner operator if no time attribute operations on rowtime

2021-07-09 Thread Jark Wu (Jira)
[ https://issues.apache.org/jira/browse/FLINK-14621?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jark Wu updated FLINK-14621: Labels: (was: auto-deprioritized-major) > Do not generate watermark assigner operator if no time

[GitHub] [flink] flinkbot edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876475935 ## CI report: * 1b3a0d615d4f69eafd023cb3a7dd6cd70e3d6673 Azure:

[GitHub] [flink] flinkbot commented on pull request #16450: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot commented on pull request #16450: URL: https://github.com/apache/flink/pull/16450#issuecomment-877548232 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 commented on pull request #16449: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
flinkbot commented on pull request #16449: URL: https://github.com/apache/flink/pull/16449#issuecomment-877548237 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] gaoyunhaii opened a new pull request #16450: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
gaoyunhaii opened a new pull request #16450: URL: https://github.com/apache/flink/pull/16450 This PR picks https://github.com/apache/flink/pull/16366 to Release 1.13 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[GitHub] [flink] gaoyunhaii opened a new pull request #16449: [FLINK-23223] Notifies if there are available data on resumption for pipelined subpartition

2021-07-09 Thread GitBox
gaoyunhaii opened a new pull request #16449: URL: https://github.com/apache/flink/pull/16449 This PR picks https://github.com/apache/flink/pull/16366 to Release 1.12 -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use

[jira] [Commented] (FLINK-23302) Precondition failed building CheckpointMetrics.

2021-07-09 Thread Yun Gao (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378384#comment-17378384 ] Yun Gao commented on FLINK-23302: - Hi [~ibzib] very thanks for reporting the issue! What flink version

[GitHub] [flink] flinkbot edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-876475935 ## CI report: * 1b3a0d615d4f69eafd023cb3a7dd6cd70e3d6673 Azure:

[GitHub] [flink] gaoyunhaii commented on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
gaoyunhaii commented on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877544691 Hi, I updated the PR according to the above comments. During the implementation and test I found that we would still need to keep tracking future to be atomic with event

[GitHub] [flink] flinkbot edited a comment on pull request #16446: [FLINK-23308] Replace regular SourceContext with a throwing one on close

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16446: URL: https://github.com/apache/flink/pull/16446#issuecomment-877162212 ## CI report: * ce8275c245eeaad5aacc99b64e23552c0381c4b4 Azure:

[jira] [Updated] (FLINK-17196) Improve the implementation of Fabric8FlinkKubeClient#getRestEndpoint

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-17196: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-18810) Golang remote functions SDK

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-18810?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-18810: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22816) Investigate feasibility of supporting multiple RM leader sessions within JM process

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22816: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-10896) Extend state schema evolution support for more types

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-10896?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-10896: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22827) Hive dialect supports CLUSTERED BY clause of CREATE TABLE DDL

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22827?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22827: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22764) Disable Values Source node in streaming plan optimization

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22764?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22764: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22449) Casting an invalid constant string to int throws exception from SinkNotNullEnforcer

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22449?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22449: --- Labels: auto-deprioritized-major (was: stale-major) Priority: Minor (was: Major)

[jira] [Updated] (FLINK-22834) KafkaITCase.testBigRecordJob times out on azure

2021-07-09 Thread Flink Jira Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22834?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Flink Jira Bot updated FLINK-22834: --- Labels: auto-deprioritized-major test-stability (was: stale-major test-stability)

[GitHub] [flink] gaoyunhaii edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
gaoyunhaii edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877487310 Very thanks @tillrohrmann for the review and very thanks @StephanEwen for the detail investigation and analysis! I also agree with chaining the futures as

[jira] [Updated] (FLINK-23342) State ownership: compute shared state on recovery

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23342?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23342: -- Description: # Introduce / refactor State object ID (consider StringBasedID, 

[GitHub] [flink] gaoyunhaii edited a comment on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
gaoyunhaii edited a comment on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877487310 Very thanks @tillrohrmann for the review and very thanks @StephanEwen for the detail investigation and analysis! I also agree with chaining the futures as

[GitHub] [flink] gaoyunhaii commented on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
gaoyunhaii commented on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877487310 Very thanks @tillrohrmann for the review and very thanks @StephanEwen for the detail investigation and analysis! I also agree with chaining the futures as

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state (registry+changelog)

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Summary: State ownership: track and discard private state (registry+changelog) (was:

[jira] [Updated] (FLINK-23344) State ownership: track and discard private state (rocks, heap)

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23344: -- Description: Inject TaskStateRegistry added in FLINK-23139 into existing state

[GitHub] [flink] gaoyunhaii commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
gaoyunhaii commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r667231362 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java ## @@ -72,19 +79,28 @@

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state (changelog)

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Description: TM should own changelog backend state to prevent re-uploading state on

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state (changelog)

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Summary: State ownership: track and discard private state (changelog) (was: State

[jira] [Created] (FLINK-23344) State ownership: track and discard private state (rocks, heap)

2021-07-09 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23344: - Summary: State ownership: track and discard private state (rocks, heap) Key: FLINK-23344 URL: https://issues.apache.org/jira/browse/FLINK-23344 Project:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * ff1952859f9a48186047c6ffe347efe3bea1a660 Azure:

[GitHub] [flink] sap1ens commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-07-09 Thread GitBox
sap1ens commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-877475470 > Has it been working for you otherwise? @galenwarren yep, so far so good  We'll use it more next week and share feedback. -- This is an automated message from the

[jira] [Created] (FLINK-23343) State ownership: prevent shared state deletion on TM

2021-07-09 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23343: - Summary: State ownership: prevent shared state deletion on TM Key: FLINK-23343 URL: https://issues.apache.org/jira/browse/FLINK-23343 Project: Flink

[GitHub] [flink] galenwarren commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-07-09 Thread GitBox
galenwarren commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-877474406 @xintongsong Sorry it's been a while since I've pushed code. I've just been really busy with other stuff, but I do want to get this wrapped up and it would be nice to get

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Description: (materialized and non-materialized, only changelog backend)   TM

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Summary: State ownership: track and discard private state (was: State ownership:

[jira] [Updated] (FLINK-23139) State ownership: track and discard private state (materialized and non-materialized)

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23139: -- Summary: State ownership: track and discard private state (materialized and

[jira] [Commented] (FLINK-23322) RMQSourceITCase.testStopWithSavepoint fails on azure due to timeout

2021-07-09 Thread Jira
[ https://issues.apache.org/jira/browse/FLINK-23322?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378320#comment-17378320 ] Michał Ciesielczyk commented on FLINK-23322: I've had a closer look and found out in

[jira] [Updated] (FLINK-23137) State ownership: prevent private state deletion on JM

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23137: -- Description: Inject shared state IDs computed in StateAssignmentOperation

[GitHub] [flink] sap1ens commented on pull request #15599: [FLINK-11838][flink-gs-fs-hadoop] Create Google Storage file system with recoverable writer support

2021-07-09 Thread GitBox
sap1ens commented on pull request #15599: URL: https://github.com/apache/flink/pull/15599#issuecomment-877470182 Hi, just wanted to suggest a few more changes. We've started using this branch and needed to add a few more things to `flink-dist`. `flink-dist/pom.xml`, line 369:

[jira] [Updated] (FLINK-23137) State ownership: prevent private state deletion on JM

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23137?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23137: -- Summary: State ownership: prevent private state deletion on JM (was: State

[jira] [Created] (FLINK-23342) State ownership: compute shared state on recovery

2021-07-09 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23342: - Summary: State ownership: compute shared state on recovery Key: FLINK-23342 URL: https://issues.apache.org/jira/browse/FLINK-23342 Project: Flink

[GitHub] [flink] sjwiesman commented on pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
sjwiesman commented on pull request #16448: URL: https://github.com/apache/flink/pull/16448#issuecomment-877469355 merged into master and release-1.13 -- 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

[GitHub] [flink] sjwiesman closed pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
sjwiesman closed pull request #16448: URL: https://github.com/apache/flink/pull/16448 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] alpinegizmo commented on a change in pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
alpinegizmo commented on a change in pull request #16448: URL: https://github.com/apache/flink/pull/16448#discussion_r667220263 ## File path: docs/content/release-notes/flink-1.13.md ## @@ -38,6 +38,22 @@ by default before) and there is no option to configure a synchronous

[GitHub] [flink] flinkbot edited a comment on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * efb7a931424fb31d3a7dce6369af829b136ece8c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16448: URL: https://github.com/apache/flink/pull/16448#issuecomment-877451436 ## CI report: * b607be37ed008e15a202ecd86b874089b179049e Azure:

[GitHub] [flink] sjwiesman commented on pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
sjwiesman commented on pull request #16448: URL: https://github.com/apache/flink/pull/16448#issuecomment-877458460 Changes applied -- 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 the specific

[GitHub] [flink] flinkbot commented on pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
flinkbot commented on pull request #16448: URL: https://github.com/apache/flink/pull/16448#issuecomment-877451436 ## CI report: * b607be37ed008e15a202ecd86b874089b179049e UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot commented on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-09 Thread GitBox
flinkbot commented on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877451350 ## CI report: * efb7a931424fb31d3a7dce6369af829b136ece8c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Updated] (FLINK-23170) Write metadata after materialization

2021-07-09 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-23170: -- Description: Currently, changelog state backend writes state metadata on first state

[GitHub] [flink] alpinegizmo commented on a change in pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
alpinegizmo commented on a change in pull request #16448: URL: https://github.com/apache/flink/pull/16448#discussion_r667197168 ## File path: docs/content.zh/release-notes/flink-1.13.md ## @@ -38,6 +38,20 @@ by default before) and there is no option to configure a synchronous

[GitHub] [flink] flinkbot commented on pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
flinkbot commented on pull request #16448: URL: https://github.com/apache/flink/pull/16448#issuecomment-877447312 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] sjwiesman opened a new pull request #16448: [hotfix][docs] Update release notes for 1.13 with state backend migra…

2021-07-09 Thread GitBox
sjwiesman opened a new pull request #16448: URL: https://github.com/apache/flink/pull/16448 …tion details -- 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 the specific comment. To

[jira] [Updated] (FLINK-23144) Add percentiles to checkpoint stats

2021-07-09 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-23144: --- Labels: pull-request-available (was: ) > Add percentiles to checkpoint stats >

[GitHub] [flink] flinkbot commented on pull request #16447: [FLINK-23144][metrics] Add percentiles to checkpoint statistics

2021-07-09 Thread GitBox
flinkbot commented on pull request #16447: URL: https://github.com/apache/flink/pull/16447#issuecomment-877438959 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] rkhachatryan opened a new pull request #16447: F23144

2021-07-09 Thread GitBox
rkhachatryan opened a new pull request #16447: URL: https://github.com/apache/flink/pull/16447 ## What is the purpose of the change Add percentiles to checkpoint statistics to better understand backends and checkpointing behaviour. ## Verifying this change - Added

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 118de16a5a386817bdcd65e0343e5a1d0fab1c2e Azure:

[GitHub] [flink] bytesandwich commented on a change in pull request #15898: [FLINK-21439][core] WIP: Adds Exception History for AdaptiveScheduler

2021-07-09 Thread GitBox
bytesandwich commented on a change in pull request #15898: URL: https://github.com/apache/flink/pull/15898#discussion_r667173863 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/scheduler/adaptive/StateWithExecutionGraph.java ## @@ -110,6 +121,22 @@

[GitHub] [flink] flinkbot edited a comment on pull request #16446: [FLINK-23308] Replace regular SourceContext with a throwing one on close

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16446: URL: https://github.com/apache/flink/pull/16446#issuecomment-877162212 ## CI report: * 5fae7e78e3947c10a3f2e2a05381d7647e5ca97d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16446: [FLINK-23308] Replace regular SourceContext with a throwing one on close

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16446: URL: https://github.com/apache/flink/pull/16446#issuecomment-877162212 ## CI report: * 5fae7e78e3947c10a3f2e2a05381d7647e5ca97d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * e280421bc1009e2462551e76f81c3ec980cf3f77 Azure:

[GitHub] [flink] tillrohrmann commented on a change in pull request #15812: remove slotpoolImpl

2021-07-09 Thread GitBox
tillrohrmann commented on a change in pull request #15812: URL: https://github.com/apache/flink/pull/15812#discussion_r666971878 ## File path: flink-runtime/src/test/java/org/apache/flink/runtime/jobmaster/slotpool/DeclarativeSlotPoolBridgeBuilder.java ## @@ -21,73 +21,84 @@

[jira] [Commented] (FLINK-23302) Precondition failed building CheckpointMetrics.

2021-07-09 Thread Kyle Weaver (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23302?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378238#comment-17378238 ] Kyle Weaver commented on FLINK-23302: - [~gaoyunhaii] I saw you have contributed to this code – do

[GitHub] [flink] flinkbot edited a comment on pull request #16399: FLIP-177 Draft: Extend Sink API

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16399: URL: https://github.com/apache/flink/pull/16399#issuecomment-874970474 ## CI report: * 41fe915190f13560e60e6b77c7159e462da0dfae Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-872940369 ## CI report: * e1210105c5a1f739f75f6d9ff68f00ccd64d013b Azure:

[jira] [Closed] (FLINK-23341) AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23341?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23341. Resolution: Duplicate >

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 1b2cc77ae6ec783bad99accd53467be8c9eb3d91 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15924: [FLINK-22670][FLIP-150][connector/common] Hybrid source baseline

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #15924: URL: https://github.com/apache/flink/pull/15924#issuecomment-841943851 ## CI report: * c95109768facc0535e3ca1b9da56cf4197fb4ba9 UNKNOWN * 1b2cc77ae6ec783bad99accd53467be8c9eb3d91 Azure:

[GitHub] [flink] StephanEwen commented on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
StephanEwen commented on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877346128 To re-summarize the failure cause: A failed RPC (failed result future) leads to the failure of the checkpoint and triggers a task failure. Then the tracking

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 546eb9257a0b64a4d965b457173b3c08cde58251 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16446: [FLINK-23308] Replace regular SourceContext with a throwing one on close

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16446: URL: https://github.com/apache/flink/pull/16446#issuecomment-877162212 ## CI report: * 5fae7e78e3947c10a3f2e2a05381d7647e5ca97d Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16332: [FLINK-22386] Introduce cache for docker images used during testing

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16332: URL: https://github.com/apache/flink/pull/16332#issuecomment-871230385 ## CI report: * 546eb9257a0b64a4d965b457173b3c08cde58251 Azure:

[jira] [Commented] (FLINK-23233) OperatorEventSendingCheckpointITCase.testOperatorEventLostWithReaderFailure fails on azure

2021-07-09 Thread Stephan Ewen (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23233?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378164#comment-17378164 ] Stephan Ewen commented on FLINK-23233: -- Thanks, [~gaoyunhaii] for debugging this. Your analysis of

[GitHub] [flink] flinkbot edited a comment on pull request #16445: [FLINK-23322][connectors/rabbitmq] Capture container log output of RM…

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16445: URL: https://github.com/apache/flink/pull/16445#issuecomment-877143095 ## CI report: * 5a0cf10a15e27f43e4e6e89382767491438daa76 Azure:

[jira] [Created] (FLINK-23341) AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-09 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23341: - Summary: AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure Key: FLINK-23341 URL:

[GitHub] [flink] StephanEwen commented on a change in pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
StephanEwen commented on a change in pull request #16432: URL: https://github.com/apache/flink/pull/16432#discussion_r667052349 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/operators/coordination/SubtaskGatewayImpl.java ## @@ -72,19 +79,28 @@

[GitHub] [flink] tillrohrmann commented on pull request #16432: [FLINK-23233][runtime] Failing checkpoints before failover for failed events in OperatorCoordinator

2021-07-09 Thread GitBox
tillrohrmann commented on pull request #16432: URL: https://github.com/apache/flink/pull/16432#issuecomment-877284936 Technically, both solutions should work (modulo Stephan's investigation of the two things). If we consider error handling being part of the event sending, then the

[GitHub] [flink] flinkbot edited a comment on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-872940369 ## CI report: * 25d8a08a42245175f94694e651c37f156484bb71 Azure:

[jira] [Comment Edited] (FLINK-23326) Bump flink-shaded-guava to 30.1.1

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17378115#comment-17378115 ] Chesnay Schepler edited comment on FLINK-23326 at 7/9/21, 3:16 PM: ---

[GitHub] [flink] tillrohrmann commented on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

2021-07-09 Thread GitBox
tillrohrmann commented on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-877261051 Thanks for sharing your thoughts @zentol and @pltbkd. I think this is a very important discussion to have. In general we do agree that we should try to speed up Flink's

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 09ac6e50da595b080878d1f18815d2a9fb251f13 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16357: [FLINK-23209] Introduce HeartbeatListener.notifyTargetUnreachable

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16357: URL: https://github.com/apache/flink/pull/16357#issuecomment-872940369 ## CI report: * 25d8a08a42245175f94694e651c37f156484bb71 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15938: [FLINK-11103][runtime] Set a configurable default uncaught exception handler for all entrypoints

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #15938: URL: https://github.com/apache/flink/pull/15938#issuecomment-842314070 ## CI report: * 2fff1ceaeb7a780060022d89c72f933e1125a52b Azure:

[jira] [Closed] (FLINK-23325) Bump flink-shaded-netty to 4.1.65

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23325?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23325. shaded-master: 0dafc0b3b7a7a436d65e054976c04d2a6dc05caf > Bump flink-shaded-netty to 4.1.65

[jira] [Closed] (FLINK-23299) Bump flink-shaded-zookeeper 3.5 to 3.5.9

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23299. Fix Version/s: (was: 1.14.0) Resolution: Fixed shaded-master:

[jira] [Closed] (FLINK-23291) Bump flink-shaded-jackson to 2.12.4

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23291. Resolution: Fixed shaded-master: 9fc48b10bcf273b8b8abd181301412387ad7df15

[GitHub] [flink-shaded] zentol merged pull request #98: [FLINK-23299] Bump Zookeeper to 3.5.9

2021-07-09 Thread GitBox
zentol merged pull request #98: URL: https://github.com/apache/flink-shaded/pull/98 -- 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 the specific comment. To unsubscribe, e-mail:

[jira] [Closed] (FLINK-23326) Bump flink-shaded-guava to 30.1.1

2021-07-09 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-23326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler closed FLINK-23326. Resolution: Fixed shaded-master: 5782380675a0bcfb85031e9985a9bd4ae5f19259 > Bump

[GitHub] [flink-shaded] zentol merged pull request #97: [FLINK-23291] Bump jackson to 2.12.4

2021-07-09 Thread GitBox
zentol merged pull request #97: URL: https://github.com/apache/flink-shaded/pull/97 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink-shaded] zentol merged pull request #96: [FLINK-23326] Bump guava to 30.1.1-jre

2021-07-09 Thread GitBox
zentol merged pull request #96: URL: https://github.com/apache/flink-shaded/pull/96 -- 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 the specific comment. To unsubscribe, e-mail:

[GitHub] [flink] flinkbot edited a comment on pull request #16444: [FLINK-23076][tests] Harden DispatcherTest.testWaitingForJobMasterLeadership

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16444: URL: https://github.com/apache/flink/pull/16444#issuecomment-877097274 ## CI report: * bc7d452f4875e0f2ac024271f1f81c7f41a55d26 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16441: [FLINK-23235][connector] Fix SinkITCase instability

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16441: URL: https://github.com/apache/flink/pull/16441#issuecomment-877063785 ## CI report: * 3f5e10bd9f8670ef3d91100055805bbc816ba754 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16399: FLIP-177 Draft: Extend Sink API

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16399: URL: https://github.com/apache/flink/pull/16399#issuecomment-874970474 ## CI report: * f9ab21f93316f297c67b0d195756e195f80cc690 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #16368: ignore

2021-07-09 Thread GitBox
flinkbot edited a comment on pull request #16368: URL: https://github.com/apache/flink/pull/16368#issuecomment-873854539 ## CI report: * 09ac6e50da595b080878d1f18815d2a9fb251f13 Azure:

  1   2   3   4   >