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-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-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-25678:
-
Summary: TaskExecutorStateChangelogStoragesManager.shutdown is not
thread-safe
Key: FLINK-25678
URL: https://issues.apache.org/jira/browse/FLINK-25678
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/F
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-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-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-25824:
-
Summary: E2e test phase fails on AZP after "Unable to locate
package moreutils"
Key: FLINK-25824
URL: https://issues.apache.org/jira/browse/F
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-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-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-25867:
-
Summary: [ZH] Add ChangelogBackend documentation
Key: FLINK-25867
URL: https://issues.apache.org/jira/browse/FLINK-25867
Project: Flink
Issue Type
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
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-25992:
-
Summary:
JobDispatcherITCase..testRecoverFromCheckpointAfterLosingAndRegainingLeadership
fails on azure
Key: FLINK-25992
URL: https://issues.apache.org/jira/browse
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-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-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-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-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-26093:
-
Summary: SavepointFormatITCase fails with ChangelogStateBackend
Key: FLINK-26093
URL: https://issues.apache.org/jira/browse/FLINK-26093
Project: Flink
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-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-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-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-26231:
-
Summary: [Changelog] Incorrect MaterializationID passed to
ChangelogStateBackendHandleImpl
Key: FLINK-26231
URL: https://issues.apache.org/jira/browse/FLINK-26231
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-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-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-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-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-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-20993:
-
Summary: Cleaning up checkpoint during shutdown may fail JM
Key: FLINK-20993
URL: https://issues.apache.org/jira/browse/FLINK-20993
Project: Flink
Roman Khachatryan created FLINK-21015:
-
Summary: Wait for checkpoint cleanup completion during shutdown
Key: FLINK-21015
URL: https://issues.apache.org/jira/browse/FLINK-21015
Project: Flink
Roman Khachatryan created FLINK-21033:
-
Summary: Remove PendingCheckpoint.statsCallback
Key: FLINK-21033
URL: https://issues.apache.org/jira/browse/FLINK-21033
Project: Flink
Issue Type
Roman Khachatryan created FLINK-21053:
-
Summary: Prevent further RejectedExecutionExceptions in
CheckpointCoordinator failing JM
Key: FLINK-21053
URL: https://issues.apache.org/jira/browse/FLINK-21053
Roman Khachatryan created FLINK-21122:
-
Summary: Update docs/ops/monitoring/checkpoint_monitoring.zh.md
Key: FLINK-21122
URL: https://issues.apache.org/jira/browse/FLINK-21122
Project: Flink
Roman Khachatryan created FLINK-21124:
-
Summary: Checkpoint abort RPC can be ignored in some cases
Key: FLINK-21124
URL: https://issues.apache.org/jira/browse/FLINK-21124
Project: Flink
Roman Khachatryan created FLINK-21131:
-
Summary: Show alignment timeout in checkpoint configuration (web
UI)
Key: FLINK-21131
URL: https://issues.apache.org/jira/browse/FLINK-21131
Project: Flink
Roman Khachatryan created FLINK-21233:
-
Summary: Race condition in CheckpointCoordinator in finishing sync
savepoint
Key: FLINK-21233
URL: https://issues.apache.org/jira/browse/FLINK-21233
Roman Khachatryan created FLINK-21352:
-
Summary: FLIP-158: Generalized incremental checkpoints
Key: FLINK-21352
URL: https://issues.apache.org/jira/browse/FLINK-21352
Project: Flink
Roman Khachatryan created FLINK-21353:
-
Summary: Add FS-based StateChangelog implementation
Key: FLINK-21353
URL: https://issues.apache.org/jira/browse/FLINK-21353
Project: Flink
Issue
Roman Khachatryan created FLINK-21354:
-
Summary: Add ChangelogStateBackend (proxy-everything)
Key: FLINK-21354
URL: https://issues.apache.org/jira/browse/FLINK-21354
Project: Flink
Issue
Roman Khachatryan created FLINK-21355:
-
Summary: Send changes to the state changelog (still proxy
everything)
Key: FLINK-21355
URL: https://issues.apache.org/jira/browse/FLINK-21355
Project
Roman Khachatryan created FLINK-21356:
-
Summary: Implement incremental checkpointing and recovery using
state changelog
Key: FLINK-21356
URL: https://issues.apache.org/jira/browse/FLINK-21356
Roman Khachatryan created FLINK-21357:
-
Summary: Add periodic materialization
Key: FLINK-21357
URL: https://issues.apache.org/jira/browse/FLINK-21357
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-21365:
-
Summary: Visibility issue in
FutureUtils.ResultConjunctFuture.handleCompletedFuture
Key: FLINK-21365
URL: https://issues.apache.org/jira/browse/FLINK-21365
Roman Khachatryan created FLINK-21367:
-
Summary: Support objectReuse in JDBC sink
Key: FLINK-21367
URL: https://issues.apache.org/jira/browse/FLINK-21367
Project: Flink
Issue Type
Roman Khachatryan created FLINK-21504:
-
Summary: Enrich checkpoint barriers with information previous
checkpoint(s)
Key: FLINK-21504
URL: https://issues.apache.org/jira/browse/FLINK-21504
Project
Roman Khachatryan created FLINK-21570:
-
Summary: Add Job ID to RuntimeContext
Key: FLINK-21570
URL: https://issues.apache.org/jira/browse/FLINK-21570
Project: Flink
Issue Type
Roman Khachatryan created FLINK-21581:
-
Summary: Add PublicEvolving to RuntimeContext.jobId
Key: FLINK-21581
URL: https://issues.apache.org/jira/browse/FLINK-21581
Project: Flink
Issue
Roman Khachatryan created FLINK-21648:
-
Summary: FLIP-151: Incremental snapshots for heap-based state
backend
Key: FLINK-21648
URL: https://issues.apache.org/jira/browse/FLINK-21648
Project
Roman Khachatryan created FLINK-21649:
-
Summary: Refactor CopyOnWrite state classes
Key: FLINK-21649
URL: https://issues.apache.org/jira/browse/FLINK-21649
Project: Flink
Issue Type: Sub
Roman Khachatryan created FLINK-21650:
-
Summary: On heap state restore, skip key groups from other state
backends
Key: FLINK-21650
URL: https://issues.apache.org/jira/browse/FLINK-21650
Project
Roman Khachatryan created FLINK-21673:
-
Summary: Add extension points to heap backend to read/write
incremental snapshots
Key: FLINK-21673
URL: https://issues.apache.org/jira/browse/FLINK-21673
Roman Khachatryan created FLINK-21752:
-
Summary: NullPointerException on restore in PojoSerializer
Key: FLINK-21752
URL: https://issues.apache.org/jira/browse/FLINK-21752
Project: Flink
Roman Khachatryan created FLINK-21783:
-
Summary: Allow extension of HeapBackend SnapshotStrategy
Key: FLINK-21783
URL: https://issues.apache.org/jira/browse/FLINK-21783
Project: Flink
Roman Khachatryan created FLINK-21784:
-
Summary: Allow extension of HeapBackend RestoreOperation
Key: FLINK-21784
URL: https://issues.apache.org/jira/browse/FLINK-21784
Project: Flink
Roman Khachatryan created FLINK-21804:
-
Summary: Load Changelog implementation via PluginManager
Key: FLINK-21804
URL: https://issues.apache.org/jira/browse/FLINK-21804
Project: Flink
Roman Khachatryan created FLINK-21831:
-
Summary: CLONE - Add ChangelogStateBackend (proxy-everything)
Key: FLINK-21831
URL: https://issues.apache.org/jira/browse/FLINK-21831
Project: Flink
Roman Khachatryan created FLINK-21970:
-
Summary: DegreesWithExceptionITCase fails on azure
Key: FLINK-21970
URL: https://issues.apache.org/jira/browse/FLINK-21970
Project: Flink
Issue
Roman Khachatryan created FLINK-22050:
-
Summary: Failed to release input gate
(IllegalReferenceCountException)
Key: FLINK-22050
URL: https://issues.apache.org/jira/browse/FLINK-22050
Project
Roman Khachatryan created FLINK-22141:
-
Summary: Manually test exactly-once JDBC sink
Key: FLINK-22141
URL: https://issues.apache.org/jira/browse/FLINK-22141
Project: Flink
Issue Type
Roman Khachatryan created FLINK-22232:
-
Summary: Improve test coverage for network stack
Key: FLINK-22232
URL: https://issues.apache.org/jira/browse/FLINK-22232
Project: Flink
Issue Type
Roman Khachatryan created FLINK-22288:
-
Summary: Remove unnecesary argument from JdbcSink.exactlyOnceSink
Key: FLINK-22288
URL: https://issues.apache.org/jira/browse/FLINK-22288
Project: Flink
Roman Khachatryan created FLINK-22289:
-
Summary: Update JDBC XA sink docs
Key: FLINK-22289
URL: https://issues.apache.org/jira/browse/FLINK-22289
Project: Flink
Issue Type: Improvement
Roman Khachatryan created FLINK-22325:
-
Summary: Channel state iterator is accessed concurrently without
proper synchronization
Key: FLINK-22325
URL: https://issues.apache.org/jira/browse/FLINK-22325
Roman Khachatryan created FLINK-22375:
-
Summary: Disable JDBC XA connection pooling if unnecessary
Key: FLINK-22375
URL: https://issues.apache.org/jira/browse/FLINK-22375
Project: Flink
Roman Khachatryan created FLINK-22376:
-
Summary: SequentialChannelStateReaderImpl may recycle buffer twice
Key: FLINK-22376
URL: https://issues.apache.org/jira/browse/FLINK-22376
Project: Flink
Roman Khachatryan created FLINK-22377:
-
Summary: Ignore if writer is stopped when aborting channel state
writing
Key: FLINK-22377
URL: https://issues.apache.org/jira/browse/FLINK-22377
Project
Roman Khachatryan created FLINK-22381:
-
Summary:
RocksDBStateBackendTests::test_get_set_number_of_transfering_threads fails on
azure
Key: FLINK-22381
URL: https://issues.apache.org/jira/browse/FLINK-22381
Roman Khachatryan created FLINK-22553:
-
Summary: Improve error reporting on TM connection failures
Key: FLINK-22553
URL: https://issues.apache.org/jira/browse/FLINK-22553
Project: Flink
Roman Khachatryan created FLINK-22621:
-
Summary: HBaseConnectorITCase.testTableSourceSinkWithDDL unstable
on azure
Key: FLINK-22621
URL: https://issues.apache.org/jira/browse/FLINK-22621
Project
Roman Khachatryan created FLINK-22717:
-
Summary:
JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails
fails with Adaptive Scheduler
Key: FLINK-22717
URL: https
Roman Khachatryan created FLINK-22731:
-
Summary: Environment variables are not passed to TM (YARN)
Key: FLINK-22731
URL: https://issues.apache.org/jira/browse/FLINK-22731
Project: Flink
Roman Khachatryan created FLINK-22746:
-
Summary: Links to connectors in docs are broken
Key: FLINK-22746
URL: https://issues.apache.org/jira/browse/FLINK-22746
Project: Flink
Issue Type
Roman Khachatryan created FLINK-22808:
-
Summary: Log metadata
Key: FLINK-22808
URL: https://issues.apache.org/jira/browse/FLINK-22808
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-22835:
-
Summary: ChangelogStateBackend tests use nested backend on recovery
Key: FLINK-22835
URL: https://issues.apache.org/jira/browse/FLINK-22835
Project: Flink
Roman Khachatryan created FLINK-22932:
-
Summary: RocksDBStateBackendWindowITCase fails with savepoint
timeout
Key: FLINK-22932
URL: https://issues.apache.org/jira/browse/FLINK-22932
Project
Roman Khachatryan created FLINK-22944:
-
Summary: Optimize writing state changes
Key: FLINK-22944
URL: https://issues.apache.org/jira/browse/FLINK-22944
Project: Flink
Issue Type
Roman Khachatryan created FLINK-22966:
-
Summary: NPE in StateAssignmentOperation when rescaling
Key: FLINK-22966
URL: https://issues.apache.org/jira/browse/FLINK-22966
Project: Flink
Roman Khachatryan created FLINK-23035:
-
Summary: Add explicit method to StateChangelogWriter to write
metadata
Key: FLINK-23035
URL: https://issues.apache.org/jira/browse/FLINK-23035
Project
Roman Khachatryan created FLINK-23137:
-
Summary: State ownership: disable discarding state of
ChangelogStateBackendHandle on JM
Key: FLINK-23137
URL: https://issues.apache.org/jira/browse/FLINK-23137
Roman Khachatryan created FLINK-23139:
-
Summary: State ownership: track and discard state (materialized
and non-materialized)
Key: FLINK-23139
URL: https://issues.apache.org/jira/browse/FLINK-23139
Roman Khachatryan created FLINK-23143:
-
Summary: Support state migration
Key: FLINK-23143
URL: https://issues.apache.org/jira/browse/FLINK-23143
Project: Flink
Issue Type: Sub-task
Roman Khachatryan created FLINK-23144:
-
Summary: Add percentiles to checkpoint stats
Key: FLINK-23144
URL: https://issues.apache.org/jira/browse/FLINK-23144
Project: Flink
Issue Type
Roman Khachatryan created FLINK-23170:
-
Summary: Write metadata after materialization
Key: FLINK-23170
URL: https://issues.apache.org/jira/browse/FLINK-23170
Project: Flink
Issue Type
Roman Khachatryan created FLINK-23204:
-
Summary: Provide StateBackends access to MailboxExecutor
Key: FLINK-23204
URL: https://issues.apache.org/jira/browse/FLINK-23204
Project: Flink
Roman Khachatryan created FLINK-23251:
-
Summary: Support more than one retained checkpoints
Key: FLINK-23251
URL: https://issues.apache.org/jira/browse/FLINK-23251
Project: Flink
Issue
Roman Khachatryan created FLINK-23252:
-
Summary: Support recovery with altered "changelog.enabled" option
Key: FLINK-23252
URL: https://issues.apache.org/jira/browse/FLINK-23252
Proj
Roman Khachatryan created FLINK-23276:
-
Summary: Changelog backend not always updates delegating functions
Key: FLINK-23276
URL: https://issues.apache.org/jira/browse/FLINK-23276
Project: Flink
Roman Khachatryan created FLINK-23277:
-
Summary: Changelog backend doesn't apply TTL after recovery
Key: FLINK-23277
URL: https://issues.apache.org/jira/browse/FLINK-23277
Project:
Roman Khachatryan created FLINK-23278:
-
Summary: Changelog backend creates "raw materialized" savepoint
but expects it's "normal" snapshot on recovery
Key: FLINK-23278
URL: https
Roman Khachatryan created FLINK-23279:
-
Summary: Enable changelog backend in tests
Key: FLINK-23279
URL: https://issues.apache.org/jira/browse/FLINK-23279
Project: Flink
Issue Type: Sub
Roman Khachatryan created FLINK-23283:
-
Summary: GroupWindowITCase.testWindowAggregateOnUpsertSource fails
on azure
Key: FLINK-23283
URL: https://issues.apache.org/jira/browse/FLINK-23283
Project
Roman Khachatryan created FLINK-23341:
-
Summary:
AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails
on azure
Key: FLINK-23341
URL: https://issues.apache.org/jira/browse/FLINK
Roman Khachatryan created FLINK-23342:
-
Summary: State ownership: compute shared state on recovery
Key: FLINK-23342
URL: https://issues.apache.org/jira/browse/FLINK-23342
Project: Flink
Roman Khachatryan created FLINK-23343:
-
Summary: State ownership: prevent shared state deletion on TM
Key: FLINK-23343
URL: https://issues.apache.org/jira/browse/FLINK-23343
Project: Flink
Roman Khachatryan created FLINK-23344:
-
Summary: State ownership: track and discard private state (rocks,
heap)
Key: FLINK-23344
URL: https://issues.apache.org/jira/browse/FLINK-23344
Project
201 - 300 of 377 matches
Mail list logo
