diff --git a/sdks/python/apache_beam/runners/interactive/interactive_beam.py b/sdks/python/apache_beam/runners/interactive/interactive_beam.py
index 0ae015dbf023..5eab4893985a 100644
--- a/sdks/python/apache_beam/runners/interactive/interactive_beam.py
+++ b/sdks/python/apache_beam/runners/interactive/interactive_beam.py
@@ -420,10 +420,6 @@ def cleanup(
           self.master_urls.pop(master_url, None)
           self.master_urls_to_pipelines.pop(master_url, None)
           self.dataproc_cluster_managers.pop(str(id(pipeline)), None)
-      else:
-        _LOGGER.error(
-            'No cluster_manager is associated with the provided '
-            'pipeline!')
     else:
       cluster_manager_identifiers = set()
       for cluster_manager in self.dataproc_cluster_managers.values():
diff --git a/sdks/python/apache_beam/runners/interactive/interactive_beam_test.py b/sdks/python/apache_beam/runners/interactive/interactive_beam_test.py
index b438980fab1a..b14848c0afc6 100644
--- a/sdks/python/apache_beam/runners/interactive/interactive_beam_test.py
+++ b/sdks/python/apache_beam/runners/interactive/interactive_beam_test.py
@@ -311,19 +311,6 @@ def test_clusters_describe(self):
     self.assertEqual('test-project', clusters.describe()[None] \
     ['cluster_metadata'].project_id)
 
-  def test_clusters_cleanup_cluster_manager_not_found(self):
-    clusters = ib.Clusters()
-    p = beam.Pipeline(
-        options=PipelineOptions(
-            project='test-project',
-            region='test-region',
-        ))
-    from apache_beam.runners.interactive.interactive_beam import _LOGGER
-    with self.assertLogs(_LOGGER, level='ERROR') as context_manager:
-      clusters.cleanup(p)
-      self.assertTrue(
-          'No cluster_manager is associated' in context_manager.output[0])
-
   @patch(
       'apache_beam.runners.interactive.dataproc.dataproc_cluster_manager.'
       'DataprocClusterManager.get_master_url',