clear query| facets| time Search criteria: .   Results from 1 to 10 from 153 (0.0s).
Loading phrases to help you
refine your search...
[FLINK-12960] Move ResultPartitionDeploymentDescriptor#releasedOnConsumption to PartitionDescriptor#releasedOnConsumption - Flink - [issue]
...ResultPartitionDeploymentDescriptor#releasedOnConsumption shows the intention how the partition is going to be used by the shuffle user. If it is not supported by the shuffle service for a c...    Author: Andrey Zagrebin , 2019-06-24, 12:21
[FLINK-12555] Introduce an encapsulated metric group layout for shuffle API and deprecate old one - Flink - [issue]
...At the moment, partition/gate create methods in NetworkEnvironment have a lot of metrics arguments to maintain original layout for metric groups. This approach is not quite encapsulated and ...    Author: Andrey Zagrebin , 2019-06-24, 10:09
[FLINK-12731] Load shuffle service implementations from plugin manager - Flink - [issue]
...The simple way to load shuffle service is to do it from class path with the default class loader. Additionally, shuffle service implementations can be loaded as plugins with their own class ...    Author: Andrey Zagrebin , 2019-06-21, 15:42
[FLINK-12706] Introduce ShuffleService interface and its configuration - Flink - [issue]
...ShuffleService should be a factory for ShuffleMaster in JM and local ShuffleEnvironment in TM. The default implementation is already available former NetworkEnvironment. To make it pluggable...    Author: Andrey Zagrebin , 2019-06-20, 17:22
[FLINK-12890] Add partition lifecycle related Shuffle API - Flink - [issue]
...At the moment we have ShuffleEnvironment.releasePartitions which is used to release locally occupied resources of partition. JM can also use it by calling TaskExecutorGateway.releasePartitio...    Author: Andrey Zagrebin , 2019-06-19, 07:36
[FLINK-12873] Create a separate maven module for Shuffle API - Flink - [issue]
...At the moment, shuffle service API is a part of flink-runtime maven module. The implementers of other shuffle services will have to depend on the fat dependency of flink-runtime. We should c...    Author: Andrey Zagrebin , 2019-06-17, 13:39
[FLINK-10831] Consider making processing time monotonically increasing by default - Flink - [issue]
...At the moment, the processing time is basically implemented in a fixed way as System.currentTimeMillis() and not configurable by users.The timestamp provided this way is not guaranteed to be...    Author: Andrey Zagrebin , 2019-06-17, 11:27
[FLINK-11392] Introduce ShuffleEnvironment in Task Executor - Flink - [issue]
...Extract ShuffleEnvironment interface from NetworkEnvironment. Make NetworkEnvironment its default implementation Rename NetworkEnvironment to NettyShuffleEnvironment....    Author: Andrey Zagrebin , 2019-06-11, 10:05
[FLINK-11391] Introduce ShuffleMaster in Job Master - Flink - [issue]
...Implement PartitionShuffleDescriptor for covering necessary abstract info. Implement ShuffleDeploymentDecriptor generated from PartitionShuffleDecriptor. Define ShuffleMaster interface and c...    Author: Andrey Zagrebin , 2019-06-06, 09:42
[FLINK-12673] Introduce NetworkEnvironment.getUnreleasedPartitions instead of using getResultPartitionManager - Flink - [issue]
...At the moment NetworkEnvironment.getResultPartitionManager is used to query TaskExecutor whether all partitions are released. We should hide this direct access to ResultPartitionManager behi...    Author: Andrey Zagrebin , 2019-06-06, 08:52