[jira] [Created] (FLINK-12285) Memory leak in SavepointITCase and SavepointMigrationTestBase

2019-04-21 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-12285: Summary: Memory leak in SavepointITCase and SavepointMigrationTestBase Key: FLINK-12285 URL: https://issues.apache.org/jira/browse/FLINK-12285 Project: Flink

[jira] [Created] (FLINK-12284) InputBufferPoolUsage is incorrect in credit-based network control flow

2019-04-21 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-12284: Summary: InputBufferPoolUsage is incorrect in credit-based network control flow Key: FLINK-12284 URL: https://issues.apache.org/jira/browse/FLINK-12284 Project: Flink

[jira] [Created] (FLINK-6364) Implement incremental checkpointing in RocksDBStateBackend

2017-04-23 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6364: --- Summary: Implement incremental checkpointing in RocksDBStateBackend Key: FLINK-6364 URL: https://issues.apache.org/jira/browse/FLINK-6364 Project: Flink Issue

[jira] [Created] (FLINK-6284) Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore

2017-04-09 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6284: --- Summary: Incorrect sorting of completed checkpoints in ZooKeeperCompletedCheckpointStore Key: FLINK-6284 URL: https://issues.apache.org/jira/browse/FLINK-6284 Project:

[jira] [Created] (FLINK-6096) Refactor the migration of old versioned savepoints

2017-03-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6096: --- Summary: Refactor the migration of old versioned savepoints Key: FLINK-6096 URL: https://issues.apache.org/jira/browse/FLINK-6096 Project: Flink Issue Type: Im

[jira] [Created] (FLINK-6034) Add KeyedStateHandle for the snapshots in keyed streams

2017-03-13 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6034: --- Summary: Add KeyedStateHandle for the snapshots in keyed streams Key: FLINK-6034 URL: https://issues.apache.org/jira/browse/FLINK-6034 Project: Flink Issue Typ

[jira] [Created] (FLINK-6027) Ignore the exception thrown by the subsuming of old completed checkpoints

2017-03-13 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6027: --- Summary: Ignore the exception thrown by the subsuming of old completed checkpoints Key: FLINK-6027 URL: https://issues.apache.org/jira/browse/FLINK-6027 Project: Flink

[jira] [Created] (FLINK-6014) Allow the registration of state objects in checkpoints

2017-03-09 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-6014: --- Summary: Allow the registration of state objects in checkpoints Key: FLINK-6014 URL: https://issues.apache.org/jira/browse/FLINK-6014 Project: Flink Issue Type

[jira] [Created] (FLINK-5865) Throw original exception in RocksDB states

2017-02-21 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5865: --- Summary: Throw original exception in RocksDB states Key: FLINK-5865 URL: https://issues.apache.org/jira/browse/FLINK-5865 Project: Flink Issue Type: Improvemen

[jira] [Created] (FLINK-5863) Unify the serialization of queryable list states in different backends

2017-02-21 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5863: --- Summary: Unify the serialization of queryable list states in different backends Key: FLINK-5863 URL: https://issues.apache.org/jira/browse/FLINK-5863 Project: Flink

[jira] [Created] (FLINK-5790) Use list types when ListStateDescriptor extends StateDescriptor

2017-02-13 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5790: --- Summary: Use list types when ListStateDescriptor extends StateDescriptor Key: FLINK-5790 URL: https://issues.apache.org/jira/browse/FLINK-5790 Project: Flink

[jira] [Created] (FLINK-5738) Destroy created backend when task is canceled

2017-02-07 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5738: --- Summary: Destroy created backend when task is canceled Key: FLINK-5738 URL: https://issues.apache.org/jira/browse/FLINK-5738 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5544) Implement Internal Timer Service in RocksDB

2017-01-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5544: --- Summary: Implement Internal Timer Service in RocksDB Key: FLINK-5544 URL: https://issues.apache.org/jira/browse/FLINK-5544 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5400) Add accessor to folding states in RuntimeContext

2016-12-29 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5400: --- Summary: Add accessor to folding states in RuntimeContext Key: FLINK-5400 URL: https://issues.apache.org/jira/browse/FLINK-5400 Project: Flink Issue Type: Bug

[jira] [Created] (FLINK-5398) Exclude generated files in module flink-batch-connectors in license checking

2016-12-28 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5398: --- Summary: Exclude generated files in module flink-batch-connectors in license checking Key: FLINK-5398 URL: https://issues.apache.org/jira/browse/FLINK-5398 Project: Fli

[jira] [Created] (FLINK-5397) Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors

2016-12-28 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5397: --- Summary: Fail to deserialize savepoints in v1.1 when there exist missing fields in class serialization descriptors Key: FLINK-5397 URL: https://issues.apache.org/jira/browse/FLINK-5

[jira] [Created] (FLINK-5086) Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints

2016-11-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5086: --- Summary: Clean dead snapshot files produced by the tasks failing to acknowledge checkpoints Key: FLINK-5086 URL: https://issues.apache.org/jira/browse/FLINK-5086 Projec

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

2016-11-08 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5036: --- Summary: Perform the grouping of keys in restoring instead of checkpointing Key: FLINK-5036 URL: https://issues.apache.org/jira/browse/FLINK-5036 Project: Flink

[jira] [Created] (FLINK-5024) Add SimpleStateDescriptor to clarify the concepts

2016-11-06 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5024: --- Summary: Add SimpleStateDescriptor to clarify the concepts Key: FLINK-5024 URL: https://issues.apache.org/jira/browse/FLINK-5024 Project: Flink Issue Type: Imp

[jira] [Created] (FLINK-5023) Add get() method in State interface

2016-11-06 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-5023: --- Summary: Add get() method in State interface Key: FLINK-5023 URL: https://issues.apache.org/jira/browse/FLINK-5023 Project: Flink Issue Type: Improvement

[jira] [Created] (FLINK-4856) Add MapState for keyed streams

2016-10-18 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4856: --- Summary: Add MapState for keyed streams Key: FLINK-4856 URL: https://issues.apache.org/jira/browse/FLINK-4856 Project: Flink Issue Type: New Feature

[jira] [Created] (FLINK-4448) Use Listeners to monitor execution status

2016-08-22 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4448: --- Summary: Use Listeners to monitor execution status Key: FLINK-4448 URL: https://issues.apache.org/jira/browse/FLINK-4448 Project: Flink Issue Type: Sub-task

[jira] [Created] (FLINK-4408) JobSubmission

2016-08-17 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4408: --- Summary: JobSubmission Key: FLINK-4408 URL: https://issues.apache.org/jira/browse/FLINK-4408 Project: Flink Issue Type: Sub-task Components: Cluster

[jira] [Created] (FLINK-4400) Leadership Election among JobManagers

2016-08-15 Thread Xiaogang Shi (JIRA)
Xiaogang Shi created FLINK-4400: --- Summary: Leadership Election among JobManagers Key: FLINK-4400 URL: https://issues.apache.org/jira/browse/FLINK-4400 Project: Flink Issue Type: Sub-task