[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] [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&focusedCommentId=17307383#comment-17307383 ] Arvid Heise commented on FLINK-21936: - As a first step, we might want to provide use

[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&focusedCommentId=17307386#comment-17307386 ] Arvid Heise commented on FLINK-21936: - Alternatively or additionally, we might want

[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&focusedCommentId=17307388#comment-17307388 ] Arvid Heise commented on FLINK-21936: - A completely different approach would be poss

[jira] [Updated] (FLINK-21936) Rescale pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21936: Summary: Rescale pointwise connections for unaligned checkpoints (was: Disable checkpointing of i

[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&focusedCommentId=17307637#comment-17307637 ] Arvid Heise commented on FLINK-21936: - Note that the initial example was deliberatel

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

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

[jira] [Assigned] (FLINK-21936) Rescale pointwise connections for unaligned checkpoints

[ https://issues.apache.org/jira/browse/FLINK-21936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21936: --- Assignee: (was: Arvid Heise) > Rescale pointwise connections for unaligned checkpoints

[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 Issue

[jira] [Commented] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17309412#comment-17309412 ] Arvid Heise commented on FLINK-20654: - Merged another set of test tunings + improved

[jira] [Resolved] (FLINK-20654) Unaligned checkpoint recovery may lead to corrupted data stream

[ https://issues.apache.org/jira/browse/FLINK-20654?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20654. - Resolution: Fixed > Unaligned checkpoint recovery may lead to corrupted data stream > --

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

[ https://issues.apache.org/jira/browse/FLINK-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21992: Component/s: Runtime / Checkpointing > Investigate potential buffer leak in unaligned checkpoint >

[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&focusedCommentId=17310986#comment-17310986 ] Arvid Heise commented on FLINK-22019: - Since there are no logs, there is not much I

[jira] [Updated] (FLINK-21181) Buffer pool is destroyed error when outputting data over a timer after cancellation.

[ https://issues.apache.org/jira/browse/FLINK-21181?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21181: Description: A [user reported|http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com

[jira] [Commented] (FLINK-22001) Exceptions from JobMaster initialization are not forwarded to the user

[ https://issues.apache.org/jira/browse/FLINK-22001?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311472#comment-17311472 ] Arvid Heise commented on FLINK-22001: - Another case here https://dev.azure.com/apac

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

[ https://issues.apache.org/jira/browse/FLINK-21880?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17311473#comment-17311473 ] Arvid Heise commented on FLINK-21880: - The OP error is pure test. Probably the cance

[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 89fde844d05125c49a9bbb9d06

[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: While recovering from unaligned checkpoints, users can now change the parallelism of

[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] [Assigned] (FLINK-22053) Recovery of a completed split in NumberSequenceSource causes fatal exception.

[ https://issues.apache.org/jira/browse/FLINK-22053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22053: --- Assignee: Arvid Heise > Recovery of a completed split in NumberSequenceSource causes fatal

[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: Summary: NumberSequenceSource causes fatal exception when less splits than parallelism. (was: Rec

[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 sp

[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: 'from

[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: 'from

[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: 'from

[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: 'from

[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: Arvid Heise > NumberSequenceSource causes fatal exception when less splits than p

[jira] [Commented] (FLINK-22003) UnalignedCheckpointITCase fail

[ https://issues.apache.org/jira/browse/FLINK-22003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312302#comment-17312302 ] Arvid Heise commented on FLINK-22003: - This one is really strange: Usually, when we

[jira] [Commented] (FLINK-22003) UnalignedCheckpointITCase fail

[ https://issues.apache.org/jira/browse/FLINK-22003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17312550#comment-17312550 ] Arvid Heise commented on FLINK-22003: - In general, I have seen long recovery times i

[jira] [Commented] (FLINK-23011) FLIP-27 sources are generating non-deterministic results when using event time

[ https://issues.apache.org/jira/browse/FLINK-23011?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17368643#comment-17368643 ] Arvid Heise commented on FLINK-23011: - I think we a have a large agreement here. I'd

[jira] [Updated] (FLINK-23127) Can't use plugins for GCS filesystem

[ https://issues.apache.org/jira/browse/FLINK-23127?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23127: Component/s: FileSystems > Can't use plugins for GCS filesystem >

[jira] [Assigned] (FLINK-22492) KinesisTableApiITCase with wrong results

[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22492: --- Assignee: Arvid Heise > KinesisTableApiITCase with wrong results >

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369251#comment-17369251 ] Arvid Heise commented on FLINK-23147: - Hi Chesnay, I'm lacking a bit of knowledge to

[jira] [Commented] (FLINK-22257) Clarify Flink ConfigOptions Usage

[ https://issues.apache.org/jira/browse/FLINK-22257?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369320#comment-17369320 ] Arvid Heise commented on FLINK-22257: - :+1: to Robert's idea. Could some config have

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369348#comment-17369348 ] Arvid Heise commented on FLINK-23147: - Just to repeat what I have stated at other pl

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369374#comment-17369374 ] Arvid Heise commented on FLINK-23147: - > ehhh; a plugin interface with this sign

[jira] [Comment Edited] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369374#comment-17369374 ] Arvid Heise edited comment on FLINK-23147 at 6/25/21, 10:15 AM: --

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

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

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369815#comment-17369815 ] Arvid Heise commented on FLINK-22492: - Merged into 1.13 as b06862333119359afba6a8f43

[jira] [Commented] (FLINK-22492) KinesisTableApiITCase with wrong results

[ https://issues.apache.org/jira/browse/FLINK-22492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17369816#comment-17369816 ] Arvid Heise commented on FLINK-22492: - See for FLINK-23009 for different issue with

[jira] [Resolved] (FLINK-22492) KinesisTableApiITCase with wrong results

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

[jira] [Commented] (FLINK-23147) ThreadPools can be poisoned by context class loaders

[ https://issues.apache.org/jira/browse/FLINK-23147?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17370506#comment-17370506 ] Arvid Heise commented on FLINK-23147: - My main question is why are our plugins diffe

[jira] [Assigned] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-22964: --- Assignee: Arvid Heise > Connector-base exposes dependency to flink-core. >

[jira] [Commented] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

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

[jira] [Commented] (FLINK-22964) Connector-base exposes dependency to flink-core.

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

[jira] [Resolved] (FLINK-22964) Connector-base exposes dependency to flink-core.

[ https://issues.apache.org/jira/browse/FLINK-22964?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-22964. - Release Note: Connectors do not transitively hold a reference to `flink-core` anymore. That mean

[jira] [Commented] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17371866#comment-17371866 ] Arvid Heise commented on FLINK-20888: - Merged into 1.12 as 83a26d519261f3d7607a2e25c

[jira] [Commented] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372111#comment-17372111 ] Arvid Heise commented on FLINK-22416: - Looking at the stack traces: - all subtasks

[jira] [Comment Edited] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372111#comment-17372111 ] Arvid Heise edited comment on FLINK-22416 at 6/30/21, 4:40 PM: ---

[jira] [Comment Edited] (FLINK-22416) UpsertKafkaTableITCase hangs when collecting results

[ https://issues.apache.org/jira/browse/FLINK-22416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372111#comment-17372111 ] Arvid Heise edited comment on FLINK-22416 at 6/30/21, 4:42 PM: ---

[jira] [Resolved] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

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

[jira] [Commented] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17372568#comment-17372568 ] Arvid Heise commented on FLINK-20888: - Sorry yes. I have updated the status. > Cont

[jira] [Commented] (FLINK-22085) KafkaSourceLegacyITCase hangs/fails on azure

[ https://issues.apache.org/jira/browse/FLINK-22085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17373612#comment-17373612 ] Arvid Heise commented on FLINK-22085: - I think having `notifyDataAvailable` at the e

[jira] [Commented] (FLINK-23248) SinkWriter is not closed when failing

[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17375344#comment-17375344 ] Arvid Heise commented on FLINK-23248: - Merged into 1.13 as 9d77656381f55d05a3eb74c6c

[jira] [Resolved] (FLINK-23248) SinkWriter is not closed when failing

[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23248. - Resolution: Fixed > SinkWriter is not closed when failing >

[jira] [Updated] (FLINK-23248) SinkWriter is not closed when failing

[ https://issues.apache.org/jira/browse/FLINK-23248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-23248: Fix Version/s: 1.13.3 1.12.6 > SinkWriter is not closed when failing >

[jira] [Commented] (FLINK-23182) Connection leak in RMQSource

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

[jira] [Resolved] (FLINK-23182) Connection leak in RMQSource

[ https://issues.apache.org/jira/browse/FLINK-23182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-23182. - Fix Version/s: 1.13.3 1.12.6 1.14.0 Resolution: Fixe

[jira] [Assigned] (FLINK-16851) Add common metrics to the SourceReader base implementation.

[ https://issues.apache.org/jira/browse/FLINK-16851?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-16851: --- Assignee: Arvid Heise > Add common metrics to the SourceReader base implementation. > -

[jira] [Commented] (FLINK-16852) Add metrics to the source coordinator.

[ https://issues.apache.org/jira/browse/FLINK-16852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17377917#comment-17377917 ] Arvid Heise commented on FLINK-16852: - Hi [~becket_qin], could you write which metri

[jira] [Commented] (FLINK-18562) Add Support for Azure Data Lake Store Gen 2 in Flink File System

[ https://issues.apache.org/jira/browse/FLINK-18562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17386956#comment-17386956 ] Arvid Heise commented on FLINK-18562: - I'll have a peek on Tuesday. > Add Support f

[jira] [Commented] (FLINK-20726) Introduce Pulsar connector

[ https://issues.apache.org/jira/browse/FLINK-20726?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17386957#comment-17386957 ] Arvid Heise commented on FLINK-20726: - [~Jianyun Zhao], please use the new interface

[jira] [Commented] (FLINK-23509) FlinkKafkaInternalProducer overrides static final ProducerIdAndEpoch#NONE during transaction recovery (fails)

[ https://issues.apache.org/jira/browse/FLINK-23509?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17387966#comment-17387966 ] Arvid Heise commented on FLINK-23509: - Hi Matthias, good observation and I see your

[jira] [Assigned] (FLINK-23255) Add JUnit 5 jupiter and vintage engine

[ https://issues.apache.org/jira/browse/FLINK-23255?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-23255: --- Assignee: Qingsheng Ren > Add JUnit 5 jupiter and vintage engine >

[jira] [Resolved] (FLINK-20433) UnalignedCheckpointTestBase.execute failed with "TestTimedOutException: test timed out after 300 seconds"

[ https://issues.apache.org/jira/browse/FLINK-20433?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20433. - Fix Version/s: 1.12.1 Resolution: Resolved > UnalignedCheckpointTestBase.execute failed w

[jira] [Commented] (FLINK-20886) Add the option to get a threaddump on checkpoint timeouts

[ https://issues.apache.org/jira/browse/FLINK-20886?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260462#comment-17260462 ] Arvid Heise commented on FLINK-20886: - I'd probably always have the thread dump in.

[jira] [Commented] (FLINK-20888) ContinuousFileReaderOperator should not close the output on close()

[ https://issues.apache.org/jira/browse/FLINK-20888?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17260476#comment-17260476 ] Arvid Heise commented on FLINK-20888: - Thanks for the investigation, we would take i

[jira] [Assigned] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

[ https://issues.apache.org/jira/browse/FLINK-20462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20462: --- Assignee: Arvid Heise > MailboxOperatorTest.testAvoidTaskStarvation > -

[jira] [Commented] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262702#comment-17262702 ] Arvid Heise commented on FLINK-20376: - I think you misunderstood my statement. {nofo

[jira] [Comment Edited] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262702#comment-17262702 ] Arvid Heise edited comment on FLINK-20376 at 1/11/21, 3:03 PM: ---

[jira] [Comment Edited] (FLINK-20376) Error in restoring checkpoint/savepoint when Flink is upgraded from 1.9 to 1.11.2

[ https://issues.apache.org/jira/browse/FLINK-20376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17262702#comment-17262702 ] Arvid Heise edited comment on FLINK-20376 at 1/11/21, 3:05 PM: ---

[jira] [Assigned] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-20955: --- Assignee: Moritz Manner > Refactor HBase Source in accordance with FLIP-27 > --

[jira] [Updated] (FLINK-20955) Refactor HBase Source in accordance with FLIP-27

[ https://issues.apache.org/jira/browse/FLINK-20955?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20955: Fix Version/s: (was: 1.12.0) 1.13.0 > Refactor HBase Source in accordance w

[jira] [Commented] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

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

[jira] [Resolved] (FLINK-20462) MailboxOperatorTest.testAvoidTaskStarvation

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

[jira] [Updated] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20309: Priority: Major (was: Blocker) > UnalignedCheckpointTestBase.execute is failed >

[jira] [Resolved] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-20309. - Resolution: Fixed > UnalignedCheckpointTestBase.execute is failed >

[jira] [Commented] (FLINK-20309) UnalignedCheckpointTestBase.execute is failed

[ https://issues.apache.org/jira/browse/FLINK-20309?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17266654#comment-17266654 ] Arvid Heise commented on FLINK-20309: - The latest issues were test only issues. Merg

[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&focusedCommentId=17299805#comment-17299805 ] Arvid Heise commented on FLINK-19801: - Merged as 8bfc905bf5e9a7e523f0f083c948cbb32a

[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-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&focusedCommentId=17299809#comment-17299809 ] Arvid Heise commented on FLINK-21535: - A quick assessment of the 3 cases: the test i

[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&focusedCommentId=17299809#comment-17299809 ] Arvid Heise edited comment on FLINK-21535 at 3/11/21, 6:54 PM: ---

[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] [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] [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&focusedCommentId=17300147#comment-17300147 ] Arvid Heise commented on FLINK-21535: - I verified that FLINK-21540, FLINK-21599, and

[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-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&focusedCommentId=17301851#comment-17301851 ] Arvid Heise commented on FLINK-21535: - Merged as c177d15323d5025f0cf737b98bb051efbc0

[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] [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&focusedCommentId=17301877#comment-17301877 ] Arvid Heise commented on FLINK-20130: - Merged into master as 889b3845217141b295eb2b6

[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] [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&focusedCommentId=17302747#comment-17302747 ] Arvid Heise commented on FLINK-21535: - Merged as 755a8d8214554c64e9db0271a8274852081

[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 > UnalignedCheckpointIT

[jira] [Commented] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

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

[jira] [Closed] (FLINK-19585) UnalignedCheckpointCompatibilityITCase.test:97->runAndTakeSavepoint: "Not all required tasks are currently running."

[ https://issues.apache.org/jira/browse/FLINK-19585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-19585. --- Fix Version/s: 1.12.0 Resolution: Fixed > UnalignedCheckpointCompatibilityITCase.test:97->run

[jira] [Commented] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217420#comment-17217420 ] Arvid Heise commented on FLINK-19589: - Hi [~Padarn], thank you for the ideas. I like

[jira] [Comment Edited] (FLINK-19589) Expose S3 options for tagging and object lifecycle policy for FileSystem

[ https://issues.apache.org/jira/browse/FLINK-19589?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17217420#comment-17217420 ] Arvid Heise edited comment on FLINK-19589 at 10/20/20, 8:52 AM: --

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218541#comment-17218541 ] Arvid Heise commented on FLINK-19401: - Added to master as be448ecbd97ff9f79daac9ec7b

[jira] [Commented] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17218851#comment-17218851 ] Arvid Heise commented on FLINK-19401: - Merged into release-1.11 as bff79f5efffccd179

[jira] [Resolved] (FLINK-19401) Job stuck in restart loop due to excessive checkpoint recoveries which block the JobMaster

[ https://issues.apache.org/jira/browse/FLINK-19401?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-19401. - Resolution: Fixed > Job stuck in restart loop due to excessive checkpoint recoveries which block

<    1   2   3   4   5   6   7   8   9   10   >