|
|
|
FLINK-19476
|
FLINK-19343
Introduce CacheManager in CatalogManager to keep track of the ClusterPartitionDescriptor
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19355
|
FLINK-19343
Add close() method to TableEnvironment
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19354
|
FLINK-19343
Add invalidateCache() method in CachedTable
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19353
|
FLINK-19343
BlinkPlanner translate and optimize CacheOperation
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19352
|
FLINK-19343
Add cache() method to Table
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19351
|
FLINK-19343
StreamingJobGraphGenerator set the caching node to BoundedBlockingType
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19350
|
FLINK-19343
StreamingJobGraphGenerator add the ClusterPartitionDescriptor of cached node to JobVertex
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19349
|
FLINK-19343
StreamGraphGenerator handle CacheSource and CacheSink
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19348
|
FLINK-19343
Introduce CacheSource and CacheSink
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19347
|
FLINK-19343
Generate InputGateDeploymentDescriptor from a JobVertex with ClusterPartitionDescriptor
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|
|
|
|
FLINK-19346
|
FLINK-19343
Generate and put ClusterPartitionDescriptor of ClusterPartition in JobResult when job finishes
|
Unassigned
|
Xuannan Su
|
|
Open |
Unresolved
|
|
|
|
|