[jira] [Created] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

2016-06-16 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4374) GroupReduce Broken for null Date

2016-08-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4230) Session Windowing IT Case

2016-07-18 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4201) Checkpoints for jobs in non-terminal state (e.g. suspended) get deleted

2016-07-12 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4200) Kafka consumers should log the offset from which they restore

2016-07-12 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session

2016-07-13 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4166) Generate automatic different namespaces in Zookeeper for Flink applications

2016-07-07 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown

2016-07-04 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4156) Job with -m yarn-cluster registers TaskManagers to another running Yarn session

2016-07-06 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events

2016-06-30 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4141) TaskManager failures not always recover when killed during an ApplicationMaster failure in HA mode on Yarn

2016-07-01 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.5.0

2016-07-01 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5730) User can concurrently modify state metadata of RocksDB asynchronous snapshots

2017-02-07 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5715) Asynchronous snapshotting for HeapKeyedStateBackend

2017-02-06 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5707) Find better keys for backend configuration parameters

2017-02-03 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5681) Make ReaperThread for SafetyNetCloseableRegistry a singleton

2017-01-27 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4492) Cleanup files from canceled snapshots

2016-08-25 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4493) Unify the snapshot output format for keyed-state backends

2016-08-25 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4744) Introduce usercode class loader to deserialize partitionable operator state

2016-10-05 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-4730) Introduce CheckpointMetaData

2016-10-04 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4731) HeapKeyedStateBackend restorig broken for scale-in

2016-10-04 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4508) Consolidate DummyEnvironment and MockEnvironment for Tests

2016-08-26 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5041) Implement savepoint backwards compatibility 1.1 -> 1.2

2016-11-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5043) Converting keyed state from Flink 1.1 backend implementations to their new counterparts in 1.2

2016-11-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5042) Convert old savepoints to new savepoints

2016-11-09 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

2016-11-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5051) Backwards compatibility for serializers in backend state

2016-11-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5052) Changing the maximum parallelism (number of key groups) of a job

2016-11-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5053) Incremental / lightweight snapshots for checkpoints

2016-11-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5146) Improved resource cleanup in RocksDB keyed state backend

2016-11-23 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5099) Test testCancelPartitionRequest is instable

2016-11-18 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5100) Test testZooKeeperReelection is instable

2016-11-18 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5101) Test CassandraConnectorITCase instable

2016-11-18 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5107) Job Manager goes out of memory from long history of prior execution attempts

2016-11-21 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5019) Proper isRestored result for tasks that did not write state

2016-11-04 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-4956) Introduce convenient methods for testing checkpoint/restore in StreamTaskTestHarness

2016-10-28 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5291) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-5290) Ensure backwards compatibility of the hashes used to generate JobVertexIds

2016-12-08 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-5335) Allow ListCheckpointed user functions to return null

2016-12-14 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5480) User-provided hashes for operators

2017-01-13 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5442) Add test to fix ordinals of serialized enum StateDescriptor.Type

2017-01-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5421) Explicit restore method in Snapshotable

2017-01-06 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6207) Duplicate type serializers for async snapshots of CopyOnWriteStateTable

2017-03-28 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-5961) Queryable State is broken for HeapKeyedStateBackend

2017-03-03 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6048) Asynchronous snapshots for heap-based operator state backends

2017-03-14 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6049) Parallelize execution of (async) snapshots in AsyncCheckpointRunnable

2017-03-14 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5979) Backwards compatibility for HeapKeyedStateBackend serialization format (1.2 -> 1.3)

2017-03-07 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-5958) Asyncronous snapshots for heap-based keyed state backends

2017-03-03 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-7460) Close all ColumnFamilyHandles when restoring rescaled incremental checkpoints

2017-08-16 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-7461) Remove Backwards compatibility for Flink 1.1 from Flink 1.4

2017-08-16 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-7213) Introduce state management by OperatorID in TaskManager

2017-07-17 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-7220) Update RocksDB dependency to 5.5.1

2017-07-18 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6534) SharedStateRegistry is disposing state handles from main thread

2017-05-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6533) Duplicated registration of new shared state when checkpoint confirmations are still pending

2017-05-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6556) Include and expose Flink version in the savepoint data

2017-05-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6535) JobID should not be part of the registration key to the SharedStateRegistry

2017-05-11 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6545) Make incremental checkpoints externalizable

2017-05-11 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6537) Umbrella issue for fixes to incremental snapshots

2017-05-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6540) Create tests that cover all the issues

2017-05-11 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6527) OperatorSubtaskState has empty implementations of (un)/registerSharedStates

2017-05-10 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6506) Some tests in flink-tests exceed memory the resources in containerized Travis builds

2017-05-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6505) Proactively cleanup local FS for RocksDBKeyedStateBackend on startup

2017-05-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6507) Potential bug in ContinuousFileProcessing

2017-05-09 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6964) Fix recovery for incremental checkpoints in StandaloneCompletedCheckpointStore

2017-06-21 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6984) Do not recover CompletedCheckpointStore on every restore

2017-06-22 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6633) Register with shared state registry before aadding to CompletedCheckpointStore

2017-05-19 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6685) SafetyNetCloseableRegistry is closed prematurely in Task::triggerCheckpointBarrier

2017-05-23 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6684) Remove AsyncCheckpointRunnable from StreamTask

2017-05-23 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6640) Ensure registration of shared state happens before externalizing a checkpoint

2017-05-19 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6761) Limitation for maximum state size per key in RocksDB backend

2017-05-29 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6766) Update documentation with async backends and incremental checkpoints

2017-05-29 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6599) Communicate last committed checkpoint through trigger checkpoint message

2017-05-16 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6773) Use compression (e.g. snappy) for full check/savepoints

2017-05-30 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6776) Use skip instead of seek for small forward repositioning in DFS streams

2017-05-30 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6931) Support custom compression formats for checkpoints (+Upgrade/Compatibility)

2017-06-15 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-6480) Add executor service parameter Snapshotable::snapshot(...)

2017-05-08 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6481) Encapsulate different snapshot algorithms (full, incremental) slightly clearer into strategy pattern

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6481: - Summary: Encapsulate different snapshot algorithms (full, incremental) slightly clearer into strategy pattern Key: FLINK-6481 URL:

[jira] [Created] (FLINK-6484) Send only the registry keys for already registered files in incremental checkpointing

2017-05-08 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6475) Incremental snapshots in RocksDB hold lock during async file upload

2017-05-07 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-6485) Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints

2017-05-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-6485: - Summary: Use buffering to avoid frequent memtable flushes for short intervals in RockdDB incremental checkpoints Key: FLINK-6485 URL:

[jira] [Created] (FLINK-7619) Improve abstraction in AbstractAsyncIOCallable to better fit

2017-09-14 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-7719) Send checkpoint id to task as part of deployment descriptor when resuming

2017-09-27 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-7757) RocksDB lock is too strict and can block snapshots in synchronous phase

2017-10-03 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-7505) Use lambdas in suppressed exception idiom

2017-08-24 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-8086) FlinkKafkaProducer011 can permanently fail in recovery

2017-11-15 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9304) Timer service shutdown should not be interrupted

2018-05-07 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-9355) Simplify configuration of local recovery to a simple on/off

2018-05-14 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9388) Inconsistency in job shutdown produces confusing log message

2018-05-17 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9390) Shutdown of KafkaProducer causes confusing log message

2018-05-17 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9375) Introduce AbortCheckpoint message from JM to TMs

2018-05-16 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-9436) Remove generic parameter namespace from InternalTimeServiceManager

2018-05-25 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9485) Improving Flink’s timer management for large state

2018-06-01 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9486) Introduce TimerState in keyed state backend

2018-06-01 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-9487) Prepare InternalTimerHeap for asynchronous snapshots

2018-06-01 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9489) Checkpoint timers as part of managed keyed state instead of raw keyed state

2018-06-01 Thread Stefan Richter (JIRA)
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:

[jira] [Created] (FLINK-9490) Provide backwards compatibility for timer state of Flink 1.5

2018-06-01 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-9702) Improvement in (de)serialization of keys and values for RocksDB state

2018-07-02 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-8385) Fix exceptions in AbstractEventTimeWindowCheckpointingITCase

2018-01-08 Thread Stefan Richter (JIRA)
Stefan Richter created FLINK-8385: - Summary: Fix exceptions in AbstractEventTimeWindowCheckpointingITCase Key: FLINK-8385 URL: https://issues.apache.org/jira/browse/FLINK-8385 Project: Flink

[jira] [Created] (FLINK-8360) Implement task-local state recovery

2018-01-04 Thread Stefan Richter (JIRA)
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

[jira] [Created] (FLINK-10040) Decompose RocksDBKeyedStateBackend

2018-08-03 Thread Stefan Richter (JIRA)
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   2   >