Fix a failed test.

Author: shunping

sdks/python/apache_beam/runners/interactive/interactive_beam_test.py

@@ -395,7 +395,12 @@ def test_cleanup_by_a_pipeline(self):
     # Pipeline association is cleaned up.
     self.assertNotIn(p, self.clusters.pipelines)
     self.assertNotIn(p, dcm.pipelines)
-    self.assertEqual(options.view_as(FlinkRunnerOptions).flink_master, '[auto]')
+    # The internal option in the pipeline is overwritten.
+    self.assertEqual(
+        p.options.view_as(FlinkRunnerOptions).flink_master, '[auto]')
+    # The original option is unchanged.
+    self.assertEqual(
+        options.view_as(FlinkRunnerOptions).flink_master, meta.master_url)
     # The cluster is unknown now.
     self.assertNotIn(meta, self.clusters.dataproc_cluster_managers)
     self.assertNotIn(meta.master_url, self.clusters.master_urls)