[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-22085) KafkaSourceLegacyITCase hangs/fails on azure

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

[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=17371579#comment-17371579 ] Arvid Heise commented on FLINK-20888: - Merged into master as

[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=17369717#comment-17369717 ] Arvid Heise commented on FLINK-22492: - Merged into master as

[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=17372568#comment-17372568 ] Arvid Heise commented on FLINK-20888: - Sorry yes. I have updated the status. >

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

[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

[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=17371863#comment-17371863 ] Arvid Heise commented on FLINK-22964: - Merged into master as

[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=17371866#comment-17371866 ] Arvid Heise commented on FLINK-20888: - Merged into 1.12 as 83a26d519261f3d7607a2e25ce77e5f2c10b11f2

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

[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=17369816#comment-17369816 ] Arvid Heise commented on FLINK-22492: - See for FLINK-23009 for different issue with the same test.

[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=17369815#comment-17369815 ] Arvid Heise commented on FLINK-22492: - Merged into 1.13 as b06862333119359afba6a8f43ed08a55a7c7e57b.

[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=17370506#comment-17370506 ] Arvid Heise commented on FLINK-23147: - My main question is why are our plugins different from other

[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=17377917#comment-17377917 ] Arvid Heise commented on FLINK-16852: - Hi [~becket_qin], could you write which metrics do you

[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-23182) Connection leak in RMQSource

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

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

[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=17372111#comment-17372111 ] Arvid Heise edited comment on FLINK-22416 at 6/30/21, 4:40 PM: --- Looking at

[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=17372111#comment-17372111 ] Arvid Heise commented on FLINK-22416: - Looking at the stack traces: - all subtasks are waiting for

[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=17372111#comment-17372111 ] Arvid Heise edited comment on FLINK-22416 at 6/30/21, 4:42 PM: --- Looking at

[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] [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-23248) SinkWriter is not closed when failing

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

[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=17331824#comment-17331824 ] Arvid Heise commented on FLINK-22019: - Probably a duplicate of FLINK-22368. >

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

[ https://issues.apache.org/jira/browse/FLINK-22019?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17331824#comment-17331824 ] Arvid Heise edited comment on FLINK-22019 at 4/26/21, 6:59 AM: --- {noformat}

[jira] [Commented] (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:comment-tabpanel=17333024#comment-17333024 ] Arvid Heise commented on FLINK-22136: - Merged into master as

[jira] [Resolved] (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 resolved FLINK-22136. - Fix Version/s: 1.14.0 Resolution: Fixed > Device application for unaligned checkpoint

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

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17337132#comment-17337132 ] Arvid Heise commented on FLINK-17170: - Hi [~dannycranmer] , why do we need to have this{{

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

[ https://issues.apache.org/jira/browse/FLINK-17170?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-17170: --- Assignee: Arvid Heise > Cannot stop streaming job with savepoint which uses kinesis

[jira] [Updated] (FLINK-22282) Move creation of SplitEnumerator to the SourceCoordinator thread

[ https://issues.apache.org/jira/browse/FLINK-22282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22282: Fix Version/s: (was: 1.12.3) 1.12.4 > Move creation of SplitEnumerator to

[jira] [Updated] (FLINK-19743) Add Source metrics definitions

[ https://issues.apache.org/jira/browse/FLINK-19743?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19743: Fix Version/s: (was: 1.12.3) 1.12.4 > Add Source metrics definitions >

[jira] [Updated] (FLINK-20553) Add end-to-end test case for new Kafka source

[ https://issues.apache.org/jira/browse/FLINK-20553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20553: Fix Version/s: (was: 1.12.3) 1.12.4 1.13.1 > Add

[jira] [Updated] (FLINK-20576) Flink Temporal Join Hive Dim Error

[ https://issues.apache.org/jira/browse/FLINK-20576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20576: Fix Version/s: (was: 1.12.3) 1.12.4 > Flink Temporal Join Hive Dim Error >

[jira] [Updated] (FLINK-20457) Fix the handling of timestamp in DataStream.from_collection

[ https://issues.apache.org/jira/browse/FLINK-20457?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20457: Fix Version/s: (was: 1.12.3) 1.12.4 > Fix the handling of timestamp in

[jira] [Updated] (FLINK-20655) Add E2E tests to the new KafkaSource based on FLIP-27.

[ https://issues.apache.org/jira/browse/FLINK-20655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20655: Fix Version/s: (was: 1.12.3) 1.12.4 > Add E2E tests to the new KafkaSource

[jira] [Updated] (FLINK-19925) Errors$NativeIoException: readAddress(..) failed: Connection reset by peer

[ https://issues.apache.org/jira/browse/FLINK-19925?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-19925: Fix Version/s: (was: 1.12.3) 1.12.4 > Errors$NativeIoException:

[jira] [Updated] (FLINK-20656) Update docs for new KafkaSource connector.

[ https://issues.apache.org/jira/browse/FLINK-20656?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20656: Fix Version/s: (was: 1.12.3) 1.12.4 > Update docs for new KafkaSource

[jira] [Updated] (FLINK-20884) NullPointerException in create statements with computed columns which the subQuery is SqlNodeList

[ https://issues.apache.org/jira/browse/FLINK-20884?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20884: Fix Version/s: (was: 1.12.3) 1.12.4 > NullPointerException in create

[jira] [Updated] (FLINK-20849) Improve JavaDoc and logging of new KafkaSource

[ https://issues.apache.org/jira/browse/FLINK-20849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20849: Fix Version/s: (was: 1.12.3) 1.12.4 > Improve JavaDoc and logging of new

[jira] [Updated] (FLINK-21029) Failure of shutdown lead to restart of (connected) pipeline

[ https://issues.apache.org/jira/browse/FLINK-21029?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21029: Fix Version/s: (was: 1.12.3) 1.12.4 > Failure of shutdown lead to restart

[jira] [Updated] (FLINK-21153) yarn-per-job deployment target ignores yarn options

[ https://issues.apache.org/jira/browse/FLINK-21153?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21153: Fix Version/s: (was: 1.12.3) 1.12.4 > yarn-per-job deployment target

[jira] [Updated] (FLINK-20777) Default value of property "partition.discovery.interval.ms" is not as documented in new Kafka Source

[ https://issues.apache.org/jira/browse/FLINK-20777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20777: Fix Version/s: (was: 1.12.3) 1.12.4 > Default value of property

[jira] [Updated] (FLINK-20714) Hive delegation token is not obtained when using `kinit` to submit Yarn per-job

[ https://issues.apache.org/jira/browse/FLINK-20714?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20714: Fix Version/s: (was: 1.12.3) 1.12.4 > Hive delegation token is not

[jira] [Updated] (FLINK-22124) The job finished without any exception if error was thrown during state access

[ https://issues.apache.org/jira/browse/FLINK-22124?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22124: Parent: (was: FLINK-22123) Issue Type: Bug (was: Sub-task) > The job finished

[jira] [Updated] (FLINK-22014) Flink JobManager failed to restart after failure in kubernetes HA setup

[ https://issues.apache.org/jira/browse/FLINK-22014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22014: Fix Version/s: (was: 1.12.3) 1.12.4 > Flink JobManager failed to restart

[jira] [Updated] (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 updated FLINK-20654: Release Note: (was: Using unaligned checkpoints in Flink 1.12.0 combined with two/multiple

[jira] [Updated] (FLINK-21693) TestStreamEnvironment does not implement executeAsync

[ https://issues.apache.org/jira/browse/FLINK-21693?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21693: Fix Version/s: (was: 1.12.3) 1.12.4 > TestStreamEnvironment does not

[jira] [Updated] (FLINK-20687) Missing 'yarn-application' target in CLI help message

[ https://issues.apache.org/jira/browse/FLINK-20687?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20687: Fix Version/s: (was: 1.12.3) 1.12.4 > Missing 'yarn-application' target in

[jira] [Updated] (FLINK-21666) Consistent documentation and recommendations regarding Stop vs Cancel with savepoint

[ https://issues.apache.org/jira/browse/FLINK-21666?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21666: Fix Version/s: (was: 1.12.3) 1.12.4 > Consistent documentation and

[jira] [Updated] (FLINK-21445) Application mode does not set the configuration when building PackagedProgram

[ https://issues.apache.org/jira/browse/FLINK-21445?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21445: Fix Version/s: (was: 1.12.3) 1.12.4 > Application mode does not set the

[jira] [Updated] (FLINK-21589) Document Table/SQL API limitations regarding upgrades with savepoints

[ https://issues.apache.org/jira/browse/FLINK-21589?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21589: Fix Version/s: (was: 1.12.3) 1.12.4 > Document Table/SQL API limitations

[jira] [Updated] (FLINK-21116) DefaultDispatcherRunnerITCase hangs on azure

[ https://issues.apache.org/jira/browse/FLINK-21116?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21116: Fix Version/s: (was: 1.12.3) 1.12.4 > DefaultDispatcherRunnerITCase hangs

[jira] [Updated] (FLINK-22040) Maven: Entry has not been leased from this pool / fix for e2e tests

[ https://issues.apache.org/jira/browse/FLINK-22040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22040: Fix Version/s: (was: 1.12.3) 1.12.4 > Maven: Entry has not been leased

[jira] [Updated] (FLINK-21876) Handle it properly when the returned value of Python UDF doesn't match the defined result type

[ https://issues.apache.org/jira/browse/FLINK-21876?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21876: Fix Version/s: (was: 1.12.3) 1.12.4 > Handle it properly when the returned

[jira] [Updated] (FLINK-21711) DataStreamSink doesn't allow setting maxParallelism

[ https://issues.apache.org/jira/browse/FLINK-21711?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-21711: Fix Version/s: (was: 1.12.3) 1.12.4 > DataStreamSink doesn't allow setting

[jira] [Updated] (FLINK-22323) JobEdges Typos

[ https://issues.apache.org/jira/browse/FLINK-22323?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-22323: Fix Version/s: (was: 1.12.3) 1.12.4 > JobEdges Typos > -- > >

[jira] [Updated] (FLINK-20465) Fail globally when not resuming from the latest checkpoint in regional failover

[ https://issues.apache.org/jira/browse/FLINK-20465?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20465: Fix Version/s: (was: 1.12.3) 1.12.4 > Fail globally when not resuming from

[jira] [Updated] (FLINK-20951) IllegalArgumentException when reading Hive parquet table if condition not contain all partitioned fields

[ https://issues.apache.org/jira/browse/FLINK-20951?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise updated FLINK-20951: Fix Version/s: (was: 1.12.3) 1.12.4 > IllegalArgumentException when

[jira] [Updated] (FLINK-20431) KafkaSourceReaderTest.testCommitOffsetsWithoutAliveFetchers:133->lambda$testCommitOffsetsWithoutAliveFetchers$3:134 expected:<10> but was:<1>

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

[jira] [Created] (FLINK-22573) AsyncIO can timeout elements after completion

Arvid Heise created FLINK-22573: --- Summary: AsyncIO can timeout elements after completion Key: FLINK-22573 URL: https://issues.apache.org/jira/browse/FLINK-22573 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-21346) Tasks on AZP should timeout more gracefully

Arvid Heise created FLINK-21346: --- Summary: Tasks on AZP should timeout more gracefully Key: FLINK-21346 URL: https://issues.apache.org/jira/browse/FLINK-21346 Project: Flink Issue Type:

[jira] [Commented] (FLINK-20847) Update CompletedCheckpointStore.shutdown() signature

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

[jira] [Resolved] (FLINK-19520) Add reliable test randomization for checkpointing

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

[jira] [Commented] (FLINK-19520) Add reliable test randomization for checkpointing

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

[jira] [Commented] (FLINK-21103) E2e tests time out on azure

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

[jira] [Commented] (FLINK-21349) 'Quickstarts Scala nightly end-to-end test' fails with errors in logs

[ https://issues.apache.org/jira/browse/FLINK-21349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282893#comment-17282893 ] Arvid Heise commented on FLINK-21349: - Probably a duplicate of

[jira] [Comment Edited] (FLINK-21349) 'Quickstarts Scala nightly end-to-end test' fails with errors in logs

[ https://issues.apache.org/jira/browse/FLINK-21349?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17282893#comment-17282893 ] Arvid Heise edited comment on FLINK-21349 at 2/11/21, 7:20 AM: --- Probably a

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

[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=17307637#comment-17307637 ] Arvid Heise commented on FLINK-21936: - Note that the initial example was deliberately kept simple.

[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] [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] [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=17309412#comment-17309412 ] Arvid Heise commented on FLINK-20654: - Merged another set of test tunings + improved logging into

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

[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=17311472#comment-17311472 ] Arvid Heise commented on FLINK-22001: - Another case here

[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=17311473#comment-17311473 ] Arvid Heise commented on FLINK-21880: - The OP error is pure test. Probably the cancellation of the

[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

[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

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

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

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

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

[jira] [Assigned] (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 reassigned FLINK-21873: --- Assignee: Arvid Heise > CoordinatedSourceRescaleITCase.testUpscaling fails on AZP >

[jira] [Commented] (FLINK-22132) Test unaligned checkpoints rescaling manually on a real cluster

[ https://issues.apache.org/jira/browse/FLINK-22132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316161#comment-17316161 ] Arvid Heise commented on FLINK-22132: - Since the task is pretty huge. I'm splitting into subtasks

[jira] [Updated] (FLINK-22132) Test unaligned checkpoints rescaling manually on a real cluster

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

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

Arvid Heise created FLINK-22136: --- Summary: Device application for unaligned checkpoint test on cluster Key: FLINK-22136 URL: https://issues.apache.org/jira/browse/FLINK-22136 Project: Flink

[jira] [Created] (FLINK-22137) Execute unaligned checkpoint test on a cluster

Arvid Heise created FLINK-22137: --- Summary: Execute unaligned checkpoint test on a cluster Key: FLINK-22137 URL: https://issues.apache.org/jira/browse/FLINK-22137 Project: Flink Issue Type:

[jira] [Updated] (FLINK-22132) Test unaligned checkpoints rescaling manually on a real cluster

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

[jira] [Commented] (FLINK-22084) RescalingITCase fails with adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-22084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316018#comment-17316018 ] Arvid Heise commented on FLINK-22084: - We shouldn't support changes in maxParallelism. But in this

[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=17316029#comment-17316029 ] Arvid Heise commented on FLINK-22019: - For the time being, I'm assuming that this is caused by

[jira] [Assigned] (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 reassigned FLINK-20816: --- Assignee: Arvid Heise > NotifyCheckpointAbortedITCase failed due to timeout >

[jira] [Commented] (FLINK-16504) Add a AWS DynamoDB sink

[ https://issues.apache.org/jira/browse/FLINK-16504?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17316107#comment-17316107 ] Arvid Heise commented on FLINK-16504: - It seems as if I get proper priority for creating the

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

[ https://issues.apache.org/jira/browse/FLINK-21797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise reassigned FLINK-21797: --- Assignee: (was: Arvid Heise) > Performance regression on 03/11/21 >

[jira] [Closed] (FLINK-21378) Rescale pointwise connection during unaligned checkpoint recovery

[ https://issues.apache.org/jira/browse/FLINK-21378?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise closed FLINK-21378. --- Resolution: Incomplete The idea is incomplete, see FLINK-21936. > Rescale pointwise connection

[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=17316001#comment-17316001 ] Arvid Heise commented on FLINK-21880: - Merged fix into master as

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

[ https://issues.apache.org/jira/browse/FLINK-21880?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Arvid Heise resolved FLINK-21880. - Fix Version/s: 1.13.0 Resolution: Fixed > UnalignedCheckpointRescaleITCase fails 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=17316183#comment-17316183 ] Arvid Heise commented on FLINK-21873: - The exception actually showed that everything works as

[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

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

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