[jira] [Created] (FLINK-23416) Don't log NoResourceAvailableException stacktrace

2021-07-17 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23381) Provide backpressure (currently job fails if a limit hit)

2021-07-14 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23344) State ownership: track and discard private state (rocks, heap)

2021-07-09 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-23343) State ownership: prevent shared state deletion on TM

2021-07-09 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23342) State ownership: compute shared state on recovery

2021-07-09 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23341) AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure

2021-07-09 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23341: - Summary: AkkaRpcActorTest.testOnStopFutureCompletionDirectlyTerminatesAkkaRpcActor fails on azure Key: FLINK-23341 URL:

[jira] [Created] (FLINK-23283) GroupWindowITCase.testWindowAggregateOnUpsertSource fails on azure

2021-07-06 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23283: - Summary: GroupWindowITCase.testWindowAggregateOnUpsertSource fails on azure Key: FLINK-23283 URL: https://issues.apache.org/jira/browse/FLINK-23283

[jira] [Created] (FLINK-23279) Enable changelog backend in tests

2021-07-06 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-23278) Changelog backend creates "raw materialized" savepoint but expects it's "normal" snapshot on recovery

2021-07-06 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-23278: - Summary: Changelog backend creates "raw materialized" savepoint but expects it's "normal" snapshot on recovery Key: FLINK-23278 URL:

[jira] [Created] (FLINK-23277) Changelog backend doesn't apply TTL after recovery

2021-07-06 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23276) Changelog backend not always updates delegating functions

2021-07-06 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23252) Support recovery with altered "changelog.enabled" option

2021-07-05 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23251) Support more than one retained checkpoints

2021-07-05 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23204) Provide StateBackends access to MailboxExecutor

2021-07-01 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23170) Write metadata after materialization

2021-06-28 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-23144) Add percentiles to checkpoint stats

2021-06-24 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-23143) Support state migration

2021-06-24 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23139) State ownership: track and discard state (materialized and non-materialized)

2021-06-24 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23137) State ownership: disable discarding state of ChangelogStateBackendHandle on JM

2021-06-24 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-23035) Add explicit method to StateChangelogWriter to write metadata

2021-06-18 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-22966) NPE in StateAssignmentOperation when rescaling

2021-06-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22944) Optimize writing state changes

2021-06-09 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-22932) RocksDBStateBackendWindowITCase fails with savepoint timeout

2021-06-08 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22932: - Summary: RocksDBStateBackendWindowITCase fails with savepoint timeout Key: FLINK-22932 URL: https://issues.apache.org/jira/browse/FLINK-22932 Project:

[jira] [Created] (FLINK-22835) ChangelogStateBackend tests use nested backend on recovery

2021-06-01 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22808) Log metadata

2021-05-31 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22746) Links to connectors in docs are broken

2021-05-21 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-22731) Environment variables are not passed to TM (YARN)

2021-05-20 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22717) JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fails with Adaptive Scheduler

2021-05-19 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22717: - Summary: JobMasterStopWithSavepointITCase.testRestartCheckpointCoordinatorIfStopWithSavepointFails fails with Adaptive Scheduler Key: FLINK-22717 URL:

[jira] [Created] (FLINK-22621) HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure

2021-05-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-22621: - Summary: HBaseConnectorITCase.testTableSourceSinkWithDDL unstable on azure Key: FLINK-22621 URL: https://issues.apache.org/jira/browse/FLINK-22621 Project:

[jira] [Created] (FLINK-22553) Improve error reporting on TM connection failures

2021-05-03 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22381) RocksDBStateBackendTests::test_get_set_number_of_transfering_threads fails on azure

2021-04-20 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22377) Ignore if writer is stopped when aborting channel state writing

2021-04-20 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-22376) SequentialChannelStateReaderImpl may recycle buffer twice

2021-04-20 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22375) Disable JDBC XA connection pooling if unnecessary

2021-04-20 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22325) Channel state iterator is accessed concurrently without proper synchronization

2021-04-16 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22289) Update JDBC XA sink docs

2021-04-15 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22288) Remove unnecesary argument from JdbcSink.exactlyOnceSink

2021-04-15 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22232) Improve test coverage for network stack

2021-04-12 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-22141) Manually test exactly-once JDBC sink

2021-04-07 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-22050) Failed to release input gate (IllegalReferenceCountException)

2021-03-30 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21970) DegreesWithExceptionITCase fails on azure

2021-03-25 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21831) CLONE - Add ChangelogStateBackend (proxy-everything)

2021-03-16 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21804) Load Changelog implementation via PluginManager

2021-03-15 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21784) Allow extension of HeapBackend RestoreOperation

2021-03-14 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21783) Allow extension of HeapBackend SnapshotStrategy

2021-03-14 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21752) NullPointerException on restore in PojoSerializer

2021-03-12 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21673) Add extension points to heap backend to read/write incremental snapshots

2021-03-08 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21650) On heap state restore, skip key groups from other state backends

2021-03-07 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21649) Refactor CopyOnWrite state classes

2021-03-07 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21648) FLIP-151: Incremental snapshots for heap-based state backend

2021-03-07 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21581) Add PublicEvolving to RuntimeContext.jobId

2021-03-03 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21570) Add Job ID to RuntimeContext

2021-03-02 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21504) Enrich checkpoint barriers with information previous checkpoint(s)

2021-02-25 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21367) Support objectReuse in JDBC sink

2021-02-12 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21365) Visibility issue in FutureUtils.ResultConjunctFuture.handleCompletedFuture

2021-02-11 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-21365: - Summary: Visibility issue in FutureUtils.ResultConjunctFuture.handleCompletedFuture Key: FLINK-21365 URL: https://issues.apache.org/jira/browse/FLINK-21365

[jira] [Created] (FLINK-21357) Add periodic materialization

2021-02-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21356) Implement incremental checkpointing and recovery using state changelog

2021-02-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21355) Send changes to the state changelog (still proxy everything)

2021-02-10 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21354) Add ChangelogStateBackend (proxy-everything)

2021-02-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21353) Add FS-based StateChangelog implementation

2021-02-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21352) FLIP-158: Generalized incremental checkpoints

2021-02-10 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21233) Race condition in CheckpointCoordinator in finishing sync savepoint

2021-02-01 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21131) Show alignment timeout in checkpoint configuration (web UI)

2021-01-25 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21124) Checkpoint abort RPC can be ignored in some cases

2021-01-25 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21122) Update docs/ops/monitoring/checkpoint_monitoring.zh.md

2021-01-25 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21053) Prevent further RejectedExecutionExceptions in CheckpointCoordinator failing JM

2021-01-20 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-21033) Remove PendingCheckpoint.statsCallback

2021-01-19 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-21015) Wait for checkpoint cleanup completion during shutdown

2021-01-18 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20993) Cleaning up checkpoint during shutdown may fail JM

2021-01-15 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20943) AsyncCheckpointRunnable.cleanup() runs in the main task thread

2021-01-12 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-20847) Update CompletedCheckpointStore.shutdown() signature

2021-01-04 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20847: - Summary: Update CompletedCheckpointStore.shutdown() signature Key: FLINK-20847 URL: https://issues.apache.org/jira/browse/FLINK-20847 Project: Flink

[jira] [Created] (FLINK-20672) CheckpointAborted RPC failure can fail JM

2020-12-18 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20548) Provide an option to disable propagation of timed out barriers

2020-12-09 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-20488) Supporting changes (UI, conf) for timing out aligned checkpoints

2020-12-04 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-20453) Move checkpointing classes to a the appropriate package

2020-12-02 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20418) NPE in IteratorSourceReader

2020-11-30 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20107) Issues with setting InputChannel.statePersister

2020-11-12 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20103) Improve test coverage for network stack

2020-11-12 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20097) Race conditions in InputChannel.ChannelStatePersister

2020-11-11 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-20079) Modified UnalignedCheckpointITCase...MassivelyParallel fails

2020-11-10 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-20079: - Summary: Modified UnalignedCheckpointITCase...MassivelyParallel fails Key: FLINK-20079 URL: https://issues.apache.org/jira/browse/FLINK-20079 Project:

[jira] [Created] (FLINK-19924) Disallow unaligned checkpoints for iterative jobs

2020-11-02 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19907) Channel state (upstream) can be restored after emission of new elements (watermarks)

2020-10-31 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19856) Add EndOfChannelRecovery rescaling epoch

2020-10-28 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19855) Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients

2020-10-28 Thread Roman Khachatryan (Jira)
Roman Khachatryan created FLINK-19855: - Summary: Incompatible semantics of channelIndex in UnionInputGate.resumeConsumption and its clients Key: FLINK-19855 URL:

[jira] [Created] (FLINK-19711) Parsing of invalid CSV fails even with ignoreParseErrors is enabled

2020-10-19 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19550) StreamingFileSink can't be interrupted when writing to S3

2020-10-09 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19539) JMXReporterFactoryTest fails on Azure

2020-10-08 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-19505) Implement distributed DSTL (DFS-based)

2020-10-05 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-19504) Implement persistence for DSTL via DFS

2020-10-05 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-19503) Add DSTL interface and its in-memory implementation for testing

2020-10-05 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-19385) Channel recovery may deadlock

2020-09-23 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19113) Add support for checkpointing with selectable inputs

2020-09-01 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-19086) Performance regressin 2020-08-28 in globalWindow benchmark

2020-08-28 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18991) Optimize reading InputChannel state

2020-08-18 Thread Roman Khachatryan (Jira)
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:

[jira] [Created] (FLINK-18990) Optimize reading ResultSubpartition state

2020-08-18 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18989) Write input and output channel state to separate files

2020-08-18 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18856) CheckpointCoordinator ignores checkpointing.min-pause

2020-08-08 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18796) FlinkKinesisProducer.backpressureLatch should be volatile

2020-08-01 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18786) Performance regresssion on 2020.07.29 in some state backend benchmarks

2020-07-31 Thread Roman Khachatryan (Jira)
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

[jira] [Created] (FLINK-18753) Support local recovery for Unaligned checkpoints

2020-07-29 Thread Roman Khachatryan (Jira)
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

<    1   2   3   >