You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@twill.apache.org by ch...@apache.org on 2015/05/06 00:59:50 UTC
[3/3] incubator-twill git commit: Fix awkward indentation.
Fix awkward indentation.
Project: http://git-wip-us.apache.org/repos/asf/incubator-twill/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-twill/commit/d14d2dde
Tree: http://git-wip-us.apache.org/repos/asf/incubator-twill/tree/d14d2dde
Diff: http://git-wip-us.apache.org/repos/asf/incubator-twill/diff/d14d2dde
Branch: refs/heads/feature/TWILL-69
Commit: d14d2dde7d82fe3daafc01c5ec45dc9438149ee4
Parents: 0d217b6
Author: Terence Yim <ch...@apache.org>
Authored: Tue May 5 15:59:41 2015 -0700
Committer: Terence Yim <ch...@apache.org>
Committed: Tue May 5 15:59:41 2015 -0700
----------------------------------------------------------------------
.../org/apache/twill/yarn/YarnTwillRunnerService.java | 13 ++++++-------
1 file changed, 6 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-twill/blob/d14d2dde/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java
----------------------------------------------------------------------
diff --git a/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java b/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java
index 3ee34cd..690d41e 100644
--- a/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java
+++ b/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillRunnerService.java
@@ -433,13 +433,12 @@ public final class YarnTwillRunnerService implements TwillRunnerService {
@Override
public void run() {
synchronized (YarnTwillRunnerService.this) {
- Iterables.removeIf(controllers.values(),
- new Predicate<TwillController>() {
- @Override
- public boolean apply(TwillController input) {
- return input == controller;
- }
- });
+ Iterables.removeIf(controllers.values(), new Predicate<YarnTwillController>() {
+ @Override
+ public boolean apply(YarnTwillController input) {
+ return input == controller;
+ }
+ });
}
}
}, Threads.SAME_THREAD_EXECUTOR);