This is an automated email from the ASF dual-hosted git repository.

mridulm80 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/spark.git


The following commit(s) were added to refs/heads/master by this push:
     new b8e2186  [SPARK-36483][CORE][TESTS] Fix intermittent test failures at 
Netty 4.1.52+
b8e2186 is described below

commit b8e2186fe13d609a777da9bf68fa31ea38da50fe
Author: Min Shen <[email protected]>
AuthorDate: Thu Aug 12 20:15:09 2021 -0500

    [SPARK-36483][CORE][TESTS] Fix intermittent test failures at Netty 4.1.52+
    
    ### What changes were proposed in this pull request?
    
    Fix an intermittent test failure due to Netty dependency version bump.
    Starting from Netty 4.1.52, its AbstractChannel will throw a new 
`StacklessClosedChannelException` for channel closed exception.
    A hardcoded list of Strings to match for channel closed exception in 
`RPCIntegrationSuite` was not updated, thus leading to the intermittent test 
failure reported in #33613
    
    ### Why are the changes needed?
    
    Fix intermittent test failure
    
    ### Does this PR introduce _any_ user-facing change?
    
    No
    
    ### How was this patch tested?
    
    Closes #33713 from Victsm/SPARK-36378-followup.
    
    Authored-by: Min Shen <[email protected]>
    Signed-off-by: Mridul Muralidharan <mridul<at>gmail.com>
---
 .../src/test/java/org/apache/spark/network/RpcIntegrationSuite.java      | 1 +
 1 file changed, 1 insertion(+)

diff --git 
a/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
 
b/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
index 3f5e33cb..f749f89 100644
--- 
a/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
+++ 
b/common/network-common/src/test/java/org/apache/spark/network/RpcIntegrationSuite.java
@@ -384,6 +384,7 @@ public class RpcIntegrationSuite {
         "closed",
         "Connection reset",
         "java.nio.channels.ClosedChannelException",
+        "io.netty.channel.StacklessClosedChannelException",
         "java.io.IOException: Broken pipe"
     );
     Set<String> containsAndClosed = Sets.newHashSet(expectedError);

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to