Skip to content

Commit 076d5df

Browse files
authored
Merge branch 'apache:trunk' into HADOOP-19415-PART7
2 parents 2f527c8 + b050ede commit 076d5df

File tree

5 files changed

+13
-1
lines changed

5 files changed

+13
-1
lines changed

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/protocolPB/AsyncRpcProtocolPBUtil.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.hadoop.ipc.Client;
2727
import org.apache.hadoop.ipc.ProtobufRpcEngine2;
2828
import org.apache.hadoop.ipc.ProtobufRpcEngineCallback2;
29+
import org.apache.hadoop.ipc.Server;
2930
import org.apache.hadoop.ipc.internal.ShadedProtobufHelper;
3031
import org.apache.hadoop.thirdparty.protobuf.Message;
3132
import org.apache.hadoop.util.concurrent.AsyncGet;
@@ -93,6 +94,8 @@ public static <T, R> R asyncIpcClient(
9394
}
9495
try {
9596
T res = asyncReqMessage.get(-1, null);
97+
LOG.debug("Async IPC Request, Call={}, CallerContext={}, Result={}",
98+
Server.getCurCall().get(), CallerContext.getCurrent(), res);
9699
return response.apply(res);
97100
} catch (Exception ex) {
98101
throw warpCompletionException(ex);

hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/router/ThreadLocalContext.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -75,6 +75,7 @@ public ThreadLocalContext() {
7575
* that the task execution reflects the state of the original calling thread.
7676
*/
7777
public void transfer() {
78+
Server.getCurCall().set(null);
7879
if (call != null) {
7980
Server.getCurCall().set(call);
8081
}

hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/HistoryClientService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -168,7 +168,7 @@ protected void initializeWebApp(Configuration conf) throws IOException {
168168
ClientRMProxy.createRMProxy(conf, ApplicationClientProtocol.class);
169169
// NOTE: there should be a .at(InetSocketAddress)
170170
WebApps
171-
.$for("jobhistory", HistoryClientService.class, this, "ws")
171+
.$for("jobhistory", HistoryClientService.class, this, "hs-ws")
172172
.with(conf)
173173
.withHttpSpnegoKeytabKey(
174174
JHAdminConfig.MR_WEBAPP_SPNEGO_KEYTAB_FILE_KEY)

hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-hs/src/main/java/org/apache/hadoop/mapreduce/v2/hs/webapp/HsWebApp.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,6 +44,7 @@ public void setup() {
4444
bind(HistoryContext.class).toInstance(history);
4545
route("/", HsController.class);
4646
route("/app", HsController.class);
47+
route("/jobhistory", HsController.class);
4748
route(pajoin("/job", JOB_ID), HsController.class, "job");
4849
route(pajoin("/conf", JOB_ID), HsController.class, "conf");
4950
routeWithoutDefaultView(pajoin("/downloadconf", JOB_ID),

hadoop-yarn-project/hadoop-yarn/hadoop-yarn-ui/pom.xml

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -270,6 +270,13 @@
270270
<groupId>ro.isdc.wro4j</groupId>
271271
<artifactId>wro4j-maven-plugin</artifactId>
272272
<version>1.8.0</version>
273+
<dependencies>
274+
<dependency>
275+
<groupId>org.mockito</groupId>
276+
<artifactId>mockito-core</artifactId>
277+
<version>4.11.0</version>
278+
</dependency>
279+
</dependencies>
273280
<executions>
274281
<execution>
275282
<phase>prepare-package</phase>

0 commit comments

Comments
 (0)