wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-17 11:32:33 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Streaming] Fix run_streaming_queue_test (#6538)

Browse Source
This commit is contained in:
wanxing
2019-12-20 11:10:01 +08:00
committed by Hao Chen
parent af9f76359a
commit 97e8afacd3
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
streaming/src/test/queue_tests_base.h
+1 -1
View File
@@ -259,7 +259,7 @@ class StreamingQueueTestBase : public ::testing::TestWithParam<uint64_t> {
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