diff --git a/tests/src/integration/tests/test_heartbeat.cpp b/tests/src/integration/tests/test_heartbeat.cpp
index 6cdc59ee..de51f716 100644
--- a/tests/src/integration/tests/test_heartbeat.cpp
+++ b/tests/src/integration/tests/test_heartbeat.cpp
@@ -78,7 +78,7 @@ CASSANDRA_INTEGRATION_TEST_F(HeartbeatTests, HeartbeatDisabled) {
  *
  * @since 2.1.0
  * @jira_ticket CPP-152
- * @expected_result Heartbeat failure on node 2; node 2 connection is lost.
+ * @expected_result Heartbeat failure on node 2 is logged.
  */
 CASSANDRA_INTEGRATION_TEST_F(HeartbeatTests, HeartbeatFailed) {
   CHECK_FAILURE;
@@ -88,17 +88,16 @@ CASSANDRA_INTEGRATION_TEST_F(HeartbeatTests, HeartbeatFailed) {
       default_cluster().with_connection_heartbeat_interval(1).with_connection_idle_timeout(5);
   connect(cluster);
 
-  cass_uint64_t initial_connections = session_.metrics().stats.total_connections;
+  std::string paused_node_ip = ccm_->get_ip_prefix() + "2";
+  Statement statement(SELECT_ALL_SYSTEM_LOCAL_CQL);
+  statement.set_host(paused_node_ip, 9042);
+  session_.execute(statement);
+
   pause_node(2);
   start_timer();
 
-  CassMetrics metrics = session_.metrics();
-  while (metrics.stats.total_connections >= initial_connections &&
-         elapsed_time() < 60000) {
-    session_.execute_async(SELECT_ALL_SYSTEM_LOCAL_CQL); // Simply execute statements ignore any
-                                                         // error that can occur from paused node
-    metrics = session_.metrics();
+  while (logger_.count() == 0 && elapsed_time() < 60000) {
+    msleep(100);
   }
-  EXPECT_LT(metrics.stats.total_connections, initial_connections);
   EXPECT_GE(logger_.count(), 1u);
 }