diff --git a/spark-client/src/test/java/org/apache/hive/spark/client/rpc/TestRpc.java b/spark-client/src/test/java/org/apache/hive/spark/client/rpc/TestRpc.java index fafdff77ea..5653e4d0c4 100644 --- a/spark-client/src/test/java/org/apache/hive/spark/client/rpc/TestRpc.java +++ b/spark-client/src/test/java/org/apache/hive/spark/client/rpc/TestRpc.java @@ -197,8 +197,10 @@ public void testServerPort() throws Exception { try { autoClose(new RpcServer(config)); assertTrue("Invalid port range should throw an exception", false); // Should not reach here - } catch(IOException e) { - assertEquals("Incorrect RPC server port configuration for HiveServer2", e.getMessage()); + } catch(IllegalArgumentException e) { + assertEquals( + "Malformed configuration value for " + HiveConf.ConfVars.SPARK_RPC_SERVER_PORT.varname, + e.getMessage()); } // Retry logic