diff --git a/src/ray/gcs/pubsub/gcs_pub_sub.h b/src/ray/gcs/pubsub/gcs_pub_sub.h index e5b3c1509..b871a02b1 100644 --- a/src/ray/gcs/pubsub/gcs_pub_sub.h +++ b/src/ray/gcs/pubsub/gcs_pub_sub.h @@ -45,7 +45,7 @@ class GcsPubSub { using Callback = std::function; explicit GcsPubSub(std::shared_ptr redis_client) - : redis_client_(redis_client) {} + : redis_client_(redis_client), total_commands_queued_(0) {} virtual ~GcsPubSub() = default;