kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1400; transient unit test failure in SocketServerTest; patched by Neha Narkhede; reviewed by Guozhang and Jun Rao
Date Tue, 29 Apr 2014 17:33:16 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk bbb357c17 -> 3de97c7c4


kafka-1400; transient unit test failure in SocketServerTest; patched by Neha Narkhede; reviewed
by Guozhang and Jun Rao


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

Branch: refs/heads/trunk
Commit: 3de97c7c4039783f4a5d1db9de48f6778123a953
Parents: bbb357c
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Tue Apr 29 10:33:00 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Apr 29 10:33:00 2014 -0700

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/3de97c7c/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 42f6f96..62fb02c 100644
--- a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
+++ b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
@@ -126,7 +126,7 @@ class SocketServerTest extends JUnitSuite {
       "Socket key should be available for reads")
   }
 
-  @Test(expected = classOf[SocketException])
+  @Test(expected = classOf[IOException])
   def testSocketsCloseOnShutdown() {
     // open a connection and then shutdown the server
     val socket = connect()


Mime
View raw message