commit | 10678052ca227b23e3b5c15f8613aed0dd3d59b2 | [log] [tgz] |
---|---|---|
author | taegeonum <taegeonum@gmail.com> | Fri Mar 31 16:29:36 2017 +0900 |
committer | Sergiy Matusevych <motus@apache.org> | Fri Mar 31 10:10:17 2017 -0700 |
tree | eb142b821b2007e365012c6f5eec2fbc8f92e420 | |
parent | 8657733fd20d370eb83aaba0d49f9c01e04d4112 [diff] |
[REEF-1762] Fix the expected number of messages in NetworkServiceTest.testMultithreadedSharedConnMessagingNetworkServiceRate JIRA: [REEF-1762](https://issues.apache.org/jira/browse/REEF-1762) Pull request: This closes #1281
diff --git a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java index 373fd31..86acc86 100644 --- a/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java +++ b/lang/java/reef-io/src/test/java/org/apache/reef/io/network/NetworkServiceTest.java
@@ -386,7 +386,7 @@ final Injector injectorNs2 = injector2.forkInjector(); injectorNs2.bindVolatileParameter(NetworkServiceParameters.NetworkServiceHandler.class, - new MessageHandler<String>(name2, monitor, numMessages)); + new MessageHandler<String>(name2, monitor, totalNumMessages)); final NetworkService<String> ns2 = injectorNs2.getInstance(NetworkService.class); final Injector injectorNs1 = injector2.forkInjector();