[jira] [Updated] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22053: Description: If more splits than {noformat} Caused by: java.lang.IllegalArgumentException:

[jira] [Assigned] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22053: --- Assignee: (was: Arvid Heise) > NumberSequenceSource causes fatal exception when less

[jira] [Updated] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22053: Description: If more splits than {noformat} Caused by: java.lang.IllegalArgumentException:

[jira] [Updated] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22053: Description: If more splits than {noformat} Caused by: java.lang.IllegalArgumentException:

[jira] [Updated] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22053: Description: If more splits than {noformat} Caused by: java.lang.IllegalArgumentException:

[jira] [Resolved] (FLINK-21945) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21945?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21945. - Fix Version/s: 1.13.0 Resolution: Fixed Merged into master as

[jira] [Created] (FLINK-22053) Recovery of a completed split in NumberSequenceSource causes fatal exception.

Arvid Heise created FLINK-22053: --- Summary: Recovery of a completed split in NumberSequenceSource causes fatal exception. Key: FLINK-22053 URL: https://issues.apache.org/jira/browse/FLINK-22053 Project:

[jira] [Commented] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17312892#comment-17312892 ] Arvid Heise commented on FLINK-22053: - Merged into master as

[jira] [Resolved] (FLINK-22053) NumberSequenceSource causes fatal exception when less splits than parallelism.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22053. - Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed > NumberSequenceSource

[jira] [Assigned] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22081: --- Assignee: Chen Qin (was: Prem Santosh) > Entropy key not resolved if flink-s3-fs-hadoop

[jira] [Commented] (FLINK-13550) Support for CPU FlameGraphs in new web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17313104#comment-17313104 ] Arvid Heise commented on FLINK-13550: - Merged into master for 1.13 as

[jira] [Closed] (FLINK-13552) Render vertex FlameGraph in web UI

[ https://issues.apache.org/jira/browse/FLINK-13552?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-13552. --- Release Note: Directly resolved in parent ticket. Resolution: Done > Render vertex FlameGraph

[jira] [Closed] (FLINK-13551) Add vertex FlameGraph REST endpoint

[ https://issues.apache.org/jira/browse/FLINK-13551?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-13551. --- Release Note: Directly resolved in parent ticket. Resolution: Fixed > Add vertex FlameGraph

[jira] [Resolved] (FLINK-13550) Support for CPU FlameGraphs in new web UI

[ https://issues.apache.org/jira/browse/FLINK-13550?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-13550. - Fix Version/s: 1.13.0 Release Note: Flink now offers Flamegraphs for each node in the job

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307383#comment-17307383 ] Arvid Heise commented on FLINK-21936: - As a first step, we might want to provide users an explicit

[jira] [Created] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

Arvid Heise created FLINK-21936: --- Summary: Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints Key: FLINK-21936 URL: https://issues.apache.org/jira/browse/FLINK-21936

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307386#comment-17307386 ] Arvid Heise commented on FLINK-21936: - Alternatively or additionally, we might want to add the keyed

[jira] [Commented] (FLINK-21936) Disable checkpointing of inflight data in pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17307388#comment-17307388 ] Arvid Heise commented on FLINK-21936: - A completely different approach would be possible with

[jira] [Created] (FLINK-21992) Investigate potential buffer leak in unaligned checkpoint

Arvid Heise created FLINK-21992: --- Summary: Investigate potential buffer leak in unaligned checkpoint Key: FLINK-21992 URL: https://issues.apache.org/jira/browse/FLINK-21992 Project: Flink

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299809#comment-17299809 ] Arvid Heise commented on FLINK-21535: - A quick assessment of the 3 cases: the test is just running

[jira] [Resolved] (FLINK-19801) Add support for virtual channels

[ https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19801. - Resolution: Fixed > Add support for virtual channels > > >

[jira] [Commented] (FLINK-19801) Add support for virtual channels

[ https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299805#comment-17299805 ] Arvid Heise commented on FLINK-19801: - Merged as

[jira] [Comment Edited] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17299809#comment-17299809 ] Arvid Heise edited comment on FLINK-21535 at 3/11/21, 6:54 PM: --- A quick

[jira] [Created] (FLINK-21797) Performance regression on 03/11/21

Arvid Heise created FLINK-21797: --- Summary: Performance regression on 03/11/21 Key: FLINK-21797 URL: https://issues.apache.org/jira/browse/FLINK-21797 Project: Flink Issue Type: Improvement

[jira] [Commented] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17304783#comment-17304783 ] Arvid Heise commented on FLINK-20130: - Remerged as a407322a452b8a371d0ce25e8f5f8418556371ef into

[jira] [Resolved] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20130. - Resolution: Fixed > Add ZStandard format to inputs > -- > >

[jira] [Closed] (FLINK-21689) UnalignedCheckpointITCase does not terminate

[ https://issues.apache.org/jira/browse/FLINK-21689?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21689. --- Resolution: Duplicate > UnalignedCheckpointITCase does not terminate >

[jira] [Closed] (FLINK-21540) finegrained_resource_management tests hang on azure

[ https://issues.apache.org/jira/browse/FLINK-21540?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21540. --- Resolution: Duplicate > finegrained_resource_management tests hang on azure >

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17300147#comment-17300147 ] Arvid Heise commented on FLINK-21535: - I verified that FLINK-21540, FLINK-21599, and FLINK-21689 are

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301851#comment-17301851 ] Arvid Heise commented on FLINK-21535: - Merged as c177d15323d5025f0cf737b98bb051efbc08a149 into

[jira] [Commented] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17301877#comment-17301877 ] Arvid Heise commented on FLINK-20130: - Merged into master as

[jira] [Assigned] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20130: --- Assignee: João Boto > Add ZStandard format to inputs > -- > >

[jira] [Resolved] (FLINK-20130) Add ZStandard format to inputs

[ https://issues.apache.org/jira/browse/FLINK-20130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20130. - Fix Version/s: 1.13.0 Resolution: Fixed > Add ZStandard format to inputs >

[jira] [Resolved] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21535. - Fix Version/s: 1.12.3 1.13.0 Resolution: Fixed >

[jira] [Commented] (FLINK-21535) UnalignedCheckpointITCase.execute failed with "OutOfMemoryError: Java heap space"

[ https://issues.apache.org/jira/browse/FLINK-21535?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17302747#comment-17302747 ] Arvid Heise commented on FLINK-21535: - Merged as 755a8d8214554c64e9db0271a827485208185b8d into 1.12.

[jira] [Commented] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17292715#comment-17292715 ] Arvid Heise commented on FLINK-21511: - Thank you [~zhangmeng0426] for bringing this up and doing the

[jira] [Assigned] (FLINK-21511) Flink connector elasticsearch 6.x has a bug about BulkProcessor hangs for threads deadlocked

[ https://issues.apache.org/jira/browse/FLINK-21511?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21511: --- Assignee: zhangmeng > Flink connector elasticsearch 6.x has a bug about BulkProcessor

[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=17291119#comment-17291119 ] Arvid Heise commented on FLINK-17510: -

[jira] [Commented] (FLINK-21452) FLIP-27 sources cannot reliably downscale

[ https://issues.apache.org/jira/browse/FLINK-21452?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291153#comment-17291153 ] Arvid Heise commented on FLINK-21452: - Merged as fb99ce2e22ca84dece1f7a431a92a4cecb6a71f2^ in 1.12

[jira] [Resolved] (FLINK-21452) FLIP-27 sources cannot reliably downscale

[ https://issues.apache.org/jira/browse/FLINK-21452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21452. - Resolution: Fixed > FLIP-27 sources cannot reliably downscale >

[jira] [Updated] (FLINK-21452) FLIP-27 sources cannot reliably downscale

[ https://issues.apache.org/jira/browse/FLINK-21452?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21452: Description: Sources currently store their registered readers into the snapshot. However, when

[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=17291126#comment-17291126 ] Arvid Heise commented on FLINK-17510: -

[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=17291114#comment-17291114 ] Arvid Heise commented on FLINK-17510: -

[jira] [Commented] (FLINK-21490) UnalignedCheckpointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17291140#comment-17291140 ] Arvid Heise commented on FLINK-21490: - Merged as 29abccd4cb7d4905fa168f8d7b68a113e9640fca^ in master

[jira] [Resolved] (FLINK-21490) UnalignedCheckpointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21490?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21490. - Resolution: Fixed > UnalignedCheckpointITCase fails on azure >

[jira] [Created] (FLINK-21452) FLIP-27 sources cannot reliably downscale

Arvid Heise created FLINK-21452: --- Summary: FLIP-27 sources cannot reliably downscale Key: FLINK-21452 URL: https://issues.apache.org/jira/browse/FLINK-21452 Project: Flink Issue Type:

[jira] [Commented] (FLINK-21490) UnalignedCheckpointITCase fails on azure

[ https://issues.apache.org/jira/browse/FLINK-21490?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17290742#comment-17290742 ] Arvid Heise commented on FLINK-21490: - The error is probably test-only: For some reason the test

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316515#comment-17316515 ] Arvid Heise commented on FLINK-20816: - [~yunta]'s analysis is spot on; there is not much to add as

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316519#comment-17316519 ] Arvid Heise commented on FLINK-20816: - Indeed

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

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317784#comment-17317784 ] Arvid Heise commented on FLINK-22173: - Browsing through the log, we first have some issues on

[jira] [Commented] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316684#comment-17316684 ] Arvid Heise commented on FLINK-21873: - Merged into master as

[jira] [Resolved] (FLINK-21873) CoordinatedSourceRescaleITCase.testUpscaling fails on AZP

[ https://issues.apache.org/jira/browse/FLINK-21873?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21873. - Fix Version/s: (was: 1.14.0) 1.13.0 Resolution: Fixed >

[jira] [Comment Edited] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317839#comment-17317839 ] Arvid Heise edited comment on FLINK-20816 at 4/9/21, 10:00 AM: --- With some

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317847#comment-17317847 ] Arvid Heise commented on FLINK-20816: - That is actually be design of the test {noformat}

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17317839#comment-17317839 ] Arvid Heise commented on FLINK-20816: - With some more echo debugging, it's most likely caused by

[jira] [Commented] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316922#comment-17316922 ] Arvid Heise commented on FLINK-22081: - Merged into master as 2d3559e66db, into 1.12 as a9b34a3db23,

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22081: Fix Version/s: (was: 1.10.4) (was: 1.12.2) (was:

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22081: Affects Version/s: 1.13.0 1.10.3 1.11.3

[jira] [Updated] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22081: Priority: Major (was: Minor) > Entropy key not resolved if flink-s3-fs-hadoop is added as a

[jira] [Commented] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316924#comment-17316924 ] Arvid Heise commented on FLINK-22081: - Merging into 1.10 is quite an effort and the version is

[jira] [Resolved] (FLINK-22081) Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin

[ https://issues.apache.org/jira/browse/FLINK-22081?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22081. - Resolution: Fixed > Entropy key not resolved if flink-s3-fs-hadoop is added as a plugin >

[jira] [Commented] (FLINK-22190) no guarantee on Flink exactly_once sink to Kafka

[ https://issues.apache.org/jira/browse/FLINK-22190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319910#comment-17319910 ] Arvid Heise commented on FLINK-22190: - 1. You get byZeroException because you are dividing by 0 in

[jira] [Updated] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21992: Summary: Fix availability notification in UnionInputGate (was: Investigate potential buffer leak

[jira] [Commented] (FLINK-21992) Investigate potential buffer leak in unaligned checkpoint

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319986#comment-17319986 ] Arvid Heise commented on FLINK-21992: - It turns out that there is an issue with notification. We

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

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319992#comment-17319992 ] Arvid Heise commented on FLINK-22173: - I'm expecting some connection to FLINK-21992. >

[jira] [Assigned] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21992: --- Assignee: Arvid Heise (was: Piotr Nowojski) > Fix availability notification in

[jira] [Comment Edited] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:25 AM: --- -I guess

[jira] [Comment Edited] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise edited comment on FLINK-22259 at 4/15/21, 7:08 AM: --- -I guess

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

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22173. - Assignee: Arvid Heise Resolution: Cannot Reproduce > UnalignedCheckpointRescaleITCase

[jira] [Commented] (FLINK-22019) UnalignedCheckpointRescaleITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322118#comment-17322118 ] Arvid Heise commented on FLINK-22019: - Let's wait for FLINK-21346 for more investigation. >

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322030#comment-17322030 ] Arvid Heise commented on FLINK-22259: - I'd close this issue in hopes that the upcoming fixes for

[jira] [Closed] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-22259. --- Resolution: Duplicate > UnalignedCheckpointITCase fails with "Value too large for header, this >

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

[ https://issues.apache.org/jira/browse/FLINK-22173?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17322038#comment-17322038 ] Arvid Heise commented on FLINK-22173: - Given the frequency and the lack of logs, I'm closing it.

[jira] [Created] (FLINK-22290) Add new unaligned checkpiont options to Python API.

Arvid Heise created FLINK-22290: --- Summary: Add new unaligned checkpiont options to Python API. Key: FLINK-22290 URL: https://issues.apache.org/jira/browse/FLINK-22290 Project: Flink Issue

[jira] [Updated] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22290: Affects Version/s: 1.13.0 > Add new unaligned checkpiont options to Python API. >

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318485#comment-17318485 ] Arvid Heise commented on FLINK-20816: - Downgraded to Major as it's a test-only issue. >

[jira] [Updated] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20816: Priority: Major (was: Critical) > NotifyCheckpointAbortedITCase failed due to timeout >

[jira] [Updated] (FLINK-19801) Add support for virtual channels

[ https://issues.apache.org/jira/browse/FLINK-19801?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19801: Release Note: (was: While recovering from unaligned checkpoints, users can now change the

[jira] [Resolved] (FLINK-17979) Support rescaling for Unaligned Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-17979. - Resolution: Fixed Solved with FLINK-19533, FLINK-19801, and FLINK-21945. > Support rescaling

[jira] [Updated] (FLINK-17979) Support rescaling for Unaligned Checkpoints

[ https://issues.apache.org/jira/browse/FLINK-17979?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-17979: Release Note: While recovering from unaligned checkpoints, users can now change the parallelism

[jira] [Resolved] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20816. - Resolution: Fixed > NotifyCheckpointAbortedITCase failed due to timeout >

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17319664#comment-17319664 ] Arvid Heise commented on FLINK-20816: - Merged into master as

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17320466#comment-17320466 ] Arvid Heise commented on FLINK-22259: - Seems to be test-only: {noformat} 07:36:19,541

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321096#comment-17321096 ] Arvid Heise commented on FLINK-21992: - Merged into master as

[jira] [Commented] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321279#comment-17321279 ] Arvid Heise commented on FLINK-21992: - Merged into 1.12 as e2cbfad6a3cdafe3d568bb43a1d048f9533b29ec.

[jira] [Resolved] (FLINK-21992) Fix availability notification in UnionInputGate

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21992. - Resolution: Fixed > Fix availability notification in UnionInputGate >

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321282#comment-17321282 ] Arvid Heise commented on FLINK-22259: - I guess the test assumes that the enumerator never fails (it

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321208#comment-17321208 ] Arvid Heise commented on FLINK-22259: - Source is not finishing as {{numRestarts}} is out of sync (at

[jira] [Commented] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17321280#comment-17321280 ] Arvid Heise commented on FLINK-22259: - It seems as if the {{SyncEvent}} is not sent from the

[jira] [Assigned] (FLINK-22259) UnalignedCheckpointITCase fails with "Value too large for header, this indicates that the test is running too long"

[ https://issues.apache.org/jira/browse/FLINK-22259?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22259: --- Assignee: Arvid Heise > UnalignedCheckpointITCase fails with "Value too large for header,

[jira] [Comment Edited] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325641#comment-17325641 ] Arvid Heise edited comment on FLINK-22368 at 4/20/21, 9:30 AM: --- The test

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325641#comment-17325641 ] Arvid Heise commented on FLINK-22368: - The test doesn't finish as checkpointing gets stuck in the

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22368: Component/s: Runtime / Checkpointing > UnalignedCheckpointITCase hangs on azure >

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325647#comment-17325647 ] Arvid Heise commented on FLINK-22368: - Okay, it makes sense that it doesn't checkpoint as

[jira] [Updated] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22368: Component/s: (was: Runtime / Checkpointing) Runtime / Task >

[jira] [Commented] (FLINK-22368) UnalignedCheckpointITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-22368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17325658#comment-17325658 ] Arvid Heise commented on FLINK-22368: - All source tasks are finished, but the job is not finishing

[jira] [Resolved] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22290. - Resolution: Fixed > Add new unaligned checkpiont options to Python API. >

[jira] [Commented] (FLINK-22290) Add new unaligned checkpiont options to Python API.

[ https://issues.apache.org/jira/browse/FLINK-22290?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17323936#comment-17323936 ] Arvid Heise commented on FLINK-22290: - Merged as

[jira] [Commented] (FLINK-20816) NotifyCheckpointAbortedITCase failed due to timeout

[ https://issues.apache.org/jira/browse/FLINK-20816?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17318134#comment-17318134 ] Arvid Heise commented on FLINK-20816: - I found the root cause: the test assumes implicitly that

[jira] [Updated] (FLINK-22136) Device application for unaligned checkpoint test on cluster

[ https://issues.apache.org/jira/browse/FLINK-22136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22136: Description: To test unaligned checkpoints, we should use a few different applications that use

<    3   4   5   6   7   8   9   10   11   12   >