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 2017/08/05 04:16:13 UTC
[5/5] twill git commit: Only copy twill configurations into the
runtime spec.
Only copy twill configurations into the runtime spec.
Project: http://git-wip-us.apache.org/repos/asf/twill/repo
Commit: http://git-wip-us.apache.org/repos/asf/twill/commit/6ccc7158
Tree: http://git-wip-us.apache.org/repos/asf/twill/tree/6ccc7158
Diff: http://git-wip-us.apache.org/repos/asf/twill/diff/6ccc7158
Branch: refs/heads/feature/TWILL-241-per-runnable-opts
Commit: 6ccc7158e13a0b7182197cc35c91d96fc9947541
Parents: 577e6c7
Author: Terence Yim <ch...@apache.org>
Authored: Fri Aug 4 21:16:00 2017 -0700
Committer: Terence Yim <ch...@apache.org>
Committed: Fri Aug 4 21:16:00 2017 -0700
----------------------------------------------------------------------
.../src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/twill/blob/6ccc7158/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java
----------------------------------------------------------------------
diff --git a/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java b/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java
index c2b0ee5..0eba62b 100644
--- a/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java
+++ b/twill-yarn/src/main/java/org/apache/twill/yarn/YarnTwillPreparer.java
@@ -698,7 +698,9 @@ final class YarnTwillPreparer implements TwillPreparer {
spec.getPlacementPolicies(), eventHandler);
Map<String, String> configMap = Maps.newHashMap();
for (Map.Entry<String, String> entry : config) {
- configMap.put(entry.getKey(), entry.getValue());
+ if (entry.getKey().startsWith("twill.")) {
+ configMap.put(entry.getKey(), entry.getValue());
+ }
}
TwillRuntimeSpecification twillRuntimeSpec = new TwillRuntimeSpecification(