diff --git a/core/src/main/java/org/elasticsearch/action/admin/cluster/node/liveness/LivenessResponse.java b/core/src/main/java/org/elasticsearch/action/admin/cluster/node/liveness/LivenessResponse.java
index f7ecfbaed4b..b0a53190bf0 100644
--- a/core/src/main/java/org/elasticsearch/action/admin/cluster/node/liveness/LivenessResponse.java
+++ b/core/src/main/java/org/elasticsearch/action/admin/cluster/node/liveness/LivenessResponse.java
@@ -48,7 +48,7 @@ public final class LivenessResponse extends ActionResponse {
     public void readFrom(StreamInput in) throws IOException {
         super.readFrom(in);
         clusterName = ClusterName.readClusterName(in);
-        in.readOptionalWritable(DiscoveryNode::new);
+        node = in.readOptionalWriteable(DiscoveryNode::new);
     }
 
     @Override
diff --git a/core/src/main/java/org/elasticsearch/transport/ConnectTransportException.java b/core/src/main/java/org/elasticsearch/transport/ConnectTransportException.java
index cd3bf87a169..e867acedef0 100644
--- a/core/src/main/java/org/elasticsearch/transport/ConnectTransportException.java
+++ b/core/src/main/java/org/elasticsearch/transport/ConnectTransportException.java
@@ -51,7 +51,7 @@ public class ConnectTransportException extends ActionTransportException {
 
     public ConnectTransportException(StreamInput in) throws IOException {
         super(in);
-        node = in.readOptionalWritable(DiscoveryNode::new);
+        node = in.readOptionalWriteable(DiscoveryNode::new);
     }
 
     @Override