Details
-
New Feature
-
Status: Open
-
Not a Priority
-
Resolution: Unresolved
-
None
-
None
Description
Please refer to the FLIP for any details: https://cwiki.apache.org/confluence/display/FLINK/FLIP-36%3A+Support+Interactive+Programming+in+Flink
Attachments
Issue Links
- is duplicated by
-
FLINK-11199 Support interactive programming in Flink
- Closed
- is related to
-
FLINK-22768 ShuffleMaster supports to promote partitions
- Open
- mentioned in
-
Page Loading...
1.
|
Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes | Open | Unassigned | |
2.
|
Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor | Open | Unassigned | |
3.
|
Introduce CacheSource and CacheSink | Open | Unassigned | |
4.
|
StreamGraphGenerator handle CacheSource and CacheSink | Open | Unassigned | |
5.
|
StreamingJobGraphGenerator add the ClusterPartitionDescriptor of cached node to JobVertex | Open | Unassigned | |
6.
|
StreamingJobGraphGenerator set the caching node to BoundedBlockingType | Open | Unassigned | |
7.
|
Add cache() method to Table | Open | Unassigned | |
8.
|
BlinkPlanner translate and optimize CacheOperation | Open | Unassigned | |
9.
|
Add invalidateCache() method in CachedTable | Open | Unassigned | |
10.
|
Add close() method to TableEnvironment | Open | Unassigned | |
11.
|
Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor | Open | Unassigned |
My team is considering the design of "Remote Shuffle Service", regarding this "Interactive" FLIP, may I comment by below points ?