[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842587#comment-17842587 ] Roman Khachatryan commented on FLINK-35217: --- Backported to 1.18 as

[jira] [Commented] (FLINK-35217) Missing fsync in FileSystemCheckpointStorage

[ https://issues.apache.org/jira/browse/FLINK-35217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17842363#comment-17842363 ] Roman Khachatryan commented on FLINK-35217: --- [~srichter] would you mind backporting the fix to

[jira] [Commented] (FLINK-34450) TwoInputStreamTaskTest.testWatermarkAndWatermarkStatusForwarding failed

[ https://issues.apache.org/jira/browse/FLINK-34450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833783#comment-17833783 ] Roman Khachatryan commented on FLINK-34450: --- 1.20 master:

[jira] [Closed] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"

[ https://issues.apache.org/jira/browse/FLINK-34994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34994. - Fix Version/s: 1.20.0 Resolution: Fixed Fix merged into master as

[jira] [Updated] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"

[ https://issues.apache.org/jira/browse/FLINK-34994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34994: -- Description:

[jira] [Updated] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"

[ https://issues.apache.org/jira/browse/FLINK-34994?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34994: -- Labels: test-stability (was: ) > JobIDLoggingITCase fails because of "checkpoint

[jira] [Comment Edited] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833443#comment-17833443 ] Roman Khachatryan edited comment on FLINK-34643 at 4/3/24 8:15 AM: --- I

[jira] [Created] (FLINK-34994) JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task"

Roman Khachatryan created FLINK-34994: - Summary: JobIDLoggingITCase fails because of "checkpoint confirmation for unknown task" Key: FLINK-34994 URL: https://issues.apache.org/jira/browse/FLINK-34994

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17833443#comment-17833443 ] Roman Khachatryan commented on FLINK-34643: --- I agree, I'd open a separate ticket since the

[jira] [Closed] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-26515. - Fix Version/s: 1.18.2 1.20.0 1.19.1

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17831259#comment-17831259 ] Roman Khachatryan commented on FLINK-34643: --- Fix merged into master as

[jira] [Closed] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34643. - Resolution: Fixed > JobIDLoggingITCase failed > - > >

[jira] [Assigned] (FLINK-26515) RetryingExecutorTest. testDiscardOnTimeout failed on azure

[ https://issues.apache.org/jira/browse/FLINK-26515?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26515: - Assignee: Roman Khachatryan > RetryingExecutorTest. testDiscardOnTimeout

[jira] [Reopened] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reopened FLINK-34643: --- Thanks for reporting, reopening the issue. > JobIDLoggingITCase failed >

[jira] [Closed] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34643. - Resolution: Fixed > JobIDLoggingITCase failed > - > >

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829969#comment-17829969 ] Roman Khachatryan commented on FLINK-34643: --- Merged into master as

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829560#comment-17829560 ] Roman Khachatryan commented on FLINK-34643: --- Or maybe it's actually simple:

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17829557#comment-17829557 ] Roman Khachatryan commented on FLINK-34643: --- Thanks for reporting My first suspicion was that

[jira] [Closed] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34643. - Fix Version/s: 1.20.0 Resolution: Fixed Merged into master as

[jira] [Assigned] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-34643: - Assignee: Roman Khachatryan > JobIDLoggingITCase failed >

[jira] [Commented] (FLINK-34643) JobIDLoggingITCase failed

[ https://issues.apache.org/jira/browse/FLINK-34643?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17825334#comment-17825334 ] Roman Khachatryan commented on FLINK-34643: --- Sure [~mapohl] , will take a look. >

[jira] [Closed] (FLINK-34417) Add JobID to logging MDC

[ https://issues.apache.org/jira/browse/FLINK-34417?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-34417. - Resolution: Fixed > Add JobID to logging MDC > > >

[jira] [Commented] (FLINK-34417) Add JobID to logging MDC

[ https://issues.apache.org/jira/browse/FLINK-34417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17824806#comment-17824806 ] Roman Khachatryan commented on FLINK-34417: --- Merged into master as

[jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck

[ https://issues.apache.org/jira/browse/FLINK-34559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34559: -- Description: RecordsWindowBuffer flushes buffered records in the following cases: *

[jira] [Updated] (FLINK-34559) TVF Window Aggregations might get stuck

[ https://issues.apache.org/jira/browse/FLINK-34559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34559: -- Summary: TVF Window Aggregations might get stuck (was: TVF Window Aggregations might

[jira] [Updated] (FLINK-34559) TVF Window Aggregations might stuck

[ https://issues.apache.org/jira/browse/FLINK-34559?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34559: -- Fix Version/s: 1.19.0 > TVF Window Aggregations might stuck >

[jira] [Created] (FLINK-34559) TVF Window Aggregations might stuck

Roman Khachatryan created FLINK-34559: - Summary: TVF Window Aggregations might stuck Key: FLINK-34559 URL: https://issues.apache.org/jira/browse/FLINK-34559 Project: Flink Issue Type:

[jira] [Commented] (FLINK-34420) Various YARN tests fail after failing to download hadoop.tar.gz

[ https://issues.apache.org/jira/browse/FLINK-34420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17821209#comment-17821209 ] Roman Khachatryan commented on FLINK-34420: --- IIRC, there was a difference in PR builds and

[jira] [Assigned] (FLINK-26050) Too many small sst files in rocksdb state backend when using time window created in ascending order

[ https://issues.apache.org/jira/browse/FLINK-26050?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-26050: - Assignee: Roman Khachatryan > Too many small sst files in rocksdb state

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818251#comment-17818251 ] Roman Khachatryan commented on FLINK-33734: --- As for {quote}IIUC, ByteStreamStateHandle in each

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818249#comment-17818249 ] Roman Khachatryan commented on FLINK-33734: --- Thanks for the PR [~Feifan Wang]  Do I

[jira] [Comment Edited] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818243#comment-17818243 ] Roman Khachatryan edited comment on FLINK-34448 at 2/18/24 6:36 AM:

[jira] [Commented] (FLINK-34448) ChangelogLocalRecoveryITCase#testRestartTM failed fatally with 127 exit code

[ https://issues.apache.org/jira/browse/FLINK-34448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17818243#comment-17818243 ] Roman Khachatryan commented on FLINK-34448: ---

[jira] [Updated] (FLINK-34420) Various YARN tests fail after failing to download hadoop.tar.gz

[ https://issues.apache.org/jira/browse/FLINK-34420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34420: -- Priority: Blocker (was: Major) > Various YARN tests fail after failing to download

[jira] [Created] (FLINK-34420) Various YARN tests fail after failing to download hadoop.tar.gz

Roman Khachatryan created FLINK-34420: - Summary: Various YARN tests fail after failing to download hadoop.tar.gz Key: FLINK-34420 URL: https://issues.apache.org/jira/browse/FLINK-34420 Project:

[jira] [Updated] (FLINK-34344) Wrong JobID in CheckpointStatsTracker

[ https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34344: -- Fix Version/s: 1.18.2 > Wrong JobID in CheckpointStatsTracker >

[jira] [Updated] (FLINK-34344) Wrong JobID in CheckpointStatsTracker

[ https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34344: -- Fix Version/s: 1.20.0 > Wrong JobID in CheckpointStatsTracker >

[jira] [Updated] (FLINK-34344) Wrong JobID in CheckpointStatsTracker

[ https://issues.apache.org/jira/browse/FLINK-34344?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-34344: -- Affects Version/s: 1.18.1 1.20.0 > Wrong JobID in

[jira] [Created] (FLINK-34417) Add JobID to logging MDC

Roman Khachatryan created FLINK-34417: - Summary: Add JobID to logging MDC Key: FLINK-34417 URL: https://issues.apache.org/jira/browse/FLINK-34417 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-34344) Wrong JobID in CheckpointStatsTracker

Roman Khachatryan created FLINK-34344: - Summary: Wrong JobID in CheckpointStatsTracker Key: FLINK-34344 URL: https://issues.apache.org/jira/browse/FLINK-34344 Project: Flink Issue Type:

[jira] [Assigned] (FLINK-33338) Bump FRocksDB version

[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-8: - Assignee: Roman Khachatryan > Bump FRocksDB version > - >

[jira] [Commented] (FLINK-33734) Merge unaligned checkpoint state handle

[ https://issues.apache.org/jira/browse/FLINK-33734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17794682#comment-17794682 ] Roman Khachatryan commented on FLINK-33734: --- Thanks for the proposal! You're right [~Feifan

[jira] [Updated] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

[ https://issues.apache.org/jira/browse/FLINK-33590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-33590: -- Component/s: (was: Runtime / Checkpointing) (was: Runtime /

[jira] [Updated] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

[ https://issues.apache.org/jira/browse/FLINK-33590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-33590: -- Affects Version/s: (was: 1.18.0) (was: 1.19.0) >

[jira] [Closed] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

[ https://issues.apache.org/jira/browse/FLINK-33590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-33590. - Fix Version/s: (was: 1.19.0) (was: 1.18.1) Assignee:

[jira] [Updated] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

[ https://issues.apache.org/jira/browse/FLINK-33590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-33590: -- Affects Version/s: 1.19.0 > CheckpointStatsTracker.totalNumberOfSubTasks not updated

[jira] [Updated] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

[ https://issues.apache.org/jira/browse/FLINK-33590?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-33590: -- Fix Version/s: 1.19.0 > CheckpointStatsTracker.totalNumberOfSubTasks not updated >

[jira] [Created] (FLINK-33590) CheckpointStatsTracker.totalNumberOfSubTasks not updated

Roman Khachatryan created FLINK-33590: - Summary: CheckpointStatsTracker.totalNumberOfSubTasks not updated Key: FLINK-33590 URL: https://issues.apache.org/jira/browse/FLINK-33590 Project: Flink

[jira] [Resolved] (FLINK-33442) UnsupportedOperationException thrown from RocksDBIncrementalRestoreOperation

[ https://issues.apache.org/jira/browse/FLINK-33442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan resolved FLINK-33442. --- Resolution: Fixed > UnsupportedOperationException thrown from

[jira] [Updated] (FLINK-33442) UnsupportedOperationException thrown from RocksDBIncrementalRestoreOperation

[ https://issues.apache.org/jira/browse/FLINK-33442?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-33442: -- Description: When using the new rescaling API, it's possible to get {code:java}

[jira] [Created] (FLINK-33442) UnsupportedOperationException thrown from RocksDBIncrementalRestoreOperation

Roman Khachatryan created FLINK-33442: - Summary: UnsupportedOperationException thrown from RocksDBIncrementalRestoreOperation Key: FLINK-33442 URL: https://issues.apache.org/jira/browse/FLINK-33442

[jira] [Commented] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17778647#comment-17778647 ] Roman Khachatryan commented on FLINK-33324: --- Thanks for clarifying [~dongwoo.kim] it seems to

[jira] [Comment Edited] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1688#comment-1688 ] Roman Khachatryan edited comment on FLINK-33324 at 10/20/23 10:10 AM:

[jira] [Commented] (FLINK-33324) Add flink managed timeout mechanism for backend restore operation

[ https://issues.apache.org/jira/browse/FLINK-33324?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1688#comment-1688 ] Roman Khachatryan commented on FLINK-33324: --- Thanks for the proposal [~dongwoo.kim]   I have

[jira] [Closed] (FLINK-33077) Minimize the risk of hard back-pressure with buffer debloating enabled

[ https://issues.apache.org/jira/browse/FLINK-33077?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-33077. - Resolution: Fixed Fixed in c7f6470bb8cc314e7651b03e171af057f4edec1e. > Minimize the

[jira] [Updated] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-32761: -- Affects Version/s: 1.18.0 > Use UUID based on PhysicalStateHandleID as

[jira] [Closed] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-32761. - Fix Version/s: 1.19.0 Resolution: Fixed Merged as

[jira] [Closed] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-31139. - Fix Version/s: 1.18.0 Resolution: Fixed > not upload empty state changelog file

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754474#comment-17754474 ] Roman Khachatryan commented on FLINK-31139: --- Merged into release-1.16 as

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17754128#comment-17754128 ] Roman Khachatryan commented on FLINK-31139: --- [~Feifan Wang] thanks for the reminder, I have

[jira] [Commented] (FLINK-21450) Add local recovery support to adaptive scheduler

[ https://issues.apache.org/jira/browse/FLINK-21450?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17752650#comment-17752650 ] Roman Khachatryan commented on FLINK-21450: --- Sorry for the late reply. Yes, good point

[jira] [Commented] (FLINK-32761) Use UUID based on PhysicalStateHandleID as SharedStateRegistryKey ChangelogStateHandleStreamImpl

[ https://issues.apache.org/jira/browse/FLINK-32761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751409#comment-17751409 ] Roman Khachatryan commented on FLINK-32761: --- Good point [~Feifan Wang], I think it makes

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751329#comment-17751329 ] Roman Khachatryan commented on FLINK-29913: --- javadoc updated in

[jira] [Closed] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-29913. - Resolution: Fixed > Shared state would be discarded by mistake when

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17751308#comment-17751308 ] Roman Khachatryan commented on FLINK-29913: --- Thanks a lot [~Feifan Wang], happy to hear that

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17750636#comment-17750636 ] Roman Khachatryan commented on FLINK-29913: --- Merged into master as

[jira] [Updated] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29913: -- Fix Version/s: 1.18.0 > Shared state would be discarded by mistake when

[jira] [Closed] (FLINK-19010) Add a system metric to show the checkpoint restore time

[ https://issues.apache.org/jira/browse/FLINK-19010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-19010. - Fix Version/s: 1.18.0 Resolution: Fixed Merged as

[jira] [Closed] (FLINK-31035) add warn info to user when NoNodeException happend

[ https://issues.apache.org/jira/browse/FLINK-31035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-31035. - Fix Version/s: 1.18.0 Assignee: xy Resolution: Fixed Merged into master

[jira] [Assigned] (FLINK-32270) Heartbeat timeout in AggregateReduceGroupingITCase.testAggOnLeftJoin on AZP

[ https://issues.apache.org/jira/browse/FLINK-32270?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-32270: - Assignee: Roman Khachatryan (was: Konstantin Knauf) > Heartbeat timeout in

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725693#comment-17725693 ] Roman Khachatryan commented on FLINK-29913: --- Great! Thanks [~Feifan Wang]  > Shared state

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725569#comment-17725569 ] Roman Khachatryan commented on FLINK-29913: --- Got it, thanks for clarifying.  However, I think

[jira] [Assigned] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-29913: - Assignee: Feifan Wang > Shared state would be discarded by mistake when

[jira] [Updated] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29913: -- Fix Version/s: 1.16.2 1.17.2 > Shared state would be discarded by

[jira] [Updated] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29913: -- Affects Version/s: 1.17.0 > Shared state would be discarded by mistake when

[jira] [Updated] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-29913: -- Priority: Major (was: Minor) > Shared state would be discarded by mistake when

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725418#comment-17725418 ] Roman Khachatryan commented on FLINK-29913: --- {quote}On a 64-bit system, about 7.63MB more

[jira] [Commented] (FLINK-29913) Shared state would be discarded by mistake when maxConcurrentCheckpoint>1

[ https://issues.apache.org/jira/browse/FLINK-29913?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725336#comment-17725336 ] Roman Khachatryan commented on FLINK-29913: --- Thanks for the proposal [~Feifan Wang]. I think

[jira] [Commented] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17725282#comment-17725282 ] Roman Khachatryan commented on FLINK-32130: --- Thanks [~Feifan Wang]  > previous checkpoint

[jira] [Commented] (FLINK-32130) previous checkpoint will be broke by the subsequent incremental checkpoint

[ https://issues.apache.org/jira/browse/FLINK-32130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17724879#comment-17724879 ] Roman Khachatryan commented on FLINK-32130: --- Thanks for reporting the issue and providing the

[jira] [Commented] (FLINK-31743) Avoid relocating the RocksDB's log failure when filename exceeds 255 characters

[ https://issues.apache.org/jira/browse/FLINK-31743?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17711097#comment-17711097 ] Roman Khachatryan commented on FLINK-31743: --- [~assassinj] are you still planning to work on

[jira] [Comment Edited] (FLINK-31593) Update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708612#comment-17708612 ] Roman Khachatryan edited comment on FLINK-31593 at 4/4/23 11:28 PM:

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708612#comment-17708612 ] Roman Khachatryan commented on FLINK-31593: --- [~mapohl] I looked into

[jira] [Commented] (FLINK-31593) Update reference data for Migration Tests

[ https://issues.apache.org/jira/browse/FLINK-31593?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17708135#comment-17708135 ] Roman Khachatryan commented on FLINK-31593: --- Sorry for the late reply [~mapohl], I'll try to

[jira] [Updated] (FLINK-31608) Re-evaluate 'min-parallelism-increase' option

[ https://issues.apache.org/jira/browse/FLINK-31608?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31608: -- Description: This option was meant to prevent scale up operations where the benefit

[jira] [Assigned] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27144: - Assignee: Lijie Wang (was: jee) > Provide timeout details when calling

[jira] [Commented] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17704514#comment-17704514 ] Roman Khachatryan commented on FLINK-27144: --- Thanks [~wanglijie] , assigned the ticket to you

[jira] [Assigned] (FLINK-27144) Provide timeout details when calling FutureUtils.orTimeout

[ https://issues.apache.org/jira/browse/FLINK-27144?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan reassigned FLINK-27144: - Assignee: jee > Provide timeout details when calling FutureUtils.orTimeout >

[jira] [Created] (FLINK-31601) While waiting for resources, resources check might be scheduled unlimited number of times (Adaptive Scheduler)

Roman Khachatryan created FLINK-31601: - Summary: While waiting for resources, resources check might be scheduled unlimited number of times (Adaptive Scheduler) Key: FLINK-31601 URL:

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703787#comment-17703787 ] Roman Khachatryan commented on FLINK-31139: --- Yes [~Feifan Wang] , I think so. I've pushed to

[jira] [Closed] (FLINK-31527) ChangelogRescalingITCase.test failed due to FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-31527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-31527. - Assignee: Roman Khachatryan Resolution: Fixed Fix merged into master as

[jira] [Updated] (FLINK-31527) ChangelogRescalingITCase.test failed due to FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-31527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31527: -- Priority: Major (was: Blocker) > ChangelogRescalingITCase.test failed due to

[jira] [Commented] (FLINK-31527) ChangelogRescalingITCase.test failed due to FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-31527?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703381#comment-17703381 ] Roman Khachatryan commented on FLINK-31527: --- The issue is indeed not 1.17-specific:

[jira] [Updated] (FLINK-31527) ChangelogRescalingITCase.test failed due to FileNotFoundException

[ https://issues.apache.org/jira/browse/FLINK-31527?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31527: -- Fix Version/s: 1.16.2 1.17.1 > ChangelogRescalingITCase.test

[jira] [Commented] (FLINK-30023) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed

[ https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703354#comment-17703354 ] Roman Khachatryan commented on FLINK-30023: --- Merged fix for test{*}Total{*}AttemptsPerUpload

[jira] [Comment Edited] (FLINK-30023) ChangelogStorageMetricsTest#testTotalAttemptsPerUpload failed

[ https://issues.apache.org/jira/browse/FLINK-30023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703354#comment-17703354 ] Roman Khachatryan edited comment on FLINK-30023 at 3/21/23 8:01 PM:

[jira] [Updated] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31139: -- Affects Version/s: 1.17.1 > not upload empty state changelog file >

[jira] [Updated] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31139: -- Fix Version/s: 1.17.1 > not upload empty state changelog file >

[jira] [Updated] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-31139: -- Affects Version/s: (was: 1.17.1) > not upload empty state changelog file >

[jira] [Commented] (FLINK-31139) not upload empty state changelog file

[ https://issues.apache.org/jira/browse/FLINK-31139?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17703348#comment-17703348 ] Roman Khachatryan commented on FLINK-31139: --- Merged into master as

  1   2   3   4   5   6   7   8   9   10   >