[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916617#comment-16916617
]
Xiaogang Shi commented on FLINK-13848:
--
[~SleePy] Sorry that I misunderstand your second question.
[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16916607#comment-16916607
]
Xiaogang Shi commented on FLINK-13848:
--
1. Yes. If the task message is already sent to the actor's
[
https://issues.apache.org/jira/browse/FLINK-13848?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16915689#comment-16915689
]
Xiaogang Shi commented on FLINK-13848:
--
Hi [~SleePy], what's your detailed plan on implementing
[
https://issues.apache.org/jira/browse/FLINK-13732?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16907856#comment-16907856
]
Xiaogang Shi commented on FLINK-13732:
--
[~SleePy] Thanks for bringing up this issue.
We are also
[
https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-12887:
Assignee: TisonKun (was: Xiaogang Shi)
> Schedule UnfencedMessage would lost envelope
[
https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-12887:
Assignee: Xiaogang Shi
> Schedule UnfencedMessage would lost envelope info
>
[
https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16883233#comment-16883233
]
Xiaogang Shi commented on FLINK-12887:
--
As described in my first comment, we are using
[
https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869118#comment-16869118
]
Xiaogang Shi commented on FLINK-12887:
--
[~till.rohrmann] I am also very curious on the method we
[
https://issues.apache.org/jira/browse/FLINK-12887?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16869086#comment-16869086
]
Xiaogang Shi commented on FLINK-12887:
--
Hi [~till.rohrmann], now we are using many unfenced
[
https://issues.apache.org/jira/browse/FLINK-12865?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16866148#comment-16866148
]
Xiaogang Shi commented on FLINK-12865:
--
[~till.rohrmann]You are right that there is no problem with
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865269#comment-16865269
]
Xiaogang Shi commented on FLINK-12863:
--
Btw, i want to note that the race condition may not
[
https://issues.apache.org/jira/browse/FLINK-12863?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16865239#comment-16865239
]
Xiaogang Shi commented on FLINK-12863:
--
I think a similar problem happens in the heartbeats between
[
https://issues.apache.org/jira/browse/FLINK-12761?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16857448#comment-16857448
]
Xiaogang Shi commented on FLINK-12761:
--
I think it's a good idea to enable fine-grained resource
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
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:
[
https://issues.apache.org/jira/browse/FLINK-10052?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16816118#comment-16816118
]
Xiaogang Shi commented on FLINK-10052:
--
What's the status of the issue? [~Wosinsan]
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16702604#comment-16702604
]
Xiaogang Shi commented on FLINK-10333:
--
I think so. We can wrap all the access to ZK in the
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701821#comment-16701821
]
Xiaogang Shi commented on FLINK-10333:
--
hi [~StephanEwen], I think the key point to achieve
[
https://issues.apache.org/jira/browse/FLINK-10333?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16701495#comment-16701495
]
Xiaogang Shi commented on FLINK-10333:
--
Hi [~till.rohrmann] Our cluster is suffering from unstable
[
https://issues.apache.org/jira/browse/FLINK-10714?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16668009#comment-16668009
]
Xiaogang Shi commented on FLINK-10714:
--
[~cmick] I came across a similar problem before. It seems
[
https://issues.apache.org/jira/browse/FLINK-6557?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16009910#comment-16009910
]
Xiaogang Shi commented on FLINK-6557:
-
[~Zentol] Thanks a lot for pointing it out. As far as i know,
[
https://issues.apache.org/jira/browse/FLINK-6545?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007785#comment-16007785
]
Xiaogang Shi commented on FLINK-6545:
-
I prefer not to use `SavepointSerializer` to
[
https://issues.apache.org/jira/browse/FLINK-6467?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002329#comment-16002329
]
Xiaogang Shi commented on FLINK-6467:
-
[~te...@apache.org] Thanks for pointing out this problem. It's
[
https://issues.apache.org/jira/browse/FLINK-6504?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-6504:
---
Assignee: Xiaogang Shi
> Lack of synchronization on materializedSstFiles in
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
[
https://issues.apache.org/jira/browse/FLINK-6014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-6014.
---
Resolution: Fixed
Fixed via 218bed8b8e49b0e4c61c61f696a8f010eafea1b7 and
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:
[
https://issues.apache.org/jira/browse/FLINK-3089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15962347#comment-15962347
]
Xiaogang Shi commented on FLINK-3089:
-
[~aljoscha] In current implementation, each RocksDB timer is
[
https://issues.apache.org/jira/browse/FLINK-6219?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15950388#comment-15950388
]
Xiaogang Shi commented on FLINK-6219:
-
I prefer to use sorted states (e.g., {{SortedMapState}}) rather
[
https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944776#comment-15944776
]
Xiaogang Shi commented on FLINK-6178:
-
[~tzulitai] Thanks a lot for your quick response. The changes
[
https://issues.apache.org/jira/browse/FLINK-6178?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15944743#comment-15944743
]
Xiaogang Shi commented on FLINK-6178:
-
The idea that allowing the upgrades to state serializers is
[
https://issues.apache.org/jira/browse/FLINK-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-6096:
---
Assignee: Xiaogang Shi
> Refactor the migration of old versioned savepoints
>
[
https://issues.apache.org/jira/browse/FLINK-6096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-6096:
Component/s: State Backends, Checkpointing
> Refactor the migration of old versioned savepoints
>
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:
[
https://issues.apache.org/jira/browse/FLINK-6055?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15925575#comment-15925575
]
Xiaogang Shi commented on FLINK-6055:
-
I think it's very challenging because the storing and restoring
[
https://issues.apache.org/jira/browse/FLINK-6034?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-6034:
Description:
Currently, the only type of the snapshots in keyed streams is
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
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
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
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5053:
---
Assignee: Xiaogang Shi
> Incremental / lightweight snapshots for checkpoints
>
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5917:
---
Assignee: Xiaogang Shi
> Remove MapState.size()
> --
>
>
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15891970#comment-15891970
]
Xiaogang Shi commented on FLINK-5917:
-
+1 to remove the {{size()}} method due to the cost
[
https://issues.apache.org/jira/browse/FLINK-5925?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15889462#comment-15889462
]
Xiaogang Shi commented on FLINK-5925:
-
+1 for the cleanup mechanism. Each component (e.g.
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15887094#comment-15887094
]
Xiaogang Shi commented on FLINK-5917:
-
[~StephanEwen] We just use the cache to avoid the costly
[
https://issues.apache.org/jira/browse/FLINK-5917?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15885019#comment-15885019
]
Xiaogang Shi commented on FLINK-5917:
-
I think it's okay to remove this method. But a better choice is
[
https://issues.apache.org/jira/browse/FLINK-5790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-5790.
---
Resolution: Fixed
Fixed via d47446cafffe0d34d89488f6eb860aa139ceb3f1
> Use list types when
[
https://issues.apache.org/jira/browse/FLINK-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-5863.
---
Resolution: Fixed
Now that we are refactoring the queryable states, we can make the changes then.
>
[
https://issues.apache.org/jira/browse/FLINK-5865?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5865:
Summary: Throw original exception in states (was: Throw original exception
in RocksDB states)
>
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:
[
https://issues.apache.org/jira/browse/FLINK-5863?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5863:
---
Assignee: Xiaogang Shi
> Unify the serialization of queryable list states in different
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
[
https://issues.apache.org/jira/browse/FLINK-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-5036.
---
Resolution: Invalid
> Perform the grouping of keys in restoring instead of checkpointing
>
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-5023.
---
Resolution: Won't Fix
The updates to the `State` interface will affect existing user code. We will
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-5024.
---
Resolution: Invalid
Now we refactor the state descriptors with the introduction of composited
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
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
[
https://issues.apache.org/jira/browse/FLINK-5590?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15833260#comment-15833260
]
Xiaogang Shi commented on FLINK-5590:
-
[~StephanEwen], do you have any ideas of the solution?
I think
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5544:
---
Assignee: Xiaogang Shi
> Implement Internal Timer Service in RocksDB
>
[
https://issues.apache.org/jira/browse/FLINK-5544?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5544:
Issue Type: New Feature (was: Bug)
> Implement Internal Timer Service in RocksDB
>
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
[
https://issues.apache.org/jira/browse/FLINK-5398?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15786803#comment-15786803
]
Xiaogang Shi commented on FLINK-5398:
-
[~fhueske] Thanks for your explanation. It helps.
> Exclude
[
https://issues.apache.org/jira/browse/FLINK-5400?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5400:
Description: Now {{RuntimeContext}} does not provide the accessors to
folding states. Therefore
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
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:
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15782811#comment-15782811
]
Xiaogang Shi commented on FLINK-5397:
-
The idea does work and is better. Very thanks for the quick fix
[
https://issues.apache.org/jira/browse/FLINK-5397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-5397:
Description:
To restore from the savepoints in previous versions, Flink now keeps all
classes
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-5214?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15710512#comment-15710512
]
Xiaogang Shi commented on FLINK-5214:
-
I opened FLINK-5086 to report a similar problem, but I do not
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15679596#comment-15679596
]
Xiaogang Shi commented on FLINK-5090:
-
In flink, the performance bottlenecks are usually caused by
1.
[
https://issues.apache.org/jira/browse/FLINK-5090?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15675401#comment-15675401
]
Xiaogang Shi commented on FLINK-5090:
-
I suggest the metrics to be channel-wise. With these metrics,
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
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673253#comment-15673253
]
Xiaogang Shi edited comment on FLINK-5053 at 11/17/16 9:41 AM:
---
[~srichter]
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673253#comment-15673253
]
Xiaogang Shi commented on FLINK-5053:
-
[~srichter] Do you have a more detailed plan about incremental
[
https://issues.apache.org/jira/browse/FLINK-5085?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15673026#comment-15673026
]
Xiaogang Shi commented on FLINK-5085:
-
Great, this is what i thought of in recent days. Our states are
[
https://issues.apache.org/jira/browse/FLINK-5053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15663160#comment-15663160
]
Xiaogang Shi commented on FLINK-5053:
-
I think it's better to use {{checkpoint}} instead of {{backup}}
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15653177#comment-15653177
]
Xiaogang Shi commented on FLINK-5023:
-
[~aljoscha] [~StephanEwen] I have updated the PR. Now, `State`
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15652901#comment-15652901
]
Xiaogang Shi commented on FLINK-5024:
-
I am very poor at English :( But i think "Simple" is more often
[
https://issues.apache.org/jira/browse/FLINK-5036?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15650462#comment-15650462
]
Xiaogang Shi commented on FLINK-5036:
-
Current implementation of both checkpointing and restoring
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
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:52 AM:
--
[~aljoscha] In
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:46 AM:
--
@Aljoscha
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi edited comment on FLINK-5023 at 11/9/16 2:45 AM:
--
@Aljoscha
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15649615#comment-15649615
]
Xiaogang Shi commented on FLINK-5023:
-
Aljoscha Krettek In that case, i think we should provide
[
https://issues.apache.org/jira/browse/FLINK-5024?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5024:
---
Assignee: Xiaogang Shi
> Add SimpleStateDescriptor to clarify the concepts
>
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-5023:
---
Assignee: Xiaogang Shi
> Add get() method in State interface
>
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15646299#comment-15646299
]
Xiaogang Shi commented on FLINK-5023:
-
I have opened a PR:
[
https://issues.apache.org/jira/browse/FLINK-5023?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15643925#comment-15643925
]
Xiaogang Shi commented on FLINK-5023:
-
The only old method affected is the `value()` method in
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642868#comment-15642868
]
Xiaogang Shi edited comment on FLINK-4856 at 11/7/16 2:29 AM:
--
I have started
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15642868#comment-15642868
]
Xiaogang Shi commented on FLINK-4856:
-
I have started the implementation of MapStates. But at prior to
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:
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
[
https://issues.apache.org/jira/browse/FLINK-4856?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi reassigned FLINK-4856:
---
Assignee: Xiaogang Shi
> Add MapState for keyed streams
> --
>
>
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
[
https://issues.apache.org/jira/browse/FLINK-4448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi closed FLINK-4448.
---
Resolution: Fixed
The functionality will be implemented in Flink-4457
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15434052#comment-15434052
]
Xiaogang Shi commented on FLINK-4408:
-
I think it's okay to pull the logics about leadership out of
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
[
https://issues.apache.org/jira/browse/FLINK-4408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xiaogang Shi updated FLINK-4408:
Summary: Submit Job and setup ExecutionGraph (was: JobSubmission)
> Submit Job and setup
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
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
99 matches
Mail list logo
