[hadoop] branch branch-3.3 updated: YARN-9333. TestFairSchedulerPreemption.testRelaxLocalityPreemptionWithNoLessAMInRemainingNodes fails intermittently. Contributed by Peter Bacsko
This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 3d715c2 YARN-9333.
TestFairSchedulerPreemption.testRelaxLocalityPreemptionWithNoLessAMInRemainingNodes
fails intermittently. Contributed by Peter Bacsko
3d715c2 is described below
commit 3d715c2e4c8d158cffb44246a018d50750e5eb1d
Author: Szilard Nemeth
AuthorDate: Thu Sep 17 19:57:19 2020 +0200
YARN-9333.
TestFairSchedulerPreemption.testRelaxLocalityPreemptionWithNoLessAMInRemainingNodes
fails intermittently. Contributed by Peter Bacsko
(cherry picked from commit eacbe07b565f7ef6f05d0775dbafcf15eecb86f6)
---
.../resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java
index 1312b18..0240132 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/fair/TestFairSchedulerPreemption.java
@@ -94,6 +94,7 @@ public class TestFairSchedulerPreemption extends
FairSchedulerTestBase {
conf.setBoolean(FairSchedulerConfiguration.PREEMPTION, true);
conf.setFloat(FairSchedulerConfiguration.PREEMPTION_THRESHOLD, 0f);
conf.setInt(FairSchedulerConfiguration.WAIT_TIME_BEFORE_KILL, 0);
+conf.setLong(FairSchedulerConfiguration.UPDATE_INTERVAL_MS, 60_000L);
setupCluster();
}
-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.3 updated: YARN-10515. Fix flaky test TestCapacitySchedulerAutoQueueCreation.testDynamicAutoQueueCreationWithTags. Contributed by Peter Bacsko
This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 3303aa5 YARN-10515. Fix flaky test
TestCapacitySchedulerAutoQueueCreation.testDynamicAutoQueueCreationWithTags.
Contributed by Peter Bacsko
3303aa5 is described below
commit 3303aa594737fe97f9d4494d958e0da5acffe7ca
Author: Szilard Nemeth
AuthorDate: Thu Jan 21 20:58:57 2021 +0100
YARN-10515. Fix flaky test
TestCapacitySchedulerAutoQueueCreation.testDynamicAutoQueueCreationWithTags.
Contributed by Peter Bacsko
(cherry picked from commit 8620984b8df53afbde420532920f5392d045f9b5)
---
.../scheduler/capacity/TestCapacitySchedulerAutoCreatedQueueBase.java | 2 ++
1 file changed, 2 insertions(+)
diff --git
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestCapacitySchedulerAutoCreatedQueueBase.java
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestCapacitySchedulerAutoCreatedQueueBase.java
index 6888c01..cc6a71b 100644
---
a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestCapacitySchedulerAutoCreatedQueueBase.java
+++
b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/scheduler/capacity/TestCapacitySchedulerAutoCreatedQueueBase.java
@@ -52,6 +52,7 @@ import
org.apache.hadoop.yarn.server.resourcemanager.placement.QueueMapping.Queu
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMApp;
import org.apache.hadoop.yarn.server.resourcemanager.rmapp.RMAppEventType;
import
org.apache.hadoop.yarn.server.resourcemanager.scheduler.ContainerUpdates;
+import org.apache.hadoop.yarn.server.resourcemanager.scheduler.QueueMetrics;
import org.apache.hadoop.yarn.server.resourcemanager.scheduler
.ResourceScheduler;
@@ -201,6 +202,7 @@ public class TestCapacitySchedulerAutoCreatedQueueBase {
@Before
public void setUp() throws Exception {
+QueueMetrics.clearQueueMetrics();
CapacitySchedulerConfiguration conf = setupSchedulerConfiguration();
setupQueueConfiguration(conf);
conf.setClass(YarnConfiguration.RM_SCHEDULER, CapacityScheduler.class,
-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.3 updated: HADOOP-17036. TestFTPFileSystem failing as ftp server dir already exists.
This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new 0f12f3e HADOOP-17036. TestFTPFileSystem failing as ftp server dir
already exists.
0f12f3e is described below
commit 0f12f3e125c87a9d559798161ec3fceaa04553f8
Author: Mike
AuthorDate: Thu May 14 20:28:00 2020 +0300
HADOOP-17036. TestFTPFileSystem failing as ftp server dir already exists.
Contributed by Mikhail Pryakhin.
(cherry picked from commit 017d24e9703e9447f88ba94df3a8aa0800de770b)
---
.../test/java/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java| 9 ++---
1 file changed, 6 insertions(+), 3 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java
b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java
index b25990f..8155d8e 100644
---
a/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java
+++
b/hadoop-common-project/hadoop-common/src/test/java/org/apache/hadoop/fs/ftp/TestFTPFileSystem.java
@@ -55,13 +55,16 @@ import static org.junit.Assert.assertEquals;
public class TestFTPFileSystem {
private FtpTestServer server;
-
+ private java.nio.file.Path testDir;
@Rule
public Timeout testTimeout = new Timeout(18);
@Before
public void setUp() throws Exception {
-server = new FtpTestServer(GenericTestUtils.getTestDir().toPath()).start();
+testDir = Files.createTempDirectory(
+GenericTestUtils.getTestDir().toPath(), getClass().getName()
+);
+server = new FtpTestServer(testDir).start();
}
@After
@@ -69,7 +72,7 @@ public class TestFTPFileSystem {
public void tearDown() throws Exception {
if (server != null) {
server.stop();
- Files.walk(server.getFtpRoot())
+ Files.walk(testDir)
.sorted(Comparator.reverseOrder())
.map(java.nio.file.Path::toFile)
.forEach(File::delete);
-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.3 updated: HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new df50e21 HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
df50e21 is described below
commit df50e210dd86f07edfaaea248511b27146da6aed
Author: Takanobu Asanuma
AuthorDate: Fri May 7 13:52:17 2021 +0900
HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
Signed-off-by: Akira Ajisaka
(cherry picked from commit 207210263a27784bf3b61771d2f8364bda7bbb50)
---
.../hadoop/tools/dynamometer/AllowAllImpersonationProvider.java | 5 +
.../org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java| 2 +-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
index 6800bbe..14f52ac 100644
---
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
+++
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
@@ -38,4 +38,9 @@ public class AllowAllImpersonationProvider extends Configured
// Do nothing
}
+ // Although this API was removed from the interface by HADOOP-17367, we need
+ // to keep it here because TestDynamometerInfra uses an old hadoop binary.
+ public void authorize(UserGroupInformation user, String remoteAddress) {
+// Do nothing
+ }
}
diff --git
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
index 174d9cc..092a54b 100644
---
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
+++
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
@@ -122,7 +122,7 @@ public class TestDynamometerInfra {
private static final String HADOOP_BIN_PATH_KEY = "dyno.hadoop.bin.path";
private static final String HADOOP_BIN_VERSION_KEY =
"dyno.hadoop.bin.version";
- private static final String HADOOP_BIN_VERSION_DEFAULT = "3.1.3";
+ private static final String HADOOP_BIN_VERSION_DEFAULT = "3.1.4";
private static final String FSIMAGE_FILENAME = "fsimage_0061740";
private static final String VERSION_FILENAME = "VERSION";
-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch trunk updated: HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
This is an automated email from the ASF dual-hosted git repository.
aajisaka pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new 2072102 HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
2072102 is described below
commit 207210263a27784bf3b61771d2f8364bda7bbb50
Author: Takanobu Asanuma
AuthorDate: Fri May 7 13:52:17 2021 +0900
HADOOP-17375. Fix the error of TestDynamometerInfra. (#2471)
Signed-off-by: Akira Ajisaka
---
.../hadoop/tools/dynamometer/AllowAllImpersonationProvider.java | 5 +
.../org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java| 2 +-
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
index 6800bbe..14f52ac 100644
---
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
+++
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/main/java/org/apache/hadoop/tools/dynamometer/AllowAllImpersonationProvider.java
@@ -38,4 +38,9 @@ public class AllowAllImpersonationProvider extends Configured
// Do nothing
}
+ // Although this API was removed from the interface by HADOOP-17367, we need
+ // to keep it here because TestDynamometerInfra uses an old hadoop binary.
+ public void authorize(UserGroupInformation user, String remoteAddress) {
+// Do nothing
+ }
}
diff --git
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
index 174d9cc..092a54b 100644
---
a/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
+++
b/hadoop-tools/hadoop-dynamometer/hadoop-dynamometer-infra/src/test/java/org/apache/hadoop/tools/dynamometer/TestDynamometerInfra.java
@@ -122,7 +122,7 @@ public class TestDynamometerInfra {
private static final String HADOOP_BIN_PATH_KEY = "dyno.hadoop.bin.path";
private static final String HADOOP_BIN_VERSION_KEY =
"dyno.hadoop.bin.version";
- private static final String HADOOP_BIN_VERSION_DEFAULT = "3.1.3";
+ private static final String HADOOP_BIN_VERSION_DEFAULT = "3.1.4";
private static final String FSIMAGE_FILENAME = "fsimage_0061740";
private static final String VERSION_FILENAME = "VERSION";
-
To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org
For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.1 updated: HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed by Hector Chaverri.
This is an automated email from the ASF dual-hosted git repository.
shv pushed a commit to branch branch-3.1
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.1 by this push:
new 39bf9e2 HADOOP-17680. Allow ProtobufRpcEngine to be extensible
(#2905) Contributed by Hector Chaverri.
39bf9e2 is described below
commit 39bf9e270e3a5dbcd3a7a2924f62bd0b2dee0a02
Author: hchaverr
AuthorDate: Thu May 6 16:40:45 2021 -0700
HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed
by Hector Chaverri.
(cherry picked from commit f40e3eb0590f85bb42d2471992bf5d524628fdd6)
---
.../org/apache/hadoop/ipc/ProtobufRpcEngine.java | 30 +-
1 file changed, 24 insertions(+), 6 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
index 959f701..670093f 100644
---
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
+++
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
@@ -115,7 +115,7 @@ public class ProtobufRpcEngine implements RpcEngine {
factory)), false);
}
- private static class Invoker implements RpcInvocationHandler {
+ protected static class Invoker implements RpcInvocationHandler {
private final Map returnTypes =
new ConcurrentHashMap();
private boolean isClosed = false;
@@ -126,7 +126,7 @@ public class ProtobufRpcEngine implements RpcEngine {
private AtomicBoolean fallbackToSimpleAuth;
private AlignmentContext alignmentContext;
-private Invoker(Class protocol, InetSocketAddress addr,
+protected Invoker(Class protocol, InetSocketAddress addr,
UserGroupInformation ticket, Configuration conf, SocketFactory factory,
int rpcTimeout, RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext)
@@ -141,7 +141,7 @@ public class ProtobufRpcEngine implements RpcEngine {
/**
* This constructor takes a connectionId, instead of creating a new one.
*/
-private Invoker(Class protocol, Client.ConnectionId connId,
+protected Invoker(Class protocol, Client.ConnectionId connId,
Configuration conf, SocketFactory factory) {
this.remoteId = connId;
this.client = CLIENTS.getClient(conf, factory, RpcWritable.Buffer.class);
@@ -218,8 +218,6 @@ public class ProtobufRpcEngine implements RpcEngine {
traceScope =
tracer.newScope(RpcClientUtil.methodToTraceString(method));
}
- RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
-
if (LOG.isTraceEnabled()) {
LOG.trace(Thread.currentThread().getId() + ": Call -> " +
remoteId + ": " + method.getName() +
@@ -231,7 +229,7 @@ public class ProtobufRpcEngine implements RpcEngine {
final RpcWritable.Buffer val;
try {
val = (RpcWritable.Buffer) client.call(RPC.RpcKind.RPC_PROTOCOL_BUFFER,
-new RpcProtobufRequest(rpcRequestHeader, theRequest), remoteId,
+constructRpcRequest(method, theRequest), remoteId,
fallbackToSimpleAuth, alignmentContext);
} catch (Throwable e) {
@@ -276,6 +274,11 @@ public class ProtobufRpcEngine implements RpcEngine {
}
}
+protected Writable constructRpcRequest(Method method, Message theRequest) {
+ RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
+ return new RpcProtobufRequest(rpcRequestHeader, theRequest);
+}
+
private Message getReturnMessage(final Method method,
final RpcWritable.Buffer buf) throws ServiceException {
Message prototype = null;
@@ -325,6 +328,14 @@ public class ProtobufRpcEngine implements RpcEngine {
public ConnectionId getConnectionId() {
return remoteId;
}
+
+protected long getClientProtocolVersion() {
+ return clientProtocolVersion;
+}
+
+protected String getProtocolName() {
+ return protocolName;
+}
}
@VisibleForTesting
@@ -503,6 +514,13 @@ public class ProtobufRpcEngine implements RpcEngine {
String declaringClassProtoName =
rpcRequest.getDeclaringClassProtocolName();
long clientVersion = rpcRequest.getClientProtocolVersion();
+return call(server, connectionProtocolName, request, receiveTime,
+methodName, declaringClassProtoName, clientVersion);
+ }
+
+ protected Writable call(RPC.Server server, String connectionProtocolName,
+ RpcWritable.Buffer request, long receiveTime, String methodName,
+ String declaringClassProtoName, long clientVersion) throws Exception
{
if (server.verbose)
LOG.info("Call: connectionProtocolName=
[hadoop] branch branch-3.2 updated: HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed by Hector Chaverri.
This is an automated email from the ASF dual-hosted git repository.
shv pushed a commit to branch branch-3.2
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.2 by this push:
new f6af5bf HADOOP-17680. Allow ProtobufRpcEngine to be extensible
(#2905) Contributed by Hector Chaverri.
f6af5bf is described below
commit f6af5bff9e1e9411f38038d4b0a8dbf4e0cbbac0
Author: hchaverr
AuthorDate: Thu May 6 16:40:45 2021 -0700
HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed
by Hector Chaverri.
(cherry picked from commit f40e3eb0590f85bb42d2471992bf5d524628fdd6)
---
.../org/apache/hadoop/ipc/ProtobufRpcEngine.java | 30 +-
1 file changed, 24 insertions(+), 6 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
index 5db2cc1..25a4fd4 100644
---
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
+++
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
@@ -115,7 +115,7 @@ public class ProtobufRpcEngine implements RpcEngine {
factory)), false);
}
- private static class Invoker implements RpcInvocationHandler {
+ protected static class Invoker implements RpcInvocationHandler {
private final Map returnTypes =
new ConcurrentHashMap();
private boolean isClosed = false;
@@ -126,7 +126,7 @@ public class ProtobufRpcEngine implements RpcEngine {
private AtomicBoolean fallbackToSimpleAuth;
private AlignmentContext alignmentContext;
-private Invoker(Class protocol, InetSocketAddress addr,
+protected Invoker(Class protocol, InetSocketAddress addr,
UserGroupInformation ticket, Configuration conf, SocketFactory factory,
int rpcTimeout, RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext)
@@ -141,7 +141,7 @@ public class ProtobufRpcEngine implements RpcEngine {
/**
* This constructor takes a connectionId, instead of creating a new one.
*/
-private Invoker(Class protocol, Client.ConnectionId connId,
+protected Invoker(Class protocol, Client.ConnectionId connId,
Configuration conf, SocketFactory factory) {
this.remoteId = connId;
this.client = CLIENTS.getClient(conf, factory, RpcWritable.Buffer.class);
@@ -218,8 +218,6 @@ public class ProtobufRpcEngine implements RpcEngine {
traceScope =
tracer.newScope(RpcClientUtil.methodToTraceString(method));
}
- RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
-
if (LOG.isTraceEnabled()) {
LOG.trace(Thread.currentThread().getId() + ": Call -> " +
remoteId + ": " + method.getName() +
@@ -231,7 +229,7 @@ public class ProtobufRpcEngine implements RpcEngine {
final RpcWritable.Buffer val;
try {
val = (RpcWritable.Buffer) client.call(RPC.RpcKind.RPC_PROTOCOL_BUFFER,
-new RpcProtobufRequest(rpcRequestHeader, theRequest), remoteId,
+constructRpcRequest(method, theRequest), remoteId,
fallbackToSimpleAuth, alignmentContext);
} catch (Throwable e) {
@@ -276,6 +274,11 @@ public class ProtobufRpcEngine implements RpcEngine {
}
}
+protected Writable constructRpcRequest(Method method, Message theRequest) {
+ RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
+ return new RpcProtobufRequest(rpcRequestHeader, theRequest);
+}
+
private Message getReturnMessage(final Method method,
final RpcWritable.Buffer buf) throws ServiceException {
Message prototype = null;
@@ -325,6 +328,14 @@ public class ProtobufRpcEngine implements RpcEngine {
public ConnectionId getConnectionId() {
return remoteId;
}
+
+protected long getClientProtocolVersion() {
+ return clientProtocolVersion;
+}
+
+protected String getProtocolName() {
+ return protocolName;
+}
}
@VisibleForTesting
@@ -504,6 +515,13 @@ public class ProtobufRpcEngine implements RpcEngine {
String declaringClassProtoName =
rpcRequest.getDeclaringClassProtocolName();
long clientVersion = rpcRequest.getClientProtocolVersion();
+return call(server, connectionProtocolName, request, receiveTime,
+methodName, declaringClassProtoName, clientVersion);
+ }
+
+ protected Writable call(RPC.Server server, String connectionProtocolName,
+ RpcWritable.Buffer request, long receiveTime, String methodName,
+ String declaringClassProtoName, long clientVersion) throws Exception
{
if (server.verbose)
LOG.info("Call: connectionProtocolName=
[hadoop] branch branch-3.3 updated: HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed by Hector Chaverri.
This is an automated email from the ASF dual-hosted git repository.
shv pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new cedebf1 HADOOP-17680. Allow ProtobufRpcEngine to be extensible
(#2905) Contributed by Hector Chaverri.
cedebf1 is described below
commit cedebf1c27361077d0a9c6a6ec7cc9bb8ec200e5
Author: hchaverr
AuthorDate: Thu May 6 16:40:45 2021 -0700
HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed
by Hector Chaverri.
(cherry picked from commit f40e3eb0590f85bb42d2471992bf5d524628fdd6)
---
.../org/apache/hadoop/ipc/ProtobufRpcEngine.java | 30 +-
.../org/apache/hadoop/ipc/ProtobufRpcEngine2.java | 30 +-
2 files changed, 48 insertions(+), 12 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
index b7b7ad4..d539bb2 100644
---
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
+++
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
@@ -122,7 +122,7 @@ public class ProtobufRpcEngine implements RpcEngine {
factory)), false);
}
- private static class Invoker implements RpcInvocationHandler {
+ protected static class Invoker implements RpcInvocationHandler {
private final Map returnTypes =
new ConcurrentHashMap();
private boolean isClosed = false;
@@ -133,7 +133,7 @@ public class ProtobufRpcEngine implements RpcEngine {
private AtomicBoolean fallbackToSimpleAuth;
private AlignmentContext alignmentContext;
-private Invoker(Class protocol, InetSocketAddress addr,
+protected Invoker(Class protocol, InetSocketAddress addr,
UserGroupInformation ticket, Configuration conf, SocketFactory factory,
int rpcTimeout, RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext)
@@ -148,7 +148,7 @@ public class ProtobufRpcEngine implements RpcEngine {
/**
* This constructor takes a connectionId, instead of creating a new one.
*/
-private Invoker(Class protocol, Client.ConnectionId connId,
+protected Invoker(Class protocol, Client.ConnectionId connId,
Configuration conf, SocketFactory factory) {
this.remoteId = connId;
this.client = CLIENTS.getClient(conf, factory, RpcWritable.Buffer.class);
@@ -225,8 +225,6 @@ public class ProtobufRpcEngine implements RpcEngine {
traceScope =
tracer.newScope(RpcClientUtil.methodToTraceString(method));
}
- RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
-
if (LOG.isTraceEnabled()) {
LOG.trace(Thread.currentThread().getId() + ": Call -> " +
remoteId + ": " + method.getName() +
@@ -238,7 +236,7 @@ public class ProtobufRpcEngine implements RpcEngine {
final RpcWritable.Buffer val;
try {
val = (RpcWritable.Buffer) client.call(RPC.RpcKind.RPC_PROTOCOL_BUFFER,
-new RpcProtobufRequest(rpcRequestHeader, theRequest), remoteId,
+constructRpcRequest(method, theRequest), remoteId,
fallbackToSimpleAuth, alignmentContext);
} catch (Throwable e) {
@@ -283,6 +281,11 @@ public class ProtobufRpcEngine implements RpcEngine {
}
}
+protected Writable constructRpcRequest(Method method, Message theRequest) {
+ RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
+ return new RpcProtobufRequest(rpcRequestHeader, theRequest);
+}
+
private Message getReturnMessage(final Method method,
final RpcWritable.Buffer buf) throws ServiceException {
Message prototype = null;
@@ -332,6 +335,14 @@ public class ProtobufRpcEngine implements RpcEngine {
public ConnectionId getConnectionId() {
return remoteId;
}
+
+protected long getClientProtocolVersion() {
+ return clientProtocolVersion;
+}
+
+protected String getProtocolName() {
+ return protocolName;
+}
}
@VisibleForTesting
@@ -518,6 +529,13 @@ public class ProtobufRpcEngine implements RpcEngine {
String declaringClassProtoName =
rpcRequest.getDeclaringClassProtocolName();
long clientVersion = rpcRequest.getClientProtocolVersion();
+return call(server, connectionProtocolName, request, receiveTime,
+methodName, declaringClassProtoName, clientVersion);
+ }
+
+ protected Writable call(RPC.Server server, String connectionProtocolName,
+ RpcWritable.Buffer request, long receiveTime, String methodName,
+ String declaringClassProtoName, long clientVersion) throws Exception
[hadoop] branch trunk updated: HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed by Hector Chaverri.
This is an automated email from the ASF dual-hosted git repository.
shv pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/hadoop.git
The following commit(s) were added to refs/heads/trunk by this push:
new f40e3eb HADOOP-17680. Allow ProtobufRpcEngine to be extensible
(#2905) Contributed by Hector Chaverri.
f40e3eb is described below
commit f40e3eb0590f85bb42d2471992bf5d524628fdd6
Author: hchaverr
AuthorDate: Thu May 6 16:40:45 2021 -0700
HADOOP-17680. Allow ProtobufRpcEngine to be extensible (#2905) Contributed
by Hector Chaverri.
---
.../org/apache/hadoop/ipc/ProtobufRpcEngine.java | 30 +-
.../org/apache/hadoop/ipc/ProtobufRpcEngine2.java | 30 +-
2 files changed, 48 insertions(+), 12 deletions(-)
diff --git
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
index a1500d5..882cc14 100644
---
a/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
+++
b/hadoop-common-project/hadoop-common/src/main/java/org/apache/hadoop/ipc/ProtobufRpcEngine.java
@@ -122,7 +122,7 @@ public class ProtobufRpcEngine implements RpcEngine {
factory)), false);
}
- private static class Invoker implements RpcInvocationHandler {
+ protected static class Invoker implements RpcInvocationHandler {
private final Map returnTypes =
new ConcurrentHashMap();
private boolean isClosed = false;
@@ -133,7 +133,7 @@ public class ProtobufRpcEngine implements RpcEngine {
private AtomicBoolean fallbackToSimpleAuth;
private AlignmentContext alignmentContext;
-private Invoker(Class protocol, InetSocketAddress addr,
+protected Invoker(Class protocol, InetSocketAddress addr,
UserGroupInformation ticket, Configuration conf, SocketFactory factory,
int rpcTimeout, RetryPolicy connectionRetryPolicy,
AtomicBoolean fallbackToSimpleAuth, AlignmentContext alignmentContext)
@@ -148,7 +148,7 @@ public class ProtobufRpcEngine implements RpcEngine {
/**
* This constructor takes a connectionId, instead of creating a new one.
*/
-private Invoker(Class protocol, Client.ConnectionId connId,
+protected Invoker(Class protocol, Client.ConnectionId connId,
Configuration conf, SocketFactory factory) {
this.remoteId = connId;
this.client = CLIENTS.getClient(conf, factory, RpcWritable.Buffer.class);
@@ -225,8 +225,6 @@ public class ProtobufRpcEngine implements RpcEngine {
traceScope =
tracer.newScope(RpcClientUtil.methodToTraceString(method));
}
- RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
-
if (LOG.isTraceEnabled()) {
LOG.trace(Thread.currentThread().getId() + ": Call -> " +
remoteId + ": " + method.getName() +
@@ -238,7 +236,7 @@ public class ProtobufRpcEngine implements RpcEngine {
final RpcWritable.Buffer val;
try {
val = (RpcWritable.Buffer) client.call(RPC.RpcKind.RPC_PROTOCOL_BUFFER,
-new RpcProtobufRequest(rpcRequestHeader, theRequest), remoteId,
+constructRpcRequest(method, theRequest), remoteId,
fallbackToSimpleAuth, alignmentContext);
} catch (Throwable e) {
@@ -283,6 +281,11 @@ public class ProtobufRpcEngine implements RpcEngine {
}
}
+protected Writable constructRpcRequest(Method method, Message theRequest) {
+ RequestHeaderProto rpcRequestHeader = constructRpcRequestHeader(method);
+ return new RpcProtobufRequest(rpcRequestHeader, theRequest);
+}
+
private Message getReturnMessage(final Method method,
final RpcWritable.Buffer buf) throws ServiceException {
Message prototype = null;
@@ -332,6 +335,14 @@ public class ProtobufRpcEngine implements RpcEngine {
public ConnectionId getConnectionId() {
return remoteId;
}
+
+protected long getClientProtocolVersion() {
+ return clientProtocolVersion;
+}
+
+protected String getProtocolName() {
+ return protocolName;
+}
}
@VisibleForTesting
@@ -518,6 +529,13 @@ public class ProtobufRpcEngine implements RpcEngine {
String declaringClassProtoName =
rpcRequest.getDeclaringClassProtocolName();
long clientVersion = rpcRequest.getClientProtocolVersion();
+return call(server, connectionProtocolName, request, receiveTime,
+methodName, declaringClassProtoName, clientVersion);
+ }
+
+ protected Writable call(RPC.Server server, String connectionProtocolName,
+ RpcWritable.Buffer request, long receiveTime, String methodName,
+ String declaringClassProtoName, long clientVersion) throws Exception
{
if (server.verbose)
LOG.info("Call: connectionProtocolName=" + co
[hadoop] branch branch-3.1 updated: YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960)
This is an automated email from the ASF dual-hosted git repository. tasanuma pushed a commit to branch branch-3.1 in repository https://gitbox.apache.org/repos/asf/hadoop.git The following commit(s) were added to refs/heads/branch-3.1 by this push: new badb6b3 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) badb6b3 is described below commit badb6b3d0dc3e25c8baed61e858a6d1ece9e14c8 Author: Akira Ajisaka AuthorDate: Thu May 6 23:37:45 2021 +0900 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) Reviewed-by: Viraj Jasani Reviewed-by: Bilwa S T Signed-off-by: Takanobu Asanuma (cherry picked from commit 7cb7b8adc137239682e6189d1663b6b868757938) --- .../hadoop-yarn-server-timelineservice-hbase-tests/pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-client/pom.xml | 13 - .../hadoop-yarn-server-timelineservice/pom.xml | 13 - 3 files changed, 39 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml index 7d98913..809f89b 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml @@ -377,19 +377,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - org.apache.maven.plugins diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml index 2e29bf1..854db87 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml @@ -198,19 +198,6 @@ org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - -org.apache.maven.plugins maven-dependency-plugin diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml index e1876f2..2afda41 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml @@ -161,19 +161,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.2 updated (ab4e90c -> a5bb211)
This is an automated email from the ASF dual-hosted git repository. tasanuma pushed a change to branch branch-3.2 in repository https://gitbox.apache.org/repos/asf/hadoop.git. from ab4e90c HDFS-15652. Make block size from NNThroughputBenchmark configurable (#2416) add a5bb211 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) No new revisions were added by this update. Summary of changes: .../hadoop-yarn-server-timelineservice-hbase-tests/pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-client/pom.xml | 13 - .../hadoop-yarn-server-timelineservice/pom.xml | 13 - 3 files changed, 39 deletions(-) - To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch branch-3.3 updated: YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960)
This is an automated email from the ASF dual-hosted git repository. tasanuma pushed a commit to branch branch-3.3 in repository https://gitbox.apache.org/repos/asf/hadoop.git The following commit(s) were added to refs/heads/branch-3.3 by this push: new 2176552 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) 2176552 is described below commit 217655269a077d592306b993ce884878d1fb40e7 Author: Akira Ajisaka AuthorDate: Thu May 6 23:37:45 2021 +0900 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) Reviewed-by: Viraj Jasani Reviewed-by: Bilwa S T Signed-off-by: Takanobu Asanuma (cherry picked from commit 7cb7b8adc137239682e6189d1663b6b868757938) --- .../pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-tests/pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-client/pom.xml | 13 - .../hadoop-yarn-server-timelineservice/pom.xml | 13 - 4 files changed, 52 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml index c86bf44..97351b9 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml @@ -144,19 +144,6 @@ org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - -org.apache.maven.plugins maven-dependency-plugin diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml index 81d206b..171afe8 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml @@ -406,19 +406,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - org.apache.maven.plugins diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml index 7661a4b..a20321f 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml @@ -206,19 +206,6 @@ org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - -org.apache.maven.plugins maven-dependency-plugin diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml index fb33a52..ee1f80a 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml @@ -157,19 +157,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
[hadoop] branch trunk updated: YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960)
This is an automated email from the ASF dual-hosted git repository. tasanuma pushed a commit to branch trunk in repository https://gitbox.apache.org/repos/asf/hadoop.git The following commit(s) were added to refs/heads/trunk by this push: new 7cb7b8a YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) 7cb7b8a is described below commit 7cb7b8adc137239682e6189d1663b6b868757938 Author: Akira Ajisaka AuthorDate: Thu May 6 23:37:45 2021 +0900 YARN-10756. Remove additional junit 4.11 dependency from javadoc. (#2960) Reviewed-by: Viraj Jasani Reviewed-by: Bilwa S T Signed-off-by: Takanobu Asanuma --- .../pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-tests/pom.xml | 13 - .../hadoop-yarn-server-timelineservice-hbase-client/pom.xml | 13 - .../hadoop-yarn-server-timelineservice/pom.xml | 13 - 4 files changed, 52 deletions(-) diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml index c51b5a2..ccd1b13 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-documentstore/pom.xml @@ -144,19 +144,6 @@ org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - -org.apache.maven.plugins maven-dependency-plugin diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml index 12b0112..d8cf6de 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase-tests/pom.xml @@ -406,19 +406,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - org.apache.maven.plugins diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml index 355a269..6207a2d 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice-hbase/hadoop-yarn-server-timelineservice-hbase-client/pom.xml @@ -206,19 +206,6 @@ org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - -org.apache.maven.plugins maven-dependency-plugin diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml index cb4f097..65af3af 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-timelineservice/pom.xml @@ -157,19 +157,6 @@ - -org.apache.maven.plugins -maven-javadoc-plugin - - - - junit - junit - 4.11 - - - - - To unsubscribe, e-mail: common-commits-unsubscr...@hadoop.apache.org For additional commands, e-mail: common-commits-h...@hadoop.apache.org
