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
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:
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:
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
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:
Roman Khachatryan created FLINK-33590:
-
Summary: CheckpointStatsTracker.totalNumberOfSubTasks not updated
Key: FLINK-33590
URL: https://issues.apache.org/jira/browse/FLINK-33590
Project: Flink
Roman Khachatryan created FLINK-33442:
-
Summary: UnsupportedOperationException thrown from
RocksDBIncrementalRestoreOperation
Key: FLINK-33442
URL: https://issues.apache.org/jira/browse/FLINK-33442
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:
Roman Khachatryan created FLINK-31261:
-
Summary: Make AdaptiveScheduler aware of the (local) state size
Key: FLINK-31261
URL: https://issues.apache.org/jira/browse/FLINK-31261
Project: Flink
Roman Khachatryan created FLINK-30073:
-
Summary: Managed memory can be wasted if rocksdb memory is
fixed-per-slot
Key: FLINK-30073
URL: https://issues.apache.org/jira/browse/FLINK-30073
Project:
Roman Khachatryan created FLINK-29985:
-
Summary: SlotTable not close on TM termination
Key: FLINK-29985
URL: https://issues.apache.org/jira/browse/FLINK-29985
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-29928:
-
Summary: Allow sharing (RocksDB) memory between slots
Key: FLINK-29928
URL: https://issues.apache.org/jira/browse/FLINK-29928
Project: Flink
Issue
Roman Khachatryan created FLINK-29158:
-
Summary: Fix logging in DefaultCompletedCheckpointStore
Key: FLINK-29158
URL: https://issues.apache.org/jira/browse/FLINK-29158
Project: Flink
Roman Khachatryan created FLINK-29157:
-
Summary: Clarify the contract between CompletedCheckpointStore and
SharedStateRegistry
Key: FLINK-29157
URL: https://issues.apache.org/jira/browse/FLINK-29157
Roman Khachatryan created FLINK-28976:
-
Summary: Changelog 1st materialization delayed unneccesarily
Key: FLINK-28976
URL: https://issues.apache.org/jira/browse/FLINK-28976
Project: Flink
Roman Khachatryan created FLINK-28931:
-
Summary: BlockingPartitionBenchmark doesn't compile
Key: FLINK-28931
URL: https://issues.apache.org/jira/browse/FLINK-28931
Project: Flink
Issue
Roman Khachatryan created FLINK-28647:
-
Summary: Remove separate error handling and adjust documentation
for CLAIM mode + RocksDB native savepoint
Key: FLINK-28647
URL:
Roman Khachatryan created FLINK-28597:
-
Summary: Empty checkpoint folders not deleted on job cancellation
if their shared state is still in use
Key: FLINK-28597
URL:
Roman Khachatryan created FLINK-27571:
-
Summary: Recognize "less is better" benchmarks in regression
detection script
Key: FLINK-27571
URL: https://issues.apache.org/jira/browse/FLINK-27571
Roman Khachatryan created FLINK-27556:
-
Summary: Performance regression in checkpointSingleInput.UNALIGNED
on 29.04.2022
Key: FLINK-27556
URL: https://issues.apache.org/jira/browse/FLINK-27556
Roman Khachatryan created FLINK-27555:
-
Summary: Performance regression in schedulingDownstreamTasks on
02.05.2022
Key: FLINK-27555
URL: https://issues.apache.org/jira/browse/FLINK-27555
Project:
Roman Khachatryan created FLINK-27150:
-
Summary: Improve error reporting in Flink UI
Key: FLINK-27150
URL: https://issues.apache.org/jira/browse/FLINK-27150
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-27149:
-
Summary: KafkaSourceE2ECase.testScaleUp failed on AZP
Key: FLINK-27149
URL: https://issues.apache.org/jira/browse/FLINK-27149
Project: Flink
Issue
Roman Khachatryan created FLINK-27148:
-
Summary: UnalignedCheckpointITCase fails on AZP
Key: FLINK-27148
URL: https://issues.apache.org/jira/browse/FLINK-27148
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-27144:
-
Summary: Provide timeout details when calling FutureUtils.orTimeout
Key: FLINK-27144
URL: https://issues.apache.org/jira/browse/FLINK-27144
Project: Flink
Roman Khachatryan created FLINK-27132:
-
Summary: CheckpointResourcesCleanupRunner might discard shared
state of the initial checkpoint
Key: FLINK-27132
URL: https://issues.apache.org/jira/browse/FLINK-27132
Roman Khachatryan created FLINK-27114:
-
Summary: On JM restart, the information about the initial
checkpoints can be lost
Key: FLINK-27114
URL: https://issues.apache.org/jira/browse/FLINK-27114
Roman Khachatryan created FLINK-26968:
-
Summary: Bump CopyOnWriteStateMap entry version before write
Key: FLINK-26968
URL: https://issues.apache.org/jira/browse/FLINK-26968
Project: Flink
Roman Khachatryan created FLINK-26967:
-
Summary: Fix race condition in CopyOnWriteStateMap
Key: FLINK-26967
URL: https://issues.apache.org/jira/browse/FLINK-26967
Project: Flink
Issue
Roman Khachatryan created FLINK-26966:
-
Summary: Implement incremental checkpoints
Key: FLINK-26966
URL: https://issues.apache.org/jira/browse/FLINK-26966
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-26965:
-
Summary: Allow reuse of PeriodicMaterializationManager
Key: FLINK-26965
URL: https://issues.apache.org/jira/browse/FLINK-26965
Project: Flink
Roman Khachatryan created FLINK-26964:
-
Summary: Notify CheckpointStrategy about checkpoint
completion/abortion
Key: FLINK-26964
URL: https://issues.apache.org/jira/browse/FLINK-26964
Project:
Roman Khachatryan created FLINK-26963:
-
Summary: Allow heap state backend creation customization
Key: FLINK-26963
URL: https://issues.apache.org/jira/browse/FLINK-26963
Project: Flink
Roman Khachatryan created FLINK-26956:
-
Summary: AZP: don't log "[ERROR] Picked up JAVA_TOOL_OPTIONS:
-XX:+HeapDumpOnOutOfMemoryError"
Key: FLINK-26956
URL: https://issues.apache.org/jira/browse/FLINK-26956
Roman Khachatryan created FLINK-26912:
-
Summary: EventTimeWindowCheckpointingITCase.testTumblingTimeWindow
failed on azure
Key: FLINK-26912
URL: https://issues.apache.org/jira/browse/FLINK-26912
Roman Khachatryan created FLINK-26853:
-
Summary: HeapStateBackend ignores metadata updates in certain cases
Key: FLINK-26853
URL: https://issues.apache.org/jira/browse/FLINK-26853
Project: Flink
Roman Khachatryan created FLINK-26685:
-
Summary: Investigate/improve tests stability when using InMemory
Changelog implementation
Key: FLINK-26685
URL: https://issues.apache.org/jira/browse/FLINK-26685
Roman Khachatryan created FLINK-26636:
-
Summary: EmbeddedMultiThreadDependencyTests test_add_python_file
failed on azure
Key: FLINK-26636
URL: https://issues.apache.org/jira/browse/FLINK-26636
Roman Khachatryan created FLINK-26635:
-
Summary: KafkaSourceE2ECase.testMultipleSplits failed on azure
with Correlation id for response does not match request
Key: FLINK-26635
URL:
Roman Khachatryan created FLINK-26632:
-
Summary: JobManagerHAProcessFailureRecoveryITCase failed due to
JVM exits with code 239
Key: FLINK-26632
URL: https://issues.apache.org/jira/browse/FLINK-26632
Roman Khachatryan created FLINK-26615:
-
Summary: BatchingStateChangeUploadSchedulerTest.testRetryOnTimeout
fails on azure
Key: FLINK-26615
URL: https://issues.apache.org/jira/browse/FLINK-26615
Roman Khachatryan created FLINK-26592:
-
Summary: [Changelog] Deadlock in FsStateChangelogWriter
Key: FLINK-26592
URL: https://issues.apache.org/jira/browse/FLINK-26592
Project: Flink
Roman Khachatryan created FLINK-26591:
-
Summary: Compilation fails due to RawToBinaryCastRule
Key: FLINK-26591
URL: https://issues.apache.org/jira/browse/FLINK-26591
Project: Flink
Issue
Roman Khachatryan created FLINK-26590:
-
Summary: Triggered checkpoints can be delayed by discarding shared
state
Key: FLINK-26590
URL: https://issues.apache.org/jira/browse/FLINK-26590
Project:
Roman Khachatryan created FLINK-26485:
-
Summary: [Changelog] State not discarded after multiple retries
Key: FLINK-26485
URL: https://issues.apache.org/jira/browse/FLINK-26485
Project: Flink
Roman Khachatryan created FLINK-26455:
-
Summary: [Changelog] Materialization interleaved with task
cancellation can fail the job
Key: FLINK-26455
URL: https://issues.apache.org/jira/browse/FLINK-26455
Roman Khachatryan created FLINK-26396:
-
Summary: [Changelog] Upload is not failed even if all attempts
timeout
Key: FLINK-26396
URL: https://issues.apache.org/jira/browse/FLINK-26396
Project:
Roman Khachatryan created FLINK-26372:
-
Summary: Allow Changelog Storage configuration per program
Key: FLINK-26372
URL: https://issues.apache.org/jira/browse/FLINK-26372
Project: Flink
Roman Khachatryan created FLINK-26306:
-
Summary: Triggered checkpoints can be delayed by discarding shared
state
Key: FLINK-26306
URL: https://issues.apache.org/jira/browse/FLINK-26306
Project:
Roman Khachatryan created FLINK-26255:
-
Summary: SplitAggregateITCase.testAggWithJoin failed on azure
Key: FLINK-26255
URL: https://issues.apache.org/jira/browse/FLINK-26255
Project: Flink
Roman Khachatryan created FLINK-26231:
-
Summary: [Changelog] Incorrect MaterializationID passed to
ChangelogStateBackendHandleImpl
Key: FLINK-26231
URL: https://issues.apache.org/jira/browse/FLINK-26231
Roman Khachatryan created FLINK-26198:
-
Summary: ArchitectureTest fails on AZP (table.api.StatementSet)
Key: FLINK-26198
URL: https://issues.apache.org/jira/browse/FLINK-26198
Project: Flink
Roman Khachatryan created FLINK-26165:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26165
URL: https://issues.apache.org/jira/browse/FLINK-26165
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-26154:
-
Summary: SavepointFormatITCase fails on azure
Key: FLINK-26154
URL: https://issues.apache.org/jira/browse/FLINK-26154
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-26144:
-
Summary: SavepointFormatITCase did NOT fail with changelog.enabled
randomized
Key: FLINK-26144
URL: https://issues.apache.org/jira/browse/FLINK-26144
Roman Khachatryan created FLINK-26092:
-
Summary: JsonAggregationFunctionsITCase fails with NPE when using
RocksDB
Key: FLINK-26092
URL: https://issues.apache.org/jira/browse/FLINK-26092
Project:
Roman Khachatryan created FLINK-26079:
-
Summary: Disallow combination of Changelog backend and CLAIM
restore mode
Key: FLINK-26079
URL: https://issues.apache.org/jira/browse/FLINK-26079
Project:
Roman Khachatryan created FLINK-26063:
-
Summary: [Changelog] Incorrect key group logged for PQ.poll and
remove
Key: FLINK-26063
URL: https://issues.apache.org/jira/browse/FLINK-26063
Project:
Roman Khachatryan created FLINK-26062:
-
Summary: [Changelog] Non-deterministic recovery of PriorityQueue
states
Key: FLINK-26062
URL: https://issues.apache.org/jira/browse/FLINK-26062
Project:
Roman Khachatryan created FLINK-26019:
-
Summary: Changelogged PriorityQueue elements recovered out-of-order
Key: FLINK-26019
URL: https://issues.apache.org/jira/browse/FLINK-26019
Project: Flink
Roman Khachatryan created FLINK-25992:
-
Summary:
JobDispatcherITCase..testRecoverFromCheckpointAfterLosingAndRegainingLeadership
fails on azure
Key: FLINK-25992
URL:
Roman Khachatryan created FLINK-25987:
-
Summary: IllegalArgumentException thrown from
FsStateChangelogWriter.truncate
Key: FLINK-25987
URL: https://issues.apache.org/jira/browse/FLINK-25987
Roman Khachatryan created FLINK-25871:
-
Summary: "License Check failed" on AZP
Key: FLINK-25871
URL: https://issues.apache.org/jira/browse/FLINK-25871
Project: Flink
Issue Type: Bug
Roman Khachatryan created FLINK-25867:
-
Summary: [ZH] Add ChangelogBackend documentation
Key: FLINK-25867
URL: https://issues.apache.org/jira/browse/FLINK-25867
Project: Flink
Issue
Roman Khachatryan created FLINK-25850:
-
Summary: Consider notifying nested state backend about checkpoint
abortion
Key: FLINK-25850
URL: https://issues.apache.org/jira/browse/FLINK-25850
Project:
Roman Khachatryan created FLINK-25842:
-
Summary: [v2] FLIP-158: Generalized incremental checkpoints
Key: FLINK-25842
URL: https://issues.apache.org/jira/browse/FLINK-25842
Project: Flink
Roman Khachatryan created FLINK-25825:
-
Summary: MySqlCatalogITCase fails on azure
Key: FLINK-25825
URL: https://issues.apache.org/jira/browse/FLINK-25825
Project: Flink
Issue Type: Bug
Roman Khachatryan created FLINK-25824:
-
Summary: E2e test phase fails on AZP after "Unable to locate
package moreutils"
Key: FLINK-25824
URL: https://issues.apache.org/jira/browse/FLINK-25824
Roman Khachatryan created FLINK-25750:
-
Summary: Performance regression on 20.01.2021 in globalWindow and
stateBackend benchmarks
Key: FLINK-25750
URL: https://issues.apache.org/jira/browse/FLINK-25750
Roman Khachatryan created FLINK-25740:
-
Summary: PulsarSourceOrderedE2ECase fails on azure
Key: FLINK-25740
URL: https://issues.apache.org/jira/browse/FLINK-25740
Project: Flink
Issue
Roman Khachatryan created FLINK-25739:
-
Summary: Include dstl-dfs into distribution (opt/)
Key: FLINK-25739
URL: https://issues.apache.org/jira/browse/FLINK-25739
Project: Flink
Issue
Roman Khachatryan created FLINK-25710:
-
Summary: Multiple Kafka IT cases fail with "ContainerLaunch
Container startup failed"
Key: FLINK-25710
URL: https://issues.apache.org/jira/browse/FLINK-25710
Roman Khachatryan created FLINK-25678:
-
Summary: TaskExecutorStateChangelogStoragesManager.shutdown is not
thread-safe
Key: FLINK-25678
URL: https://issues.apache.org/jira/browse/FLINK-25678
Roman Khachatryan created FLINK-25598:
-
Summary: Changelog materialized state discarded on failure
Key: FLINK-25598
URL: https://issues.apache.org/jira/browse/FLINK-25598
Project: Flink
Roman Khachatryan created FLINK-25395:
-
Summary: Incremental shared state might be discarded by TM
Key: FLINK-25395
URL: https://issues.apache.org/jira/browse/FLINK-25395
Project: Flink
Roman Khachatryan created FLINK-25261:
-
Summary: Changelog not truncated on materialization
Key: FLINK-25261
URL: https://issues.apache.org/jira/browse/FLINK-25261
Project: Flink
Issue
Roman Khachatryan created FLINK-25260:
-
Summary: Recovery fails when using changelog+s3+presto
Key: FLINK-25260
URL: https://issues.apache.org/jira/browse/FLINK-25260
Project: Flink
Roman Khachatryan created FLINK-25144:
-
Summary: Manual test
Key: FLINK-25144
URL: https://issues.apache.org/jira/browse/FLINK-25144
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-25143:
-
Summary: Add ITCase for periodic materialization
Key: FLINK-25143
URL: https://issues.apache.org/jira/browse/FLINK-25143
Project: Flink
Issue
Roman Khachatryan created FLINK-25024:
-
Summary: Add ChangelogBackend documentation
Key: FLINK-25024
URL: https://issues.apache.org/jira/browse/FLINK-25024
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-24938:
-
Summary: Checkpoint cleaner is closed before checkpoints are
discarded
Key: FLINK-24938
URL: https://issues.apache.org/jira/browse/FLINK-24938
Project:
Roman Khachatryan created FLINK-24903:
-
Summary:
AdaptiveSchedulerTest.testJobStatusListenerNotifiedOfJobStatusChanges unstable
Key: FLINK-24903
URL: https://issues.apache.org/jira/browse/FLINK-24903
Roman Khachatryan created FLINK-24864:
-
Summary: Release TaskManagerJobMetricGroup with the last slot
rather than task
Key: FLINK-24864
URL: https://issues.apache.org/jira/browse/FLINK-24864
Roman Khachatryan created FLINK-24826:
-
Summary: Performance regression in HeapState benchmarks on Nov 8
2021
Key: FLINK-24826
URL: https://issues.apache.org/jira/browse/FLINK-24826
Project:
Roman Khachatryan created FLINK-24611:
-
Summary: Prevent JM from discarding state on checkpoint abortion
Key: FLINK-24611
URL: https://issues.apache.org/jira/browse/FLINK-24611
Project: Flink
Roman Khachatryan created FLINK-24402:
-
Summary: Add back-pressure metrics for the ChangelogStateBackend
Key: FLINK-24402
URL: https://issues.apache.org/jira/browse/FLINK-24402
Project: Flink
Roman Khachatryan created FLINK-23971:
-
Summary: PulsarSourceITCase.testIdleReader failed on azure
Key: FLINK-23971
URL: https://issues.apache.org/jira/browse/FLINK-23971
Project: Flink
Roman Khachatryan created FLINK-23950:
-
Summary: Revert FLINK-23738 (i.e. unhide config, API, docs)
Key: FLINK-23950
URL: https://issues.apache.org/jira/browse/FLINK-23950
Project: Flink
Roman Khachatryan created FLINK-23876:
-
Summary: Remove limitation about JDBC exactly once sink about
multiple connections per transaction
Key: FLINK-23876
URL:
Roman Khachatryan created FLINK-23862:
-
Summary: Race condition while cancelling task during initialization
Key: FLINK-23862
URL: https://issues.apache.org/jira/browse/FLINK-23862
Project: Flink
Roman Khachatryan created FLINK-23811:
-
Summary: Handle FINISHED subtasks in
CommonTestUtils.waitForAllTaskRunning
Key: FLINK-23811
URL: https://issues.apache.org/jira/browse/FLINK-23811
Project:
Roman Khachatryan created FLINK-23770:
-
Summary: Unable to recover after source fully finished
Key: FLINK-23770
URL: https://issues.apache.org/jira/browse/FLINK-23770
Project: Flink
Roman Khachatryan created FLINK-23738:
-
Summary: Hide any configuration, API or docs
Key: FLINK-23738
URL: https://issues.apache.org/jira/browse/FLINK-23738
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-23647:
-
Summary: UnalignedCheckpointStressITCase crashed on azure
Key: FLINK-23647
URL: https://issues.apache.org/jira/browse/FLINK-23647
Project: Flink
Roman Khachatryan created FLINK-23607:
-
Summary: Cleanup unnecessary dependencies in dstl pom.xml
Key: FLINK-23607
URL: https://issues.apache.org/jira/browse/FLINK-23607
Project: Flink
Roman Khachatryan created FLINK-23486:
-
Summary: Add monitoring/metrics for the ChangelogStateBackend
Key: FLINK-23486
URL: https://issues.apache.org/jira/browse/FLINK-23486
Project: Flink
Roman Khachatryan created FLINK-23485:
-
Summary: Add a benchmark for the Changelog DFS writer
Key: FLINK-23485
URL: https://issues.apache.org/jira/browse/FLINK-23485
Project: Flink
Issue
Roman Khachatryan created FLINK-23484:
-
Summary: Add a benchmark for the ChangelogStateBackend
Key: FLINK-23484
URL: https://issues.apache.org/jira/browse/FLINK-23484
Project: Flink
Roman Khachatryan created FLINK-23461:
-
Summary: Consider disallowing in-memory state handles for
materialized state
Key: FLINK-23461
URL: https://issues.apache.org/jira/browse/FLINK-23461
Roman Khachatryan created FLINK-23428:
-
Summary: Performance regression in state benchmarks on Jul 16 2021
Key: FLINK-23428
URL: https://issues.apache.org/jira/browse/FLINK-23428
Project: Flink
1 - 100 of 247 matches
Mail list logo
