Roman Khachatryan created FLINK-23416:
-
Summary: Don't log NoResourceAvailableException stacktrace
Key: FLINK-23416
URL: https://issues.apache.org/jira/browse/FLINK-23416
Project: Flink
Roman Khachatryan created FLINK-23381:
-
Summary: Provide backpressure (currently job fails if a limit hit)
Key: FLINK-23381
URL: https://issues.apache.org/jira/browse/FLINK-23381
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:
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-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-23341:
-
Summary:
AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails
on azure
Key: FLINK-23341
URL:
Roman Khachatryan created FLINK-23283:
-
Summary: GroupWindowITCase.testWindowAggregateOnUpsertSource fails
on azure
Key: FLINK-23283
URL: https://issues.apache.org/jira/browse/FLINK-23283
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:
Roman Khachatryan created FLINK-23278:
-
Summary: Changelog backend creates "raw materialized" savepoint
but expects it's "normal" snapshot on recovery
Key: FLINK-23278
URL:
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: Flink
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-23252:
-
Summary: Support recovery with altered "changelog.enabled" option
Key: FLINK-23252
URL: https://issues.apache.org/jira/browse/FLINK-23252
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-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-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-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-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-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-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-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-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-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-22932:
-
Summary: RocksDBStateBackendWindowITCase fails with savepoint
timeout
Key: FLINK-22932
URL: https://issues.apache.org/jira/browse/FLINK-22932
Project:
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-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-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-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-22717:
-
Summary:
JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails
fails with Adaptive Scheduler
Key: FLINK-22717
URL:
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-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-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-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-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-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-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-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-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-22232:
-
Summary: Improve test coverage for network stack
Key: FLINK-22232
URL: https://issues.apache.org/jira/browse/FLINK-22232
Project: Flink
Issue
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-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-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-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-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-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-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-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-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-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-21649:
-
Summary: Refactor CopyOnWrite state classes
Key: FLINK-21649
URL: https://issues.apache.org/jira/browse/FLINK-21649
Project: Flink
Issue Type:
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-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-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-21504:
-
Summary: Enrich checkpoint barriers with information previous
checkpoint(s)
Key: FLINK-21504
URL: https://issues.apache.org/jira/browse/FLINK-21504
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-21365:
-
Summary: Visibility issue in
FutureUtils.ResultConjunctFuture.handleCompletedFuture
Key: FLINK-21365
URL: https://issues.apache.org/jira/browse/FLINK-21365
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-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-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-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-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-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-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-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-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-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-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-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-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-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-20943:
-
Summary: AsyncCheckpointRunnable.cleanup() runs in the main task
thread
Key: FLINK-20943
URL: https://issues.apache.org/jira/browse/FLINK-20943
Project:
Roman Khachatryan created FLINK-20847:
-
Summary: Update CompletedCheckpointStore.shutdown() signature
Key: FLINK-20847
URL: https://issues.apache.org/jira/browse/FLINK-20847
Project: Flink
Roman Khachatryan created FLINK-20672:
-
Summary: CheckpointAborted RPC failure can fail JM
Key: FLINK-20672
URL: https://issues.apache.org/jira/browse/FLINK-20672
Project: Flink
Issue
Roman Khachatryan created FLINK-20548:
-
Summary: Provide an option to disable propagation of timed out
barriers
Key: FLINK-20548
URL: https://issues.apache.org/jira/browse/FLINK-20548
Project:
Roman Khachatryan created FLINK-20488:
-
Summary: Supporting changes (UI, conf) for timing out aligned
checkpoints
Key: FLINK-20488
URL: https://issues.apache.org/jira/browse/FLINK-20488
Project:
Roman Khachatryan created FLINK-20453:
-
Summary: Move checkpointing classes to a the appropriate package
Key: FLINK-20453
URL: https://issues.apache.org/jira/browse/FLINK-20453
Project: Flink
Roman Khachatryan created FLINK-20418:
-
Summary: NPE in IteratorSourceReader
Key: FLINK-20418
URL: https://issues.apache.org/jira/browse/FLINK-20418
Project: Flink
Issue Type: Bug
Roman Khachatryan created FLINK-20107:
-
Summary: Issues with setting InputChannel.statePersister
Key: FLINK-20107
URL: https://issues.apache.org/jira/browse/FLINK-20107
Project: Flink
Roman Khachatryan created FLINK-20103:
-
Summary: Improve test coverage for network stack
Key: FLINK-20103
URL: https://issues.apache.org/jira/browse/FLINK-20103
Project: Flink
Issue
Roman Khachatryan created FLINK-20097:
-
Summary: Race conditions in InputChannel.ChannelStatePersister
Key: FLINK-20097
URL: https://issues.apache.org/jira/browse/FLINK-20097
Project: Flink
Roman Khachatryan created FLINK-20079:
-
Summary: Modified UnalignedCheckpointITCase...MassivelyParallel
fails
Key: FLINK-20079
URL: https://issues.apache.org/jira/browse/FLINK-20079
Project:
Roman Khachatryan created FLINK-19924:
-
Summary: Disallow unaligned checkpoints for iterative jobs
Key: FLINK-19924
URL: https://issues.apache.org/jira/browse/FLINK-19924
Project: Flink
Roman Khachatryan created FLINK-19907:
-
Summary: Channel state (upstream) can be restored after emission
of new elements (watermarks)
Key: FLINK-19907
URL: https://issues.apache.org/jira/browse/FLINK-19907
Roman Khachatryan created FLINK-19856:
-
Summary: Add EndOfChannelRecovery rescaling epoch
Key: FLINK-19856
URL: https://issues.apache.org/jira/browse/FLINK-19856
Project: Flink
Issue
Roman Khachatryan created FLINK-19855:
-
Summary: Incompatible semantics of channelIndex in
UnionInputGate.resumeConsumption and its clients
Key: FLINK-19855
URL:
Roman Khachatryan created FLINK-19711:
-
Summary: Parsing of invalid CSV fails even with ignoreParseErrors
is enabled
Key: FLINK-19711
URL: https://issues.apache.org/jira/browse/FLINK-19711
Roman Khachatryan created FLINK-19550:
-
Summary: StreamingFileSink can't be interrupted when writing to S3
Key: FLINK-19550
URL: https://issues.apache.org/jira/browse/FLINK-19550
Project: Flink
Roman Khachatryan created FLINK-19539:
-
Summary: JMXReporterFactoryTest fails on Azure
Key: FLINK-19539
URL: https://issues.apache.org/jira/browse/FLINK-19539
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-19505:
-
Summary: Implement distributed DSTL (DFS-based)
Key: FLINK-19505
URL: https://issues.apache.org/jira/browse/FLINK-19505
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-19504:
-
Summary: Implement persistence for DSTL via DFS
Key: FLINK-19504
URL: https://issues.apache.org/jira/browse/FLINK-19504
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-19503:
-
Summary: Add DSTL interface and its in-memory implementation for
testing
Key: FLINK-19503
URL: https://issues.apache.org/jira/browse/FLINK-19503
Project:
Roman Khachatryan created FLINK-19385:
-
Summary: Channel recovery may deadlock
Key: FLINK-19385
URL: https://issues.apache.org/jira/browse/FLINK-19385
Project: Flink
Issue Type: Bug
Roman Khachatryan created FLINK-19113:
-
Summary: Add support for checkpointing with selectable inputs
Key: FLINK-19113
URL: https://issues.apache.org/jira/browse/FLINK-19113
Project: Flink
Roman Khachatryan created FLINK-19086:
-
Summary: Performance regressin 2020-08-28 in globalWindow benchmark
Key: FLINK-19086
URL: https://issues.apache.org/jira/browse/FLINK-19086
Project: Flink
Roman Khachatryan created FLINK-18991:
-
Summary: Optimize reading InputChannel state
Key: FLINK-18991
URL: https://issues.apache.org/jira/browse/FLINK-18991
Project: Flink
Issue Type:
Roman Khachatryan created FLINK-18990:
-
Summary: Optimize reading ResultSubpartition state
Key: FLINK-18990
URL: https://issues.apache.org/jira/browse/FLINK-18990
Project: Flink
Issue
Roman Khachatryan created FLINK-18989:
-
Summary: Write input and output channel state to separate files
Key: FLINK-18989
URL: https://issues.apache.org/jira/browse/FLINK-18989
Project: Flink
Roman Khachatryan created FLINK-18856:
-
Summary: CheckpointCoordinator ignores checkpointing.min-pause
Key: FLINK-18856
URL: https://issues.apache.org/jira/browse/FLINK-18856
Project: Flink
Roman Khachatryan created FLINK-18796:
-
Summary: FlinkKinesisProducer.backpressureLatch should be volatile
Key: FLINK-18796
URL: https://issues.apache.org/jira/browse/FLINK-18796
Project: Flink
Roman Khachatryan created FLINK-18786:
-
Summary: Performance regresssion on 2020.07.29 in some state
backend benchmarks
Key: FLINK-18786
URL: https://issues.apache.org/jira/browse/FLINK-18786
Roman Khachatryan created FLINK-18753:
-
Summary: Support local recovery for Unaligned checkpoints
Key: FLINK-18753
URL: https://issues.apache.org/jira/browse/FLINK-18753
Project: Flink
101 - 200 of 247 matches
Mail list logo