[jira] [Closed] (FLINK-35581) Remove comments from the code related to ingestDB

[ https://issues.apache.org/jira/browse/FLINK-35581?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35581. - Assignee: Yue Ma Resolution: Fixed Merged into master as 0cde81ab26638f77ce4c71ed5

[jira] [Closed] (FLINK-35575) FRocksDB supports disabling perf context during compilation

[ https://issues.apache.org/jira/browse/FLINK-35575?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35575. - Assignee: Yue Ma Resolution: Fixed Merged as 7a76723056dd9092b88032526b8bfa16058e0

[jira] [Closed] (FLINK-36030) Don't use negative values for changelog recovery tests

[ https://issues.apache.org/jira/browse/FLINK-36030?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-36030. - Resolution: Fixed Merged into master as 6fcf4555391487661ffab1e72f6d0e2875bca6a4 > Don'

[jira] [Created] (FLINK-36030) Don't use negative values for changelog recovery tests

Roman Khachatryan created FLINK-36030: - Summary: Don't use negative values for changelog recovery tests Key: FLINK-36030 URL: https://issues.apache.org/jira/browse/FLINK-36030 Project: Flink

[jira] [Closed] (FLINK-35576) FRocksDB cherry pick IngestDB related commits

[ https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35576. - Resolution: Fixed Merged into FRocksDB-8.10.0 as ed46268ea99b85370e9a8098be16806860aa620

[jira] [Commented] (FLINK-35576) FRocksDB cherry pick IngestDB related commits

[ https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17872727#comment-17872727 ] Roman Khachatryan commented on FLINK-35576: --- Thanks [~mayuehappy] ! All the PR

[jira] [Commented] (FLINK-34397) Resource wait timeout can't be disabled

[ https://issues.apache.org/jira/browse/FLINK-34397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17871918#comment-17871918 ] Roman Khachatryan commented on FLINK-34397: --- Technically, java.time.Duration s

[jira] [Closed] (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 closed FLINK-26050. - Resolution: Fixed Merged as [cd722033fb326837a80a6233603d12ad176da15c|https://github.co

[jira] [Updated] (FLINK-35970) Update documentation about FLINK-26050 (merging small SST files)

[ https://issues.apache.org/jira/browse/FLINK-35970?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35970: -- Summary: Update documentation about FLINK-26050 (merging small SST files) (was: Updat

[jira] [Updated] (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 updated FLINK-26050: -- Fix Version/s: 1.20.0 (was: 2.0.0) > Too many small sst files i

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM: ---

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan commented on FLINK-26050: --- [~Weijie Guo] I created a separat

[jira] [Comment Edited] (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:comment-tabpanel&focusedCommentId=17870541#comment-17870541 ] Roman Khachatryan edited comment on FLINK-26050 at 8/2/24 2:29 PM: ---

[jira] [Created] (FLINK-35970) Update documentation about FLINK-26050 (small file compaction)

Roman Khachatryan created FLINK-35970: - Summary: Update documentation about FLINK-26050 (small file compaction) Key: FLINK-35970 URL: https://issues.apache.org/jira/browse/FLINK-35970 Project: Fli

[jira] [Closed] (FLINK-35933) Skip distributing maxAllowedWatermark if there are no subtasks

[ https://issues.apache.org/jira/browse/FLINK-35933?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35933. - Resolution: Fixed cdf43aecafa33a50a4b4b6841c4cf505b195994a > Skip distributing maxAllow

[jira] [Created] (FLINK-35933) Skip distributing maxAllowedWatermark if there are no subtasks

Roman Khachatryan created FLINK-35933: - Summary: Skip distributing maxAllowedWatermark if there are no subtasks Key: FLINK-35933 URL: https://issues.apache.org/jira/browse/FLINK-35933 Project: Fli

[jira] [Closed] (FLINK-31261) Make AdaptiveScheduler aware of the (local) state size

[ https://issues.apache.org/jira/browse/FLINK-31261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-31261. - Resolution: Fixed Implemented in caf9b23b3208c8b30cdb6c56ff6f334e2342ce5c..999b7a2f2e3a

[jira] [Commented] (FLINK-35576) FRocksDB cherry pick IngestDB related commits

[ https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17866864#comment-17866864 ] Roman Khachatryan commented on FLINK-35576: --- Thank you [~mayuehappy] and [~zak

[jira] [Commented] (FLINK-33672) Use MapState.entries() instead of keys() and get() in over window

[ https://issues.apache.org/jira/browse/FLINK-33672?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864748#comment-17864748 ] Roman Khachatryan commented on FLINK-33672: --- Nice optimization! Do you have a

[jira] [Commented] (FLINK-35576) FRocksDB cherry pick IngestDB related commits

[ https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17864570#comment-17864570 ] Roman Khachatryan commented on FLINK-35576: --- Thanks [~mayuehappy], I think it

[jira] [Closed] (FLINK-35786) NPE in BlobServer / shutdownHook

[ https://issues.apache.org/jira/browse/FLINK-35786?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35786. - Resolution: Fixed Fix merged to master as [050767cda9de4f41748b0169b28679a87b5c5a11|htt

[jira] [Updated] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

[ https://issues.apache.org/jira/browse/FLINK-35787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35787: -- Description: In our internal CI, I've encountered the following error: {code:java} * 1

[jira] [Updated] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

[ https://issues.apache.org/jira/browse/FLINK-35787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35787: -- Description: In our internal CI, I've encountered the following error: {code:java} * 1

[jira] [Updated] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

[ https://issues.apache.org/jira/browse/FLINK-35787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35787: -- Affects Version/s: 1.19.1 > DefaultSlotStatusSyncer might bring down JVM (exit code 23

[jira] [Updated] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

[ https://issues.apache.org/jira/browse/FLINK-35787?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35787: -- Component/s: Runtime / Coordination > DefaultSlotStatusSyncer might bring down JVM (ex

[jira] [Created] (FLINK-35787) DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown)

Roman Khachatryan created FLINK-35787: - Summary: DefaultSlotStatusSyncer might bring down JVM (exit code 239 instead of a proper shutdown) Key: FLINK-35787 URL: https://issues.apache.org/jira/browse/FLINK-3578

[jira] [Created] (FLINK-35786) NPE in BlobServer / shutdownHook

Roman Khachatryan created FLINK-35786: - Summary: NPE in BlobServer / shutdownHook Key: FLINK-35786 URL: https://issues.apache.org/jira/browse/FLINK-35786 Project: Flink Issue Type: Bug

[jira] [Updated] (FLINK-35769) State files might not be deleted on task cancellation

[ https://issues.apache.org/jira/browse/FLINK-35769?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35769: -- Description: We have a job in an infinite (fast) restart loop, that’s crashing with a

[jira] [Created] (FLINK-35769) State files might not be deleted on task cancellation

Roman Khachatryan created FLINK-35769: - Summary: State files might not be deleted on task cancellation Key: FLINK-35769 URL: https://issues.apache.org/jira/browse/FLINK-35769 Project: Flink

[jira] [Updated] (FLINK-35742) Don't create RocksDB CF if task cancellation is in progress

[ https://issues.apache.org/jira/browse/FLINK-35742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35742: -- Affects Version/s: (was: 1.19.1) > Don't create RocksDB CF if task cancellation is

[jira] [Updated] (FLINK-35742) Don't create RocksDB CF if task cancellation is in progress

[ https://issues.apache.org/jira/browse/FLINK-35742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35742: -- Component/s: Runtime / State Backends > Don't create RocksDB CF if task cancellation i

[jira] [Closed] (FLINK-35742) Don't create RocksDB CF if task cancellation is in progress

[ https://issues.apache.org/jira/browse/FLINK-35742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35742. - Resolution: Fixed Merged to master as https://github.com/apache/flink/commit/0b0158b4df

[jira] [Updated] (FLINK-35742) Don't create RocksDB CF if task cancellation is in progress

[ https://issues.apache.org/jira/browse/FLINK-35742?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35742: -- Affects Version/s: 1.19.1 > Don't create RocksDB CF if task cancellation is in progres

[jira] [Created] (FLINK-35742) Don't create RocksDB CF if task cancellation is in progress

Roman Khachatryan created FLINK-35742: - Summary: Don't create RocksDB CF if task cancellation is in progress Key: FLINK-35742 URL: https://issues.apache.org/jira/browse/FLINK-35742 Project: Flink

[jira] [Updated] (FLINK-35606) Release Testing Instructions: Verify 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-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35606: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-26050

[jira] [Updated] (FLINK-35606) Release Testing Instructions: Verify 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-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35606: -- Description: Follow up the test for https://issues.apache.org/jira/browse/FLINK-26050

[jira] [Commented] (FLINK-35606) Release Testing Instructions: Verify 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-35606?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17861034#comment-17861034 ] Roman Khachatryan commented on FLINK-35606: --- Hi [~Weijie Guo] , yes, it would

[jira] [Commented] (FLINK-35576) FRocksDB cherry pick IngestDB related commits

[ https://issues.apache.org/jira/browse/FLINK-35576?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859501#comment-17859501 ] Roman Khachatryan commented on FLINK-35576: --- The list of commits LGTM, only th

[jira] [Commented] (FLINK-35574) Setup base branch for FrocksDB-8.10

[ https://issues.apache.org/jira/browse/FLINK-35574?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17859500#comment-17859500 ] Roman Khachatryan commented on FLINK-35574: --- Sure [~mayuehappy] , LGTM. Sorry

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

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

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

[ https://issues.apache.org/jira/browse/FLINK-8?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17854439#comment-17854439 ] Roman Khachatryan commented on FLINK-8: --- Thanks [~mayuehappy], makes sense

[jira] [Commented] (FLINK-35557) MemoryManager only reserves memory per consumer type once

[ https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17853161#comment-17853161 ] Roman Khachatryan commented on FLINK-35557: --- I guess it doesn't manifest itsel

[jira] [Updated] (FLINK-35557) MemoryManager only reserves memory per consumer type once

[ https://issues.apache.org/jira/browse/FLINK-35557?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35557: -- Description: # In {{MemoryManager.getSharedMemoryResourceForManagedMemory}} we  [creat

[jira] [Created] (FLINK-35557) MemoryManager only reserves memory per consumer type once

Roman Khachatryan created FLINK-35557: - Summary: MemoryManager only reserves memory per consumer type once Key: FLINK-35557 URL: https://issues.apache.org/jira/browse/FLINK-35557 Project: Flink

[jira] [Updated] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED

[ https://issues.apache.org/jira/browse/FLINK-35556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan updated FLINK-35556: -- Component/s: Runtime / State Backends > Wrong constant in RocksDBSharedResourcesFactor

[jira] [Created] (FLINK-35556) Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED

Roman Khachatryan created FLINK-35556: - Summary: Wrong constant in RocksDBSharedResourcesFactory.SLOT_SHARED_MANAGED Key: FLINK-35556 URL: https://issues.apache.org/jira/browse/FLINK-35556 Project

[jira] [Closed] (FLINK-35501) Use common thread pools when transferring RocksDB state files

[ https://issues.apache.org/jira/browse/FLINK-35501?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Roman Khachatryan closed FLINK-35501. - Release Note: The semantics of state.backend.rocksdb.checkpoint.transfer.thread.num chan

[jira] [Commented] (FLINK-35501) Use common thread pools when transferring RocksDB state files

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

[jira] [Commented] (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:comment-tabpanel&focusedCommentId=17852344#comment-17852344 ] Roman Khachatryan commented on FLINK-26050: --- Manual compaction merged into mas

[jira] [Commented] (FLINK-35502) compress the checkpoint metadata generated by ZK/ETCD HA Services

[ https://issues.apache.org/jira/browse/FLINK-35502?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851292#comment-17851292 ] Roman Khachatryan commented on FLINK-35502: --- [~yingz] , could you clarify the

[jira] [Commented] (FLINK-19303) Disable WAL in RocksDB recovery

[ https://issues.apache.org/jira/browse/FLINK-19303?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17851172#comment-17851172 ] Roman Khachatryan commented on FLINK-19303: --- I think this was fixed in FLINK-3

[jira] [Created] (FLINK-35501) Use common thread pools when transferring RocksDB state files

Roman Khachatryan created FLINK-35501: - Summary: Use common thread pools when transferring RocksDB state files Key: FLINK-35501 URL: https://issues.apache.org/jira/browse/FLINK-35501 Project: Flin

[jira] [Updated] (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 updated FLINK-26050: -- Fix Version/s: 1.20.0 > Too many small sst files in rocksdb state backend when using t

[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&focusedCommentId=17842587#comment-17842587 ] Roman Khachatryan commented on FLINK-35217: --- Backported to 1.18 as e6726d3b96

[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&focusedCommentId=17842363#comment-17842363 ] Roman Khachatryan commented on FLINK-35217: --- [~srichter] would you mind backpo

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

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

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

[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: [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=5

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

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

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

[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&focusedCommentId=17833443#comment-17833443 ] Roman Khachatryan commented on FLINK-34643: --- I agree, I'd open a separate tick

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

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

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

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

[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&focusedCommentId=17829969#comment-17829969 ] Roman Khachatryan commented on FLINK-34643: --- Merged into master as ed4d6f091f

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

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

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

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

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

[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&focusedCommentId=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&focusedCommentId=17824806#comment-17824806 ] Roman Khachatryan commented on FLINK-34417: --- Merged into master as d6a4eb966fb

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

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

[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&focusedCommentId=17821209#comment-17821209 ] Roman Khachatryan commented on FLINK-34420: --- IIRC, there was a difference in P

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

[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&focusedCommentId=17818251#comment-17818251 ] Roman Khachatryan commented on FLINK-33734: --- As for {quote}IIUC, ByteStreamSta

[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&focusedCommentId=17818249#comment-17818249 ] Roman Khachatryan commented on FLINK-33734: --- Thanks for the PR [~Feifan Wang] 

[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&focusedCommentId=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&focusedCommentId=17818243#comment-17818243 ] Roman Khachatryan commented on FLINK-34448: --- [This|https://dev.azure.com/apach

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

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

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

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

[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&focusedCommentId=17794682#comment-17794682 ] Roman Khachatryan commented on FLINK-33734: --- Thanks for the proposal! You're

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

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

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

  1   2   3   4   5   6   7   8   9   10   >