diff --git a/dataproc/create_cluster_and_submit_job.py b/dataproc/create_cluster_and_submit_job.py
index 0cf58ad74c5..9275f1f9e8e 100644
--- a/dataproc/create_cluster_and_submit_job.py
+++ b/dataproc/create_cluster_and_submit_job.py
@@ -224,7 +224,7 @@ def main(project_id, zone, cluster_name, bucket_name, pyspark_file=None):
     parser.add_argument(
         '--zone', help='Region to create clusters in', required=True)
     parser.add_argument(
-        '--cluster_name', help='Region to create clusters in', required=True)
+        '--cluster_name', help='Name of the cluster to create', required=True)
     parser.add_argument(
         '--gcs_bucket', help='Bucket to upload Pyspark file to', required=True)
     parser.add_argument(