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...
http://issues.apache.org/jira/browse/FLINK-12960    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 ...
http://issues.apache.org/jira/browse/FLINK-12555    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 ...
http://issues.apache.org/jira/browse/FLINK-12731    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...
http://issues.apache.org/jira/browse/FLINK-12706    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...
http://issues.apache.org/jira/browse/FLINK-12890    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...
http://issues.apache.org/jira/browse/FLINK-12873    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...
http://issues.apache.org/jira/browse/FLINK-10831    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....
http://issues.apache.org/jira/browse/FLINK-11392    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...
http://issues.apache.org/jira/browse/FLINK-11391    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...
http://issues.apache.org/jira/browse/FLINK-12673    Author: Andrey Zagrebin , 2019-06-06, 08:52