Commits

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Commits

Commits on Jan 25, 2018

[FLINK-8266] Add network memory to ResourceProfile for input/output memory of a task

[FLINK-8224] [flip6] Shutdown application when job terminated in job mode

Commits on Jan 15, 2018

[FLINK-8399] [runtime] use independent configurations for the different timeouts in slot manager

Commits on Jan 12, 2018

[FLINK-8288] [runtime] register job master rest endpoint url to yarn

Commits on Dec 14, 2017

[FLINK-7928] [runtime] extend the resources in ResourceProfile for precisely calculating the resource of task manager

[FLINK-7878] [api] make resource type extendible in ResourceSpec

Commits on Nov 10, 2017

[FLINK-6434] cancel slot allocation if request timed out in ProviderAndOwner

Commits on Nov 7, 2017

[FLINK-7870] [runtime] slot pool cancel slot request to resource manager if timeout

Commits on May 6, 2017

[hotfix] [runtime] Correct some JavaDocs for RestartIndividualStrategy

[FLINK-5867] [flip-1] Add tests for pipelined failover region construction

[FLINK-5867] [flip-1] Support restarting only pipelined sub-regions of the ExecutionGraph on task failure

Commits on Feb 28, 2017

[FLINK-5501] [runtime] Extend RunningJobRegistry to job status created/running/done

Commits on Feb 20, 2017

[FLINK-5074] [runtime] Add a ZooKeeper-based RunningJobRegistry

Commits on Feb 15, 2017

[FLINK-5793] [runtime] fix running slot may not be add to AllocatedMap in SlotPool bug

Commits on Dec 23, 2016

[FLINK-4930] [client] [yarn] delete tmp file of job graph and refine finalizeCluster

[FLINK-4930] [client, yarn] Implement FLIP-6 YARN client

[FLINK-4927] [yarn] refine YARN Resource manager according to till's comments

[FLINK-4929] [yarn] Implement FLIP-6 YARN TaskExecutor Runner

[FLINK-4928] [yarn] Implement FLIP-6 YARN Application Master Runner

[FLINK-4928] [yarn] Implement FLIP-6 YARN Application Master Runner

[FLINK-5190] [runtime] fix ZooKeeperLeaderRetrievalService close the zk client when stopping bug

[FLINK-5170] [akka] Fix hostname usage in AkkaUtils.getConfig

[FLINK-5171] [runtime] fix wrong use of Preconditions.checkState in TaskManagerRunner

Branch selector

User selector

Commit History

Commits on Jan 25, 2018

Commits on Jan 15, 2018

Commits on Jan 12, 2018

Commits on Dec 14, 2017

Commits on Nov 10, 2017

Commits on Nov 7, 2017

Commits on May 6, 2017

Commits on Feb 28, 2017

Commits on Feb 20, 2017

Commits on Feb 15, 2017

Commits on Dec 23, 2016