Skip to content

Commit 67682ff

Browse files
authored
[Improve] flink webUI proxy support with simple auth (#4274)
1 parent 2233b18 commit 67682ff

1 file changed

Lines changed: 5 additions & 2 deletions

File tree

  • streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl

streampark-console/streampark-console-service/src/main/java/org/apache/streampark/console/core/service/impl/ProxyServiceImpl.java

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,6 +17,7 @@
1717

1818
package org.apache.streampark.console.core.service.impl;
1919

20+
import org.apache.streampark.common.util.HadoopConfigUtils;
2021
import org.apache.streampark.common.util.HadoopUtils;
2122
import org.apache.streampark.common.util.YarnUtils;
2223
import org.apache.streampark.console.core.entity.ApplicationLog;
@@ -228,9 +229,11 @@ private ResponseEntity<?> proxyYarnRequest(HttpServletRequest request, String ur
228229
setRestTemplateCredentials(ugi.getShortUserName());
229230
return ugi.doAs(
230231
(PrivilegedExceptionAction<ResponseEntity<?>>) () -> proxy(request, url, requestEntity));
231-
} else {
232-
return proxyRequest(request, url);
233232
}
233+
if (YarnUtils.hasYarnHttpSimpleAuth()) {
234+
return proxyRequest(request, String.format("%s?user.name=%s", url, HadoopConfigUtils.hadoopUserName()));
235+
}
236+
return proxyRequest(request, url);
234237
}
235238

236239
private ResponseEntity<?> proxy(

0 commit comments

Comments
 (0)