kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject kafka git commit: kafka-1400; transient unit test failure in SocketServerTest; patched by Jun Rao; reviewed by Ewen Cheslack-Postava and Jiangjie Qin
Date Fri, 27 Feb 2015 02:02:25 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk ef252dea7 -> e39373d16


kafka-1400; transient unit test failure in SocketServerTest; patched by Jun Rao; reviewed
by Ewen Cheslack-Postava and Jiangjie Qin


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/e39373d1
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/e39373d1
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/e39373d1

Branch: refs/heads/trunk
Commit: e39373d16bc208128d5d6cf0e0672f27f35e3b20
Parents: ef252de
Author: Jun Rao <junrao@gmail.com>
Authored: Thu Feb 26 18:02:19 2015 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Feb 26 18:02:19 2015 -0800

----------------------------------------------------------------------
 core/src/test/scala/unit/kafka/network/SocketServerTest.scala | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/e39373d1/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
index 78b431f..0af23ab 100644
--- a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
+++ b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
@@ -139,8 +139,11 @@ class SocketServerTest extends JUnitSuite {
     processRequest(server.requestChannel)
     // then shutdown the server
     server.shutdown()
+
+    val largeChunkOfBytes = new Array[Byte](1000000)
     // doing a subsequent send should throw an exception as the connection should be closed.
-    sendRequest(socket, 0, bytes)
+    // send a large chunk of bytes to trigger a socket flush
+    sendRequest(socket, 0, largeChunkOfBytes)
   }
 
   @Test


Mime
View raw message