[
https://issues.apache.org/jira/browse/APEXCORE-488?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15374152#comment-15374152
]
ASF GitHub Bot commented on APEXCORE-488:
-----------------------------------------
Github user PramodSSImmaneni commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/357#discussion_r70553112
--- Diff:
engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java ---
@@ -607,14 +608,15 @@ protected void serviceStart() throws Exception
}
try {
- Configuration config = getConfig();
+ YarnConfiguration config = new YarnConfiguration(getConfig());
if (SecurityUtils.isStramWebSecurityEnabled()) {
- config = new Configuration(config);
config.set("hadoop.http.filter.initializers",
StramWSFilterInitializer.class.getCanonicalName());
}
WebApp webApp = WebApps.$for("stram", StramAppContext.class,
appContext, "ws").with(config).start(new StramWebApp(this.dnmgr));
LOG.info("Started web service at port: " + webApp.port());
- this.appMasterTrackingUrl =
NetUtils.getConnectAddress(webApp.getListenerAddress()).getHostName() + ":" +
webApp.port();
+ String scheme = ConfigUtils.getSchemePrefix(config);
+ String hostname =
NetUtils.getConnectAddress(webApp.getListenerAddress()).getHostName();
+ this.appMasterTrackingUrl = scheme + hostname + ":" + webApp.port();
--- End diff --
This is changing the contract of appMasterTrackingUrl in the web service
response even though this is probably how it should have been in the first
place. This would be a backwards incompatible change. Suggest to use a separate
property for scheme.
> Issues in SSL communication with StrAM
> --------------------------------------
>
> Key: APEXCORE-488
> URL: https://issues.apache.org/jira/browse/APEXCORE-488
> Project: Apache Apex Core
> Issue Type: Bug
> Reporter: Pradeep A. Dalvi
> Assignee: Pradeep A. Dalvi
>
> Couple of issues in SSL communication with StrAM to track application progress
> - trackingURL without protocol scheme, makes YARN to pick up default HTTP.
> This happens even if the yarn.http.policy is set to HTTPS_ONLY.
> - StramAgent assumes always HTTP communication
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
