This is an automated email from the ASF dual-hosted git repository.
dajac pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new f2aa0c4 MINOR: Disable
SocketServerTest.closingChannelWithBufferedReceives and
SocketServerTest.remoteCloseWithoutBufferedReceives (#11960)
f2aa0c4 is described below
commit f2aa0c439cb0045e6505d1bbdf8bbbb731a253ca
Author: David Jacot <[email protected]>
AuthorDate: Tue Mar 29 14:31:12 2022 +0200
MINOR: Disable SocketServerTest.closingChannelWithBufferedReceives and
SocketServerTest.remoteCloseWithoutBufferedReceives (#11960)
This reverts commit d706d6cac4622153973d131417e809ee57c60de0.
Reviewers: Bruno Cadonna <[email protected]>
---
core/src/test/scala/unit/kafka/network/SocketServerTest.scala | 2 ++
1 file changed, 2 insertions(+)
diff --git a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
index 849646c..33d15ad1 100644
--- a/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
+++ b/core/src/test/scala/unit/kafka/network/SocketServerTest.scala
@@ -1389,6 +1389,7 @@ class SocketServerTest {
* buffered receive.
*/
@Test
+ @Disabled // TODO: re-enabled until KAFKA-13735 is fixed
def remoteCloseWithoutBufferedReceives(): Unit = {
verifyRemoteCloseWithBufferedReceives(numComplete = 0, hasIncomplete =
false)
}
@@ -1426,6 +1427,7 @@ class SocketServerTest {
* The channel must be closed after pending receives are processed.
*/
@Test
+ @Disabled // TODO: re-enable after KAFKA-13736 is fixed
def closingChannelWithBufferedReceives(): Unit = {
verifyRemoteCloseWithBufferedReceives(numComplete = 3, hasIncomplete =
false, makeClosing = true)
}