Stefan Richter created FLINK-4083:
-
Summary: Use ClosureCleaner for Join where and equalTo
Key: FLINK-4083
URL: https://issues.apache.org/jira/browse/FLINK-4083
Project: Flink
Issue Type:
Stefan Richter created FLINK-4374:
-
Summary: GroupReduce Broken for null Date
Key: FLINK-4374
URL: https://issues.apache.org/jira/browse/FLINK-4374
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-4230:
-
Summary: Session Windowing IT Case
Key: FLINK-4230
URL: https://issues.apache.org/jira/browse/FLINK-4230
Project: Flink
Issue Type: Test
Stefan Richter created FLINK-4201:
-
Summary: Checkpoints for jobs in non-terminal state (e.g.
suspended) get deleted
Key: FLINK-4201
URL: https://issues.apache.org/jira/browse/FLINK-4201
Project:
Stefan Richter created FLINK-4200:
-
Summary: Kafka consumers should log the offset from which they
restore
Key: FLINK-4200
URL: https://issues.apache.org/jira/browse/FLINK-4200
Project: Flink
Stefan Richter created FLINK-4211:
-
Summary: Dynamic Properties not working for jobs submitted to Yarn
session
Key: FLINK-4211
URL: https://issues.apache.org/jira/browse/FLINK-4211
Project: Flink
Stefan Richter created FLINK-4166:
-
Summary: Generate automatic different namespaces in Zookeeper for
Flink applications
Key: FLINK-4166
URL: https://issues.apache.org/jira/browse/FLINK-4166
Project:
Stefan Richter created FLINK-4150:
-
Summary: Problem with Blobstore in Yarn HA setting on recovery
after cluster shutdown
Key: FLINK-4150
URL: https://issues.apache.org/jira/browse/FLINK-4150
Stefan Richter created FLINK-4156:
-
Summary: Job with -m yarn-cluster registers TaskManagers to
another running Yarn session
Key: FLINK-4156
URL: https://issues.apache.org/jira/browse/FLINK-4156
Stefan Richter created FLINK-4134:
-
Summary: EventTimeSessionWindows trigger for empty windows when
dropping late events
Key: FLINK-4134
URL: https://issues.apache.org/jira/browse/FLINK-4134
Project:
Stefan Richter created FLINK-4141:
-
Summary: TaskManager failures not always recover when killed
during an ApplicationMaster failure in HA mode on Yarn
Key: FLINK-4141
URL:
Stefan Richter created FLINK-4142:
-
Summary: Recovery problem in HA on Hadoop Yarn 2.5.0
Key: FLINK-4142
URL: https://issues.apache.org/jira/browse/FLINK-4142
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5730:
-
Summary: User can concurrently modify state metadata of RocksDB
asynchronous snapshots
Key: FLINK-5730
URL: https://issues.apache.org/jira/browse/FLINK-5730
Stefan Richter created FLINK-5715:
-
Summary: Asynchronous snapshotting for HeapKeyedStateBackend
Key: FLINK-5715
URL: https://issues.apache.org/jira/browse/FLINK-5715
Project: Flink
Issue
Stefan Richter created FLINK-5707:
-
Summary: Find better keys for backend configuration parameters
Key: FLINK-5707
URL: https://issues.apache.org/jira/browse/FLINK-5707
Project: Flink
Issue
Stefan Richter created FLINK-5681:
-
Summary: Make ReaperThread for SafetyNetCloseableRegistry a
singleton
Key: FLINK-5681
URL: https://issues.apache.org/jira/browse/FLINK-5681
Project: Flink
Stefan Richter created FLINK-4492:
-
Summary: Cleanup files from canceled snapshots
Key: FLINK-4492
URL: https://issues.apache.org/jira/browse/FLINK-4492
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-4493:
-
Summary: Unify the snapshot output format for keyed-state backends
Key: FLINK-4493
URL: https://issues.apache.org/jira/browse/FLINK-4493
Project: Flink
Stefan Richter created FLINK-4744:
-
Summary: Introduce usercode class loader to deserialize
partitionable operator state
Key: FLINK-4744
URL: https://issues.apache.org/jira/browse/FLINK-4744
Project:
Stefan Richter created FLINK-4730:
-
Summary: Introduce CheckpointMetaData
Key: FLINK-4730
URL: https://issues.apache.org/jira/browse/FLINK-4730
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-4731:
-
Summary: HeapKeyedStateBackend restorig broken for scale-in
Key: FLINK-4731
URL: https://issues.apache.org/jira/browse/FLINK-4731
Project: Flink
Issue
Stefan Richter created FLINK-4508:
-
Summary: Consolidate DummyEnvironment and MockEnvironment for Tests
Key: FLINK-4508
URL: https://issues.apache.org/jira/browse/FLINK-4508
Project: Flink
Stefan Richter created FLINK-5041:
-
Summary: Implement savepoint backwards compatibility 1.1 -> 1.2
Key: FLINK-5041
URL: https://issues.apache.org/jira/browse/FLINK-5041
Project: Flink
Issue
Stefan Richter created FLINK-5043:
-
Summary: Converting keyed state from Flink 1.1 backend
implementations to their new counterparts in 1.2
Key: FLINK-5043
URL: https://issues.apache.org/jira/browse/FLINK-5043
Stefan Richter created FLINK-5042:
-
Summary: Convert old savepoints to new savepoints
Key: FLINK-5042
URL: https://issues.apache.org/jira/browse/FLINK-5042
Project: Flink
Issue Type:
Stefan Richter created FLINK-5044:
-
Summary: Converting operator and function state from Flink 1.1 for
all changed operators in 1.2
Key: FLINK-5044
URL: https://issues.apache.org/jira/browse/FLINK-5044
Stefan Richter created FLINK-5051:
-
Summary: Backwards compatibility for serializers in backend state
Key: FLINK-5051
URL: https://issues.apache.org/jira/browse/FLINK-5051
Project: Flink
Stefan Richter created FLINK-5052:
-
Summary: Changing the maximum parallelism (number of key groups)
of a job
Key: FLINK-5052
URL: https://issues.apache.org/jira/browse/FLINK-5052
Project: Flink
Stefan Richter created FLINK-5053:
-
Summary: Incremental / lightweight snapshots for checkpoints
Key: FLINK-5053
URL: https://issues.apache.org/jira/browse/FLINK-5053
Project: Flink
Issue
Stefan Richter created FLINK-5146:
-
Summary: Improved resource cleanup in RocksDB keyed state backend
Key: FLINK-5146
URL: https://issues.apache.org/jira/browse/FLINK-5146
Project: Flink
Stefan Richter created FLINK-5099:
-
Summary: Test testCancelPartitionRequest is instable
Key: FLINK-5099
URL: https://issues.apache.org/jira/browse/FLINK-5099
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5100:
-
Summary: Test testZooKeeperReelection is instable
Key: FLINK-5100
URL: https://issues.apache.org/jira/browse/FLINK-5100
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5101:
-
Summary: Test CassandraConnectorITCase instable
Key: FLINK-5101
URL: https://issues.apache.org/jira/browse/FLINK-5101
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-5107:
-
Summary: Job Manager goes out of memory from long history of prior
execution attempts
Key: FLINK-5107
URL: https://issues.apache.org/jira/browse/FLINK-5107
Stefan Richter created FLINK-5019:
-
Summary: Proper isRestored result for tasks that did not write
state
Key: FLINK-5019
URL: https://issues.apache.org/jira/browse/FLINK-5019
Project: Flink
Stefan Richter created FLINK-4956:
-
Summary: Introduce convenient methods for testing
checkpoint/restore in StreamTaskTestHarness
Key: FLINK-4956
URL: https://issues.apache.org/jira/browse/FLINK-4956
Stefan Richter created FLINK-5291:
-
Summary: Ensure backwards compatibility of the hashes used to
generate JobVertexIds
Key: FLINK-5291
URL: https://issues.apache.org/jira/browse/FLINK-5291
Project:
Stefan Richter created FLINK-5290:
-
Summary: Ensure backwards compatibility of the hashes used to
generate JobVertexIds
Key: FLINK-5290
URL: https://issues.apache.org/jira/browse/FLINK-5290
Project:
Stefan Richter created FLINK-5335:
-
Summary: Allow ListCheckpointed user functions to return null
Key: FLINK-5335
URL: https://issues.apache.org/jira/browse/FLINK-5335
Project: Flink
Issue
Stefan Richter created FLINK-5480:
-
Summary: User-provided hashes for operators
Key: FLINK-5480
URL: https://issues.apache.org/jira/browse/FLINK-5480
Project: Flink
Issue Type: Improvement
Stefan Richter created FLINK-5442:
-
Summary: Add test to fix ordinals of serialized enum
StateDescriptor.Type
Key: FLINK-5442
URL: https://issues.apache.org/jira/browse/FLINK-5442
Project: Flink
Stefan Richter created FLINK-5421:
-
Summary: Explicit restore method in Snapshotable
Key: FLINK-5421
URL: https://issues.apache.org/jira/browse/FLINK-5421
Project: Flink
Issue Type:
Stefan Richter created FLINK-6207:
-
Summary: Duplicate type serializers for async snapshots of
CopyOnWriteStateTable
Key: FLINK-6207
URL: https://issues.apache.org/jira/browse/FLINK-6207
Project:
Stefan Richter created FLINK-5961:
-
Summary: Queryable State is broken for HeapKeyedStateBackend
Key: FLINK-5961
URL: https://issues.apache.org/jira/browse/FLINK-5961
Project: Flink
Issue
Stefan Richter created FLINK-6048:
-
Summary: Asynchronous snapshots for heap-based operator state
backends
Key: FLINK-6048
URL: https://issues.apache.org/jira/browse/FLINK-6048
Project: Flink
Stefan Richter created FLINK-6049:
-
Summary: Parallelize execution of (async) snapshots in
AsyncCheckpointRunnable
Key: FLINK-6049
URL: https://issues.apache.org/jira/browse/FLINK-6049
Project: Flink
Stefan Richter created FLINK-5979:
-
Summary: Backwards compatibility for HeapKeyedStateBackend
serialization format (1.2 -> 1.3)
Key: FLINK-5979
URL: https://issues.apache.org/jira/browse/FLINK-5979
Stefan Richter created FLINK-5958:
-
Summary: Asyncronous snapshots for heap-based keyed state backends
Key: FLINK-5958
URL: https://issues.apache.org/jira/browse/FLINK-5958
Project: Flink
Stefan Richter created FLINK-7460:
-
Summary: Close all ColumnFamilyHandles when restoring rescaled
incremental checkpoints
Key: FLINK-7460
URL: https://issues.apache.org/jira/browse/FLINK-7460
Stefan Richter created FLINK-7461:
-
Summary: Remove Backwards compatibility for Flink 1.1 from Flink
1.4
Key: FLINK-7461
URL: https://issues.apache.org/jira/browse/FLINK-7461
Project: Flink
Stefan Richter created FLINK-7213:
-
Summary: Introduce state management by OperatorID in TaskManager
Key: FLINK-7213
URL: https://issues.apache.org/jira/browse/FLINK-7213
Project: Flink
Stefan Richter created FLINK-7220:
-
Summary: Update RocksDB dependency to 5.5.1
Key: FLINK-7220
URL: https://issues.apache.org/jira/browse/FLINK-7220
Project: Flink
Issue Type: Improvement
Stefan Richter created FLINK-6534:
-
Summary: SharedStateRegistry is disposing state handles from main
thread
Key: FLINK-6534
URL: https://issues.apache.org/jira/browse/FLINK-6534
Project: Flink
Stefan Richter created FLINK-6533:
-
Summary: Duplicated registration of new shared state when
checkpoint confirmations are still pending
Key: FLINK-6533
URL: https://issues.apache.org/jira/browse/FLINK-6533
Stefan Richter created FLINK-6556:
-
Summary: Include and expose Flink version in the savepoint data
Key: FLINK-6556
URL: https://issues.apache.org/jira/browse/FLINK-6556
Project: Flink
Issue
Stefan Richter created FLINK-6535:
-
Summary: JobID should not be part of the registration key to the
SharedStateRegistry
Key: FLINK-6535
URL: https://issues.apache.org/jira/browse/FLINK-6535
Project:
Stefan Richter created FLINK-6545:
-
Summary: Make incremental checkpoints externalizable
Key: FLINK-6545
URL: https://issues.apache.org/jira/browse/FLINK-6545
Project: Flink
Issue Type:
Stefan Richter created FLINK-6537:
-
Summary: Umbrella issue for fixes to incremental snapshots
Key: FLINK-6537
URL: https://issues.apache.org/jira/browse/FLINK-6537
Project: Flink
Issue
Stefan Richter created FLINK-6540:
-
Summary: Create tests that cover all the issues
Key: FLINK-6540
URL: https://issues.apache.org/jira/browse/FLINK-6540
Project: Flink
Issue Type: Sub-task
Stefan Richter created FLINK-6527:
-
Summary: OperatorSubtaskState has empty implementations of
(un)/registerSharedStates
Key: FLINK-6527
URL: https://issues.apache.org/jira/browse/FLINK-6527
Project:
Stefan Richter created FLINK-6506:
-
Summary: Some tests in flink-tests exceed memory the resources in
containerized Travis builds
Key: FLINK-6506
URL: https://issues.apache.org/jira/browse/FLINK-6506
Stefan Richter created FLINK-6505:
-
Summary: Proactively cleanup local FS for RocksDBKeyedStateBackend
on startup
Key: FLINK-6505
URL: https://issues.apache.org/jira/browse/FLINK-6505
Project: Flink
Stefan Richter created FLINK-6507:
-
Summary: Potential bug in ContinuousFileProcessing
Key: FLINK-6507
URL: https://issues.apache.org/jira/browse/FLINK-6507
Project: Flink
Issue Type: Bug
Stefan Richter created FLINK-6964:
-
Summary: Fix recovery for incremental checkpoints in
StandaloneCompletedCheckpointStore
Key: FLINK-6964
URL: https://issues.apache.org/jira/browse/FLINK-6964
Stefan Richter created FLINK-6984:
-
Summary: Do not recover CompletedCheckpointStore on every restore
Key: FLINK-6984
URL: https://issues.apache.org/jira/browse/FLINK-6984
Project: Flink
Stefan Richter created FLINK-6633:
-
Summary: Register with shared state registry before aadding to
CompletedCheckpointStore
Key: FLINK-6633
URL: https://issues.apache.org/jira/browse/FLINK-6633
Stefan Richter created FLINK-6685:
-
Summary: SafetyNetCloseableRegistry is closed prematurely in
Task::triggerCheckpointBarrier
Key: FLINK-6685
URL: https://issues.apache.org/jira/browse/FLINK-6685
Stefan Richter created FLINK-6684:
-
Summary: Remove AsyncCheckpointRunnable from StreamTask
Key: FLINK-6684
URL: https://issues.apache.org/jira/browse/FLINK-6684
Project: Flink
Issue Type:
Stefan Richter created FLINK-6640:
-
Summary: Ensure registration of shared state happens before
externalizing a checkpoint
Key: FLINK-6640
URL: https://issues.apache.org/jira/browse/FLINK-6640
Stefan Richter created FLINK-6761:
-
Summary: Limitation for maximum state size per key in RocksDB
backend
Key: FLINK-6761
URL: https://issues.apache.org/jira/browse/FLINK-6761
Project: Flink
Stefan Richter created FLINK-6766:
-
Summary: Update documentation with async backends and incremental
checkpoints
Key: FLINK-6766
URL: https://issues.apache.org/jira/browse/FLINK-6766
Project: Flink
Stefan Richter created FLINK-6599:
-
Summary: Communicate last committed checkpoint through trigger
checkpoint message
Key: FLINK-6599
URL: https://issues.apache.org/jira/browse/FLINK-6599
Project:
Stefan Richter created FLINK-6773:
-
Summary: Use compression (e.g. snappy) for full check/savepoints
Key: FLINK-6773
URL: https://issues.apache.org/jira/browse/FLINK-6773
Project: Flink
Stefan Richter created FLINK-6776:
-
Summary: Use skip instead of seek for small forward repositioning
in DFS streams
Key: FLINK-6776
URL: https://issues.apache.org/jira/browse/FLINK-6776
Project:
Stefan Richter created FLINK-6931:
-
Summary: Support custom compression formats for checkpoints
(+Upgrade/Compatibility)
Key: FLINK-6931
URL: https://issues.apache.org/jira/browse/FLINK-6931
Project:
Stefan Richter created FLINK-6480:
-
Summary: Add executor service parameter Snapshotable::snapshot(...)
Key: FLINK-6480
URL: https://issues.apache.org/jira/browse/FLINK-6480
Project: Flink
Stefan Richter created FLINK-6481:
-
Summary: Encapsulate different snapshot algorithms (full,
incremental) slightly clearer into strategy pattern
Key: FLINK-6481
URL:
Stefan Richter created FLINK-6484:
-
Summary: Send only the registry keys for already registered files
in incremental checkpointing
Key: FLINK-6484
URL: https://issues.apache.org/jira/browse/FLINK-6484
Stefan Richter created FLINK-6475:
-
Summary: Incremental snapshots in RocksDB hold lock during async
file upload
Key: FLINK-6475
URL: https://issues.apache.org/jira/browse/FLINK-6475
Project: Flink
Stefan Richter created FLINK-6485:
-
Summary: Use buffering to avoid frequent memtable flushes for
short intervals in RockdDB incremental checkpoints
Key: FLINK-6485
URL:
Stefan Richter created FLINK-7619:
-
Summary: Improve abstraction in AbstractAsyncIOCallable to better
fit
Key: FLINK-7619
URL: https://issues.apache.org/jira/browse/FLINK-7619
Project: Flink
Stefan Richter created FLINK-7719:
-
Summary: Send checkpoint id to task as part of deployment
descriptor when resuming
Key: FLINK-7719
URL: https://issues.apache.org/jira/browse/FLINK-7719
Project:
Stefan Richter created FLINK-7757:
-
Summary: RocksDB lock is too strict and can block snapshots in
synchronous phase
Key: FLINK-7757
URL: https://issues.apache.org/jira/browse/FLINK-7757
Project:
Stefan Richter created FLINK-7505:
-
Summary: Use lambdas in suppressed exception idiom
Key: FLINK-7505
URL: https://issues.apache.org/jira/browse/FLINK-7505
Project: Flink
Issue Type:
Stefan Richter created FLINK-8086:
-
Summary: FlinkKafkaProducer011 can permanently fail in recovery
Key: FLINK-8086
URL: https://issues.apache.org/jira/browse/FLINK-8086
Project: Flink
Issue
Stefan Richter created FLINK-9304:
-
Summary: Timer service shutdown should not be interrupted
Key: FLINK-9304
URL: https://issues.apache.org/jira/browse/FLINK-9304
Project: Flink
Issue Type:
Stefan Richter created FLINK-9355:
-
Summary: Simplify configuration of local recovery to a simple
on/off
Key: FLINK-9355
URL: https://issues.apache.org/jira/browse/FLINK-9355
Project: Flink
Stefan Richter created FLINK-9388:
-
Summary: Inconsistency in job shutdown produces confusing log
message
Key: FLINK-9388
URL: https://issues.apache.org/jira/browse/FLINK-9388
Project: Flink
Stefan Richter created FLINK-9390:
-
Summary: Shutdown of KafkaProducer causes confusing log message
Key: FLINK-9390
URL: https://issues.apache.org/jira/browse/FLINK-9390
Project: Flink
Issue
Stefan Richter created FLINK-9375:
-
Summary: Introduce AbortCheckpoint message from JM to TMs
Key: FLINK-9375
URL: https://issues.apache.org/jira/browse/FLINK-9375
Project: Flink
Issue Type:
Stefan Richter created FLINK-9436:
-
Summary: Remove generic parameter namespace from
InternalTimeServiceManager
Key: FLINK-9436
URL: https://issues.apache.org/jira/browse/FLINK-9436
Project: Flink
Stefan Richter created FLINK-9485:
-
Summary: Improving Flink’s timer management for large state
Key: FLINK-9485
URL: https://issues.apache.org/jira/browse/FLINK-9485
Project: Flink
Issue
Stefan Richter created FLINK-9486:
-
Summary: Introduce TimerState in keyed state backend
Key: FLINK-9486
URL: https://issues.apache.org/jira/browse/FLINK-9486
Project: Flink
Issue Type:
Stefan Richter created FLINK-9487:
-
Summary: Prepare InternalTimerHeap for asynchronous snapshots
Key: FLINK-9487
URL: https://issues.apache.org/jira/browse/FLINK-9487
Project: Flink
Issue
Stefan Richter created FLINK-9489:
-
Summary: Checkpoint timers as part of managed keyed state instead
of raw keyed state
Key: FLINK-9489
URL: https://issues.apache.org/jira/browse/FLINK-9489
Project:
Stefan Richter created FLINK-9490:
-
Summary: Provide backwards compatibility for timer state of Flink
1.5
Key: FLINK-9490
URL: https://issues.apache.org/jira/browse/FLINK-9490
Project: Flink
Stefan Richter created FLINK-9702:
-
Summary: Improvement in (de)serialization of keys and values for
RocksDB state
Key: FLINK-9702
URL: https://issues.apache.org/jira/browse/FLINK-9702
Project: Flink
Stefan Richter created FLINK-8385:
-
Summary: Fix exceptions in
AbstractEventTimeWindowCheckpointingITCase
Key: FLINK-8385
URL: https://issues.apache.org/jira/browse/FLINK-8385
Project: Flink
Stefan Richter created FLINK-8360:
-
Summary: Implement task-local state recovery
Key: FLINK-8360
URL: https://issues.apache.org/jira/browse/FLINK-8360
Project: Flink
Issue Type: New Feature
Stefan Richter created FLINK-10040:
--
Summary: Decompose RocksDBKeyedStateBackend
Key: FLINK-10040
URL: https://issues.apache.org/jira/browse/FLINK-10040
Project: Flink
Issue Type:
1 - 100 of 195 matches
Mail list logo