From 97e8afacd32d9ecdac4820ad379d725359e7e635 Mon Sep 17 00:00:00 2001 From: wanxing Date: Fri, 20 Dec 2019 11:10:01 +0800 Subject: [PATCH] [Streaming] Fix run_streaming_queue_test (#6538) --- streaming/src/test/queue_tests_base.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/streaming/src/test/queue_tests_base.h b/streaming/src/test/queue_tests_base.h index 4d70af01c..818b7b852 100644 --- a/streaming/src/test/queue_tests_base.h +++ b/streaming/src/test/queue_tests_base.h @@ -259,7 +259,7 @@ class StreamingQueueTestBase : public ::testing::TestWithParam { STREAMING_LOG(INFO) << "Sub process: writer."; CoreWorker driver(WorkerType::DRIVER, Language::PYTHON, raylet_store_socket_names_[0], - raylet_socket_names_[0], NextJobId(), gcs_options_, "", "", + raylet_socket_names_[0], NextJobId(), gcs_options_, "", "127.0.0.1", node_manager_port_, nullptr); // Create writer and reader actors