Merge pull request #11256 from natefoo/pulsar-param-testdebug

[21.01] Copy Pulsar params so we don't modify the actual param dict in place
This commit is contained in:
John Chilton
2021-01-29 10:58:01 -05:00
committed by GitHub
+1 -1
View File
@@ -371,7 +371,7 @@ class PulsarJobRunner(AsynchronousJobRunner):
metadata_directory = os.path.join(job_wrapper.working_directory, "metadata")
dest_params = job_destination.params
remote_pulsar_app_config = dest_params.get("pulsar_app_config", {})
remote_pulsar_app_config = dest_params.get("pulsar_app_config", {}).copy()
if "pulsar_app_config_path" in dest_params:
pulsar_app_config_path = dest_params["pulsar_app_config_path"]
with open(pulsar_app_config_path, "r") as fh: