[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:11 PM: I think

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:13 PM: I think

[jira] [Commented] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331982#comment-15331982 ] Stefan Richter commented on FLINK-4037: --- I think introducing an {{ArchivedExecutionGraph}} to

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:12 PM: I think

[jira] [Comment Edited] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331982#comment-15331982 ] Stefan Richter edited comment on FLINK-4037 at 6/15/16 4:14 PM: I think

[jira] [Updated] (FLINK-4037) Introduce ArchivedExecutionGraph without any user classes

[ https://issues.apache.org/jira/browse/FLINK-4037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4037: -- Assignee: (was: Stefan Richter) > Introduce ArchivedExecutionGraph without any user classes

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

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] [Issue Comment Deleted] (FLINK-4083) Use ClosureCleaner for Join where and equalTo

[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Comment: was deleted (was: Same problem.) > Use ClosureCleaner for Join where and equalTo >

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

[ https://issues.apache.org/jira/browse/FLINK-4083?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4083: -- Description: When specifying a key selector in the where or equalTo clause of a Join, the

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

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] [Comment Edited] (FLINK-4374) GroupReduce Broken for null Date

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417162#comment-15417162 ] Stefan Richter edited comment on FLINK-4374 at 8/11/16 12:52 PM: - Yes, it

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

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15417162#comment-15417162 ] Stefan Richter commented on FLINK-4374: --- Yes, it is the data field of the Tuple2 in

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

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4374: - Assignee: Timo Walther > GroupReduce Broken for null Date >

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

[ https://issues.apache.org/jira/browse/FLINK-4374?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4374: -- Description: The GroupReduceITCase has an error that allows a problem with {{null}} Dates to

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

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-4230) Session Windowing IT Case

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

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] [Updated] (FLINK-4150) Problem with Blobstore in Yarn HA setting on recovery after cluster shutdown

[ https://issues.apache.org/jira/browse/FLINK-4150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4150: -- Description: Submitting a job in Yarn with HA can lead to the following exception: {code}

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

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] [Commented] (FLINK-4211) Dynamic Properties not working for jobs submitted to Yarn session

[ https://issues.apache.org/jira/browse/FLINK-4211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15378999#comment-15378999 ] Stefan Richter commented on FLINK-4211: --- I see. I think unfortunately this is not really clear the

[jira] [Created] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures.

Stefan Richter created FLINK-4182: - Summary: HA recovery not working properly under ApplicationMaster failures. Key: FLINK-4182 URL: https://issues.apache.org/jira/browse/FLINK-4182 Project: Flink

[jira] [Updated] (FLINK-4182) HA recovery not working properly under ApplicationMaster failures.

[ https://issues.apache.org/jira/browse/FLINK-4182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4182: -- Description: When randomly killing TaskManager and ApplicationMaster, a job sometimes does not

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

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

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

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] [Commented] (FLINK-3623) Adjust MurmurHash algorithm

[ https://issues.apache.org/jira/browse/FLINK-3623?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15414110#comment-15414110 ] Stefan Richter commented on FLINK-3623: --- In my opinion, our implementation of Murmur might be too

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

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] [Assigned] (FLINK-4134) EventTimeSessionWindows trigger for empty windows when dropping late events

[ https://issues.apache.org/jira/browse/FLINK-4134?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4134: - Assignee: Stefan Richter > EventTimeSessionWindows trigger for empty windows when

[jira] [Assigned] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint

[ https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4140: - Assignee: Stefan Richter > CheckpointCoordinator fails to discard completed checkpoint >

[jira] [Updated] (FLINK-4140) CheckpointCoordinator fails to discard completed checkpoint

[ https://issues.apache.org/jira/browse/FLINK-4140?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4140: -- Assignee: Ufuk Celebi (was: Stefan Richter) > CheckpointCoordinator fails to discard completed

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

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-4140) CheckpointCoordinator fails to discard completed checkpoint

Stefan Richter created FLINK-4140: - Summary: CheckpointCoordinator fails to discard completed checkpoint Key: FLINK-4140 URL: https://issues.apache.org/jira/browse/FLINK-4140 Project: Flink

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

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] [Updated] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4142: -- Summary: Recovery problem in HA on Hadoop Yarn 2.4.1 (was: Recovery problem in HA on Hadoop

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

[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4142: -- Description: On Hadoop Yarn 2.4.1, recovery in HA fails in the following scenario: 1) Kill

[jira] [Commented] (FLINK-4142) Recovery problem in HA on Hadoop Yarn 2.4.1

[ https://issues.apache.org/jira/browse/FLINK-4142?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15359073#comment-15359073 ] Stefan Richter commented on FLINK-4142: --- I have a log for the problem here:

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

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] [Updated] (FLINK-5730) Users can concurrently modify state metadata of RocksDB asynchronous snapshots

[ https://issues.apache.org/jira/browse/FLINK-5730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5730: -- Summary: Users can concurrently modify state metadata of RocksDB asynchronous snapshots (was:

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

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

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] [Commented] (FLINK-5436) UDF state without CheckpointedRestoring can result in restarting loop

[ https://issues.apache.org/jira/browse/FLINK-5436?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15834292#comment-15834292 ] Stefan Richter commented on FLINK-5436: --- I think that would be good to have in. > UDF state without

[jira] [Commented] (FLINK-5663) Checkpoint fails because of closed registry

[ https://issues.apache.org/jira/browse/FLINK-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840070#comment-15840070 ] Stefan Richter commented on FLINK-5663: --- Then again, question is if this task already ended and for

[jira] [Commented] (FLINK-5663) Checkpoint fails because of closed registry

[ https://issues.apache.org/jira/browse/FLINK-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840068#comment-15840068 ] Stefan Richter commented on FLINK-5663: --- I don't think this is a race condition. This exception only

[jira] [Commented] (FLINK-5663) Checkpoint fails because of closed registry

[ https://issues.apache.org/jira/browse/FLINK-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15840101#comment-15840101 ] Stefan Richter commented on FLINK-5663: --- The only place this registry ever gets closed is through

[jira] [Assigned] (FLINK-5663) Checkpoint fails because of closed registry

[ https://issues.apache.org/jira/browse/FLINK-5663?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-5663: - Assignee: Stefan Richter > Checkpoint fails because of closed registry >

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

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] (FLINK-5044) Converting operator and function state from Flink 1.1 for all changed operators in 1.2

Title: Message Title Stefan Richter commented on FLINK-5044

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

Title: Message Title Stefan Richter commented on FLINK-5480

[jira] [Commented] (FLINK-5740) Make WrappingFunction an interface and move to flink-core

[ https://issues.apache.org/jira/browse/FLINK-5740?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15859254#comment-15859254 ] Stefan Richter commented on FLINK-5740: --- +1 very good idea. > Make WrappingFunction an interface

[jira] [Commented] (FLINK-1725) New Partitioner for better load balancing for skewed data

[ https://issues.apache.org/jira/browse/FLINK-1725?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871572#comment-15871572 ] Stefan Richter commented on FLINK-1725: --- I agree with you [~aljoscha]. While this would be nice to

[jira] [Closed] (FLINK-3841) RocksDB statebackend creates empty dbs for stateless operators

[ https://issues.apache.org/jira/browse/FLINK-3841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-3841. - Resolution: Not A Problem Fix Version/s: 1.2.0 Not a problem any more. Will close this

[jira] [Commented] (FLINK-2491) Operators are not participating in state checkpointing in some cases

[ https://issues.apache.org/jira/browse/FLINK-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871538#comment-15871538 ] Stefan Richter commented on FLINK-2491: --- This seems still valid, but I assume it is not in progress

[jira] [Commented] (FLINK-5932) Order of legacy vs new state initialization in the AbstractStreamOperator.

[ https://issues.apache.org/jira/browse/FLINK-5932?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891930#comment-15891930 ] Stefan Richter commented on FLINK-5932: --- I think it makes a lot of sense if it is easily possible.

[jira] [Commented] (FLINK-5917) Remove MapState.size()

[ https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891945#comment-15891945 ] Stefan Richter commented on FLINK-5917: --- I agree with [~aljoscha]. Unlike Java's HashMap, RocksDB

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

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-4492) Cleanup files from canceled snapshots

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-4744) Introduce usercode class loader to deserialize partitionable operator state

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] [Updated] (FLINK-4731) HeapKeyedStateBackend restoring broken for scale-in

[ https://issues.apache.org/jira/browse/FLINK-4731?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4731: -- Summary: HeapKeyedStateBackend restoring broken for scale-in (was: HeapKeyedStateBackend

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

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

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] [Updated] (FLINK-4730) Introduce CheckpointMetaData

[ https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4730: -- Component/s: State Backends, Checkpointing > Introduce CheckpointMetaData >

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

[ https://issues.apache.org/jira/browse/FLINK-4730?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4730: - Assignee: Stefan Richter > Introduce CheckpointMetaData > >

[jira] [Commented] (FLINK-4603) KeyedStateBackend cannot restore user code classes

[ https://issues.apache.org/jira/browse/FLINK-4603?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15512553#comment-15512553 ] Stefan Richter commented on FLINK-4603: --- Currently, we should still keep the UserCodeClassLoader

[jira] [Assigned] (FLINK-4556) Make Queryable State Key-Group Aware

[ https://issues.apache.org/jira/browse/FLINK-4556?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4556: - Assignee: Stefan Richter > Make Queryable State Key-Group Aware >

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

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-4942) Improve processing performance of HeapInternalTimerService with key groups

Stefan Richter created FLINK-4942: - Summary: Improve processing performance of HeapInternalTimerService with key groups Key: FLINK-4942 URL: https://issues.apache.org/jira/browse/FLINK-4942 Project:

[jira] [Assigned] (FLINK-4942) Improve processing performance of HeapInternalTimerService with key groups

[ https://issues.apache.org/jira/browse/FLINK-4942?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4942: - Assignee: Stefan Richter > Improve processing performance of HeapInternalTimerService

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

[ https://issues.apache.org/jira/browse/FLINK-5019?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5019. - Resolution: Fixed Fix Version/s: 1.2.0 > Proper isRestored result for tasks that did not

[jira] [Commented] (FLINK-5036) Perform the grouping of keys in restoring instead of checkpointing

[ https://issues.apache.org/jira/browse/FLINK-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650460#comment-15650460 ] Stefan Richter commented on FLINK-5036: --- >From the description it is not entirely clear if you are

[jira] [Closed] (FLINK-5037) Instability in AbstractUdfStreamOperatorLifecycleTest

[ https://issues.apache.org/jira/browse/FLINK-5037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-5037. - Resolution: Fixed Fix Version/s: 1.2.0 > Instability in

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

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

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

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

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

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

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

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] [Updated] (FLINK-4858) Remove Legacy Checkpointing Interfaces

[ https://issues.apache.org/jira/browse/FLINK-4858?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4858: -- Description: This issue tracks the removal of the deprecated/legacy interfaces that are still

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

[ https://issues.apache.org/jira/browse/FLINK-4492?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15575225#comment-15575225 ] Stefan Richter commented on FLINK-4492: --- I did not add any cleanup on cancel in the changes I did,

[jira] [Commented] (FLINK-4867) Investigate code generation for improving sort performance

[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592292#comment-15592292 ] Stefan Richter commented on FLINK-4867: --- If you sort performance is crucial to you, I wrote some

[jira] [Comment Edited] (FLINK-4867) Investigate code generation for improving sort performance

[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592292#comment-15592292 ] Stefan Richter edited comment on FLINK-4867 at 10/20/16 4:32 PM: - If sort

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15601278#comment-15601278 ] Stefan Richter commented on FLINK-4883: --- Ok, thanks! I will assign you to this. > Prevent UDFs

[jira] [Created] (FLINK-4843) Introduce Test for FsCheckpointStateOutputStream::getPos

Stefan Richter created FLINK-4843: - Summary: Introduce Test for FsCheckpointStateOutputStream::getPos Key: FLINK-4843 URL: https://issues.apache.org/jira/browse/FLINK-4843 Project: Flink

[jira] [Created] (FLINK-4842) Introduce test to enforce order of operator / udf lifecycles

Stefan Richter created FLINK-4842: - Summary: Introduce test to enforce order of operator / udf lifecycles Key: FLINK-4842 URL: https://issues.apache.org/jira/browse/FLINK-4842 Project: Flink

[jira] [Commented] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15604566#comment-15604566 ] Stefan Richter commented on FLINK-4883: --- Sure, here is the example from the mailing list: {code}

[jira] [Assigned] (FLINK-4910) Introduce safety net for closing file system streams

[ https://issues.apache.org/jira/browse/FLINK-4910?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter reassigned FLINK-4910: - Assignee: Stefan Richter > Introduce safety net for closing file system streams >

[jira] [Created] (FLINK-4910) Introduce safety net for closing file system streams

Stefan Richter created FLINK-4910: - Summary: Introduce safety net for closing file system streams Key: FLINK-4910 URL: https://issues.apache.org/jira/browse/FLINK-4910 Project: Flink Issue

[jira] [Updated] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

[ https://issues.apache.org/jira/browse/FLINK-4883?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-4883: -- Assignee: Renkai Ge > Prevent UDFs implementations through Scala singleton objects >

[jira] [Commented] (FLINK-4867) Investigate code generation for improving sort performance

[ https://issues.apache.org/jira/browse/FLINK-4867?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15592866#comment-15592866 ] Stefan Richter commented on FLINK-4867: --- I have already pushed my code into

[jira] [Closed] (FLINK-4842) Introduce test to enforce order of operator / udf lifecycles

[ https://issues.apache.org/jira/browse/FLINK-4842?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-4842. - Resolution: Implemented Fix Version/s: 1.2.0 > Introduce test to enforce order of operator

[jira] [Closed] (FLINK-4844) Partitionable Raw Keyed/Operator State

[ https://issues.apache.org/jira/browse/FLINK-4844?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter closed FLINK-4844. - Resolution: Implemented Fix Version/s: 1.2.0 > Partitionable Raw Keyed/Operator State >

[jira] [Created] (FLINK-4883) Prevent UDFs implementations through Scala singleton objects

Stefan Richter created FLINK-4883: - Summary: Prevent UDFs implementations through Scala singleton objects Key: FLINK-4883 URL: https://issues.apache.org/jira/browse/FLINK-4883 Project: Flink

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

[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663198#comment-15663198 ] Stefan Richter commented on FLINK-5053: --- That might very well be, I am still planning to take closer

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

[ https://issues.apache.org/jira/browse/FLINK-5146?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5146: -- Priority: Blocker (was: Major) > Improved resource cleanup in RocksDB keyed state backend >

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

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] [Commented] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

[ https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15692874#comment-15692874 ] Stefan Richter commented on FLINK-5024: --- Independently of this, I also talked with Aljoscha about

[jira] [Commented] (FLINK-4100) RocksDBStateBackend#close() can throw NPE

[ https://issues.apache.org/jira/browse/FLINK-4100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15701566#comment-15701566 ] Stefan Richter commented on FLINK-4100: --- Yes, this looks very outdated. >

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

[ https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stefan Richter updated FLINK-5053: -- Description: There is currently basically no difference between savepoints and checkpoints in

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

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

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

  1   2   3   4   5   6   7   8   9   10   >