diff --git a/syncmaster/tests/test_integration/test_run_transfer/conftest.py b/syncmaster/tests/test_integration/test_run_transfer/conftest.py index 32cd1cd5..6a0075fd 100644 --- a/syncmaster/tests/test_integration/test_run_transfer/conftest.py +++ b/syncmaster/tests/test_integration/test_run_transfer/conftest.py @@ -313,7 +313,7 @@ def hdfs_file_df_connection(spark, hdfs_server): from onetl.connection import SparkHDFS return SparkHDFS( - cluster="rnd-dwh", + cluster="test-hive", host=hdfs_server.host, ipc_port=hdfs_server.ipc_port, spark=spark,