[jira] [Commented] (FLINK-22563) Add migration guide for new StateBackend interfaces

2021-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22563?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339285#comment-17339285 ] Seth Wiesman commented on FLINK-22563: -- fixed in 1.13: ff1005524641dc5cdcb8188aa9528f6c1a4b92a8

[GitHub] [flink-web] sjwiesman opened a new pull request #444: [hotfix] Link to StateBackend migration guide from the release notes

2021-05-04 Thread GitBox
sjwiesman opened a new pull request #444: URL: https://github.com/apache/flink-web/pull/444 **DO NOT MERGE** until the after the next docs rebuild. Otherwise the link will 404 :) -- This is an automated message from the Apache Git Service. To respond to the message, please log on to

[GitHub] [flink] flinkbot commented on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-04 Thread GitBox
flinkbot commented on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-832197189 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 #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15831: URL: https://github.com/apache/flink/pull/15831#issuecomment-832154834 ## CI report: * a53ddc5b667675d973e9b868616693137860754c Azure:

[GitHub] [flink] NicoK commented on pull request #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
NicoK commented on pull request #15831: URL: https://github.com/apache/flink/pull/15831#issuecomment-832207746 @flinkbot approve all -- 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 #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-04 Thread GitBox
flinkbot commented on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-832214416 ## CI report: * a14a487a208ab8c5ea047665e472fd27f829e51c UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] flinkbot edited a comment on pull request #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15831: URL: https://github.com/apache/flink/pull/15831#issuecomment-832154834 ## CI report: * a53ddc5b667675d973e9b868616693137860754c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15831: URL: https://github.com/apache/flink/pull/15831#issuecomment-832154834 ## CI report: * a53ddc5b667675d973e9b868616693137860754c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-832214416 ## CI report: * a14a487a208ab8c5ea047665e472fd27f829e51c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15829: [FLINK-22266][hotfix] Do not clean up jobs in AbstractTestBase if the MiniCluster is not running

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15829: URL: https://github.com/apache/flink/pull/15829#issuecomment-832067869 ## CI report: * c3cd1869dd193119c55d514913fabb4da1e41ed7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * f2158c0730f5bfe61d13d8f0850b40059a3bfadc Azure:

[GitHub] [flink] sjwiesman commented on pull request #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
sjwiesman commented on pull request #15831: URL: https://github.com/apache/flink/pull/15831#issuecomment-832165703 Thanks for the fast review @NicoK, I've applied your changes to both files -- This is an automated message from the Apache Git Service. To respond to the message, please log

[jira] [Updated] (FLINK-22494) Avoid discarding checkpoints in case of failure

2021-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22494: --- Labels: pull-request-available (was: ) > Avoid discarding checkpoints in case of failure >

[jira] [Closed] (FLINK-22563) Add migration guide for new StateBackend interfaces

2021-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman closed FLINK-22563. Resolution: Fixed > Add migration guide for new StateBackend interfaces >

[jira] [Updated] (FLINK-22563) Add migration guide for new StateBackend interfaces

2021-05-04 Thread Seth Wiesman (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22563?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Seth Wiesman updated FLINK-22563: - Fix Version/s: 1.13.1 1.14.0 > Add migration guide for new StateBackend

[GitHub] [flink] XComp opened a new pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-04 Thread GitBox
XComp opened a new pull request #15832: URL: https://github.com/apache/flink/pull/15832 ## What is the purpose of the change Updating the Checkpoint Metadata store of ZooKeeper and Kubernetes might lead into situations where the data was actually written but the request still

[GitHub] [flink] sjwiesman closed pull request #15831: [FLINK-22563][docs] Add migration guide for new StateBackend interfaces

2021-05-04 Thread GitBox
sjwiesman closed pull request #15831: URL: https://github.com/apache/flink/pull/15831 -- 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. For queries about this service,

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * f3c98471c5902ebf1ad8528235d4854c0c0a3cc0 Azure:

[GitHub] [flink] LinyuYao1021 commented on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-04 Thread GitBox
LinyuYao1021 commented on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832339034 @flinkbot run azure -- 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

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * f3c98471c5902ebf1ad8528235d4854c0c0a3cc0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * f3c98471c5902ebf1ad8528235d4854c0c0a3cc0 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15832: [FLINK-22494][ha] Introduce PossibleInconsistentStateException

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15832: URL: https://github.com/apache/flink/pull/15832#issuecomment-832214416 ## CI report: * a14a487a208ab8c5ea047665e472fd27f829e51c Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15830: [FLINK-22515][docs] Add documentation for GSR-Flink Integration

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15830: URL: https://github.com/apache/flink/pull/15830#issuecomment-832141758 ## CI report: * f3c98471c5902ebf1ad8528235d4854c0c0a3cc0 Azure:

[jira] [Commented] (FLINK-22555) LGPL-2.1 files in flink-python jars

2021-05-04 Thread Robert Metzger (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338771#comment-17338771 ] Robert Metzger commented on FLINK-22555: I will look into extending the license checker for

[jira] [Created] (FLINK-22556) Extend license checker to scan for traces of (L)GPL licensed code

2021-05-04 Thread Robert Metzger (Jira)
Robert Metzger created FLINK-22556: -- Summary: Extend license checker to scan for traces of (L)GPL licensed code Key: FLINK-22556 URL: https://issues.apache.org/jira/browse/FLINK-22556 Project: Flink

[jira] [Commented] (FLINK-22557) Japicmp fails on 1.12 branch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338817#comment-17338817 ] Dawid Wysakowicz commented on FLINK-22557: -- It happens for scala 2.12 only. > Japicmp fails on

[jira] [Created] (FLINK-22557) Japicmp fails on 1.12 branch

2021-05-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22557: Summary: Japicmp fails on 1.12 branch Key: FLINK-22557 URL: https://issues.apache.org/jira/browse/FLINK-22557 Project: Flink Issue Type: Bug

[jira] [Closed] (FLINK-22432) Update upgrading.md with 1.13.x

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz closed FLINK-22432. Resolution: Fixed > Update upgrading.md with 1.13.x > --- > >

[jira] [Commented] (FLINK-22432) Update upgrading.md with 1.13.x

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22432?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338830#comment-17338830 ] Dawid Wysakowicz commented on FLINK-22432: -- Implemented in: * master **

[jira] [Assigned] (FLINK-22379) Do not trigger checkpoint when non source tasks are INITIALIZING

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22379: -- Assignee: Anton Kalashnikov > Do not trigger checkpoint when non source tasks are

[GitHub] [flink] flinkbot edited a comment on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-829351182 ## CI report: * 37ed232bf76ead04550e8f770a1280bebcfab326 UNKNOWN * 58c0870f82a6e08c901500cf504955f08ae304ea Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * 298a03029ffb6012dafd28348442e32fba364588 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-829351182 ## CI report: * 18592abce53b12b5cb99ac02df8f529c8a544ef1 Azure:

[jira] [Commented] (FLINK-21431) UpsertKafkaTableITCase.testTemporalJoin hang

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338819#comment-17338819 ] Dawid Wysakowicz commented on FLINK-21431: --

[jira] [Created] (FLINK-22558) testcontainers fail to start ResourceReaper

2021-05-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22558: Summary: testcontainers fail to start ResourceReaper Key: FLINK-22558 URL: https://issues.apache.org/jira/browse/FLINK-22558 Project: Flink Issue

[jira] [Commented] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338825#comment-17338825 ] Dawid Wysakowicz commented on FLINK-22548: --

[GitHub] [flink] flinkbot commented on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot commented on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831748236 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-22376) SequentialChannelStateReaderImpl may recycle buffer twice

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22376: --- Priority: Critical (was: Minor) > SequentialChannelStateReaderImpl may recycle buffer

[jira] [Updated] (FLINK-22559) UpsertKafkaTableITCase fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22559: - Summary: UpsertKafkaTableITCase fails with output mismatch (was:

[jira] [Updated] (FLINK-22376) SequentialChannelStateReaderImpl may recycle buffer twice

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22376?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22376: --- Fix Version/s: 1.13.1 > SequentialChannelStateReaderImpl may recycle buffer twice >

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338827#comment-17338827 ] Dawid Wysakowicz commented on FLINK-22559: --

[jira] [Assigned] (FLINK-21131) Show alignment timeout in checkpoint configuration (web UI)

2021-05-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-21131: - Assignee: Anton Kalashnikov > Show alignment timeout in checkpoint

[GitHub] [flink] flinkbot edited a comment on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * 298a03029ffb6012dafd28348442e32fba364588 Azure:

[jira] [Updated] (FLINK-22559) UpsertKafkaTableITCase fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22559: - Affects Version/s: 1.13.0 > UpsertKafkaTableITCase fails with output mismatch >

[GitHub] [flink] flinkbot edited a comment on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * 298a03029ffb6012dafd28348442e32fba364588 Azure:

[GitHub] [flink] zentol opened a new pull request #15827: [FLINK-22555][build][python] Exclude leftover jboss files

2021-05-04 Thread GitBox
zentol opened a new pull request #15827: URL: https://github.com/apache/flink/pull/15827 Removes auto-generated maven metadata from all jars as this may accidentally bundle poms under incompatible licenses, and adds another exclusions for jboss schema files contained in flink-python. --

[GitHub] [flink] dawidwys commented on a change in pull request #15789: [FLINK-21181][runtime] Wait for Invokable cancellation before releasing network resources

2021-05-04 Thread GitBox
dawidwys commented on a change in pull request #15789: URL: https://github.com/apache/flink/pull/15789#discussion_r625661050 ## File path: flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java ## @@ -1574,6 +1574,12 @@ public void run() {

[jira] [Commented] (FLINK-21519) SQLClientHBaseITCase hangs on azure

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338806#comment-17338806 ] Dawid Wysakowicz commented on FLINK-21519: --

[GitHub] [flink] pnowojski commented on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
pnowojski commented on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-831733422 Thanks for the suggestions @alpinegizmo! Yes, uc timeout is counted against subtask's alignment time. -- This is an automated message from the Apache Git Service. To

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338823#comment-17338823 ] Dawid Wysakowicz commented on FLINK-22559: --

[jira] [Updated] (FLINK-17170) Cannot stop streaming job with savepoint which uses kinesis consumer

2021-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-17170: --- Labels: pull-request-available stale-critical usability (was: stale-critical usability) >

[GitHub] [flink] flinkbot edited a comment on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-829351182 ## CI report: * 18592abce53b12b5cb99ac02df8f529c8a544ef1 Azure:

[GitHub] [flink] dawidwys merged pull request #15735: [FLINK-22432] Update upgrading.md with 1.13.x

2021-05-04 Thread GitBox
dawidwys merged pull request #15735: URL: https://github.com/apache/flink/pull/15735 -- 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. For queries about this service,

[jira] [Updated] (FLINK-22432) Update upgrading.md with 1.13.x

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22432?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dawid Wysakowicz updated FLINK-22432: - Fix Version/s: 1.13.0 > Update upgrading.md with 1.13.x >

[GitHub] [flink] flinkbot edited a comment on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-829351182 ## CI report: * 18592abce53b12b5cb99ac02df8f529c8a544ef1 Azure:

[GitHub] [flink] flinkbot commented on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot commented on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * 298a03029ffb6012dafd28348442e32fba364588 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink-docker] zentol commented on pull request #74: Updated maintainers

2021-05-04 Thread GitBox
zentol commented on pull request #74: URL: https://github.com/apache/flink-docker/pull/74#issuecomment-831764779 > Not sure why you need to list maintainers here in the first place... Because the docker folks require it:

[jira] [Created] (FLINK-22560) Filter maven metadata from all jars

2021-05-04 Thread Chesnay Schepler (Jira)
Chesnay Schepler created FLINK-22560: Summary: Filter maven metadata from all jars Key: FLINK-22560 URL: https://issues.apache.org/jira/browse/FLINK-22560 Project: Flink Issue Type:

[GitHub] [flink] flinkbot commented on pull request #15827: [FLINK-22555][build][python] Exclude leftover jboss files

2021-05-04 Thread GitBox
flinkbot commented on pull request #15827: URL: https://github.com/apache/flink/pull/15827#issuecomment-831829389 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] [Commented] (FLINK-22557) Japicmp fails on 1.12 branch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338818#comment-17338818 ] Dawid Wysakowicz commented on FLINK-22557: -- Could you take a look [~AHeise] [~chesnay]? You

[jira] [Commented] (FLINK-20498) SQLClientSchemaRegistryITCase.testReading test timed out after 120000 milliseconds

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-20498?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338822#comment-17338822 ] Dawid Wysakowicz commented on FLINK-20498: --

[GitHub] [flink] AHeise opened a new pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
AHeise opened a new pull request #15826: URL: https://github.com/apache/flink/pull/15826 ## What is the purpose of the change During stop-with-savepoint cancel is called under lock in legacy sources. Thus, if the fetcher is trying to emit a record at the same time, it

[jira] [Created] (FLINK-22559) UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
Dawid Wysakowicz created FLINK-22559: Summary: UpsertKafkaTableITCase.testKafkaSourceSinkWithKeyAndFullValue fails with output mismatch Key: FLINK-22559 URL: https://issues.apache.org/jira/browse/FLINK-22559

[jira] [Commented] (FLINK-22559) UpsertKafkaTableITCase fails with output mismatch

2021-05-04 Thread Dawid Wysakowicz (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22559?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338828#comment-17338828 ] Dawid Wysakowicz commented on FLINK-22559: -- This test fails all over the place in the linked

[GitHub] [flink] dawidwys commented on pull request #15735: [FLINK-22432] Update upgrading.md with 1.13.x

2021-05-04 Thread GitBox
dawidwys commented on pull request #15735: URL: https://github.com/apache/flink/pull/15735#issuecomment-831750013 Merging. -- 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.

[GitHub] [flink] alpinegizmo commented on a change in pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
alpinegizmo commented on a change in pull request #15811: URL: https://github.com/apache/flink/pull/15811#discussion_r625598632 ## File path: docs/content/docs/ops/state/checkpoints.md ## @@ -219,10 +212,10 @@ state. To support rescaling, watermarks should be stored per

[jira] [Updated] (FLINK-22377) Ignore if writer is stopped when aborting channel state writing

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22377?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22377: --- Description: When channel state write is being aborted it can happen that writer is already

[jira] [Created] (FLINK-22561) Restore checkpoint from another cluster

2021-05-04 Thread zhang haoyan (Jira)
zhang haoyan created FLINK-22561: Summary: Restore checkpoint from another cluster Key: FLINK-22561 URL: https://issues.apache.org/jira/browse/FLINK-22561 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-22556) Extend license checker to scan for traces of (L)GPL licensed code

2021-05-04 Thread Chesnay Schepler (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chesnay Schepler reassigned FLINK-22556: Assignee: Chesnay Schepler > Extend license checker to scan for traces of (L)GPL

[jira] [Updated] (FLINK-22555) LGPL-2.1 files in flink-python jars

2021-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22555: --- Labels: pull-request-available (was: ) > LGPL-2.1 files in flink-python jars >

[jira] [Closed] (FLINK-22253) Update backpressure monitoring documentation

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22253?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22253. -- Fix Version/s: 1.13.1 Resolution: Fixed merged to master as baf27ef7266 merged to

[jira] [Commented] (FLINK-22555) LGPL-2.1 files in flink-python jars

2021-05-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338900#comment-17338900 ] Till Rohrmann commented on FLINK-22555: --- cc [~dianfu]. > LGPL-2.1 files in flink-python jars >

[jira] [Updated] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread ASF GitHub Bot (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] ASF GitHub Bot updated FLINK-22548: --- Labels: pull-request-available test-stability (was: test-stability) >

[GitHub] [flink] flinkbot edited a comment on pull request #15828: [FLINK-22548][network] Remove illegal unsynchronized access to PipelinedSubpartition#buffers

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15828: URL: https://github.com/apache/flink/pull/15828#issuecomment-831863456 ## CI report: * 0f517580ee7a2f8062913a8be96f01c95180c390 Azure:

[GitHub] [flink] pnowojski merged pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
pnowojski merged pull request #15811: URL: https://github.com/apache/flink/pull/15811 -- 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. For queries about this service,

[jira] [Comment Edited] (FLINK-22535) Resource leak would happen if exception thrown during AbstractInvokable#restore of task life

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338367#comment-17338367 ] Piotr Nowojski edited comment on FLINK-22535 at 5/4/21, 10:20 AM: --

[GitHub] [flink] zentol commented on a change in pull request #15827: [FLINK-22555][build][python] Exclude leftover jboss files

2021-05-04 Thread GitBox
zentol commented on a change in pull request #15827: URL: https://github.com/apache/flink/pull/15827#discussion_r625691675 ## File path: pom.xml ## @@ -1748,6 +1748,7 @@ under the License.

[GitHub] [flink] zentol merged pull request #15738: modify annotation

2021-05-04 Thread GitBox
zentol merged pull request #15738: URL: https://github.com/apache/flink/pull/15738 -- 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. For queries about this service, please

[GitHub] [flink] pnowojski merged pull request #15828: [FLINK-22548][network] Remove illegal unsynchronized access to PipelinedSubpartition#buffers

2021-05-04 Thread GitBox
pnowojski merged pull request #15828: URL: https://github.com/apache/flink/pull/15828 -- 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. For queries about this service,

[jira] [Resolved] (FLINK-21131) Show alignment timeout in checkpoint configuration (web UI)

2021-05-04 Thread Roman Khachatryan (Jira)
[ https://issues.apache.org/jira/browse/FLINK-21131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-21131. --- Fix Version/s: 1.14.0 Resolution: Fixed Merged into master as

[jira] [Created] (FLINK-22562) Translate recent updates to backpressure and checkpointing docs

2021-05-04 Thread Piotr Nowojski (Jira)
Piotr Nowojski created FLINK-22562: -- Summary: Translate recent updates to backpressure and checkpointing docs Key: FLINK-22562 URL: https://issues.apache.org/jira/browse/FLINK-22562 Project: Flink

[jira] [Comment Edited] (FLINK-22253) Update backpressure monitoring documentation

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22253?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338897#comment-17338897 ] Piotr Nowojski edited comment on FLINK-22253 at 5/4/21, 10:24 AM: --

[jira] [Commented] (FLINK-22173) UnalignedCheckpointRescaleITCase fails on azure

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338905#comment-17338905 ] Piotr Nowojski commented on FLINK-22173: [~roman_khachatryan], your issue is unrelated to this

[GitHub] [flink] flinkbot commented on pull request #15828: [FLINK-22548][network] Remove illegal unsynchronized access to PipelinedSubpartition#buffers

2021-05-04 Thread GitBox
flinkbot commented on pull request #15828: URL: https://github.com/apache/flink/pull/15828#issuecomment-831846667 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 merged pull request #15772: [FLINK-21131][webui] Alignment timeout displayed in checkpoint config…

2021-05-04 Thread GitBox
rkhachatryan merged pull request #15772: URL: https://github.com/apache/flink/pull/15772 -- 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. For queries about this service,

[GitHub] [flink] pnowojski commented on pull request #15811: [FLINK-22253][docs] Update back pressure monitoring docs with new WebUI changes

2021-05-04 Thread GitBox
pnowojski commented on pull request #15811: URL: https://github.com/apache/flink/pull/15811#issuecomment-831834103 Thanks a lot! I've included that last one suggestion and I'm going to merge it soon. -- This is an automated message from the Apache Git Service. To respond to the message,

[jira] [Assigned] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski reassigned FLINK-22548: -- Assignee: Piotr Nowojski >

[GitHub] [flink] flinkbot commented on pull request #15827: [FLINK-22555][build][python] Exclude leftover jboss files

2021-05-04 Thread GitBox
flinkbot commented on pull request #15827: URL: https://github.com/apache/flink/pull/15827#issuecomment-831839655 ## CI report: * 054af9b357b26f41fd879384b1a0fe3b35cc UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[jira] [Commented] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17338903#comment-17338903 ] Piotr Nowojski commented on FLINK-22548: This is just a TRACE logging issue. There was indeed a

[GitHub] [flink] pnowojski opened a new pull request #15828: [FLINK-22548][network] Remove illegal unsynchronized access to PipelinedSubpartition#buffers

2021-05-04 Thread GitBox
pnowojski opened a new pull request #15828: URL: https://github.com/apache/flink/pull/15828 After peeking last buffer, this last buffer could have been processed and recycled by the task thread, before NetworkActionsLogger.traceRecover would manage to check it's content causing

[GitHub] [flink] flinkbot edited a comment on pull request #15827: [FLINK-22555][build][python] Exclude leftover jboss files

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15827: URL: https://github.com/apache/flink/pull/15827#issuecomment-831839655 ## CI report: * 054af9b357b26f41fd879384b1a0fe3b35cc Azure:

[GitHub] [flink] flinkbot commented on pull request #15828: [FLINK-22548][network] Remove illegal unsynchronized access to PipelinedSubpartition#buffers

2021-05-04 Thread GitBox
flinkbot commented on pull request #15828: URL: https://github.com/apache/flink/pull/15828#issuecomment-831863456 ## CI report: * 0f517580ee7a2f8062913a8be96f01c95180c390 UNKNOWN Bot commands The @flinkbot bot supports the following commands: - `@flinkbot

[GitHub] [flink] dannycranmer commented on a change in pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
dannycranmer commented on a change in pull request #15826: URL: https://github.com/apache/flink/pull/15826#discussion_r625742538 ## File path: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisITCase.java ## @@

[GitHub] [flink] AHeise commented on a change in pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
AHeise commented on a change in pull request #15826: URL: https://github.com/apache/flink/pull/15826#discussion_r625931365 ## File path: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/KinesaliteContainer.java ## @@ -0,0

[GitHub] [flink] AHeise commented on a change in pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
AHeise commented on a change in pull request #15826: URL: https://github.com/apache/flink/pull/15826#discussion_r625931801 ## File path: flink-connectors/flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisITCase.java ## @@ -0,0

[GitHub] [flink] flinkbot edited a comment on pull request #15829: [FLINK-22266][hotfix] Do not clean up jobs in AbstractTestBase if the MiniCluster is not running

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15829: URL: https://github.com/apache/flink/pull/15829#issuecomment-832067869 ## CI report: * c3cd1869dd193119c55d514913fabb4da1e41ed7 Azure:

[GitHub] [flink] flinkbot edited a comment on pull request #15826: [FLINK-17170][kinesis] Fix deadlock during stop-with-savepoint.

2021-05-04 Thread GitBox
flinkbot edited a comment on pull request #15826: URL: https://github.com/apache/flink/pull/15826#issuecomment-831762997 ## CI report: * ebdf6f053c6e8c2b07e40af8629a2a5954e37b10 Azure:

[jira] [Commented] (FLINK-22266) Harden JobMasterStopWithSavepointITCase

2021-05-04 Thread Till Rohrmann (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22266?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17339140#comment-17339140 ] Till Rohrmann commented on FLINK-22266: --- Thanks for the analysis [~dwysakowicz]. [~rmetzger]

[jira] [Closed] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski closed FLINK-22548. -- Fix Version/s: (was: 1.13.1) Resolution: Fixed merged commit 1554292 into

[jira] [Updated] (FLINK-22548) UnalignedCheckpointRescaleITCase.shouldRescaleUnalignedCheckpoint fail due to IllegalReferenceCountException

2021-05-04 Thread Piotr Nowojski (Jira)
[ https://issues.apache.org/jira/browse/FLINK-22548?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Piotr Nowojski updated FLINK-22548: --- Affects Version/s: (was: 1.13.0) >

  1   2   >