You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@quickstep.apache.org by zu...@apache.org on 2017/03/13 20:56:03 UTC
[54/60] [abbrv] incubator-quickstep git commit: Fixed the test hang
due to changes in Shiftboss registration process.
Fixed the test hang due to changes in Shiftboss registration process.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/42bf6b83
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/42bf6b83
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/42bf6b83
Branch: refs/heads/dist-patch
Commit: 42bf6b83691d943382a3724b252e2219723ed6f3
Parents: 9a991bb
Author: Zuyu Zhang <zu...@apache.org>
Authored: Sun Mar 12 13:16:07 2017 -0700
Committer: Zuyu Zhang <zu...@apache.org>
Committed: Sun Mar 12 13:16:07 2017 -0700
----------------------------------------------------------------------
cli/tests/DistributedCommandExecutorTestRunner.cpp | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/42bf6b83/cli/tests/DistributedCommandExecutorTestRunner.cpp
----------------------------------------------------------------------
diff --git a/cli/tests/DistributedCommandExecutorTestRunner.cpp b/cli/tests/DistributedCommandExecutorTestRunner.cpp
index 0df488e..a029975 100644
--- a/cli/tests/DistributedCommandExecutorTestRunner.cpp
+++ b/cli/tests/DistributedCommandExecutorTestRunner.cpp
@@ -99,6 +99,7 @@ DistributedCommandExecutorTestRunner::DistributedCommandExecutorTestRunner(const
// could receive a registration message from the latter.
foreman_ = make_unique<ForemanDistributed>(*block_locator_, &bus_, test_database_loader_->catalog_database(),
nullptr /* query_processor */);
+ foreman_->start();
// We don't use the NUMA aware version of worker code.
const vector<numa_node_id> numa_nodes(1 /* Number of worker threads per instance */,
@@ -123,8 +124,6 @@ DistributedCommandExecutorTestRunner::DistributedCommandExecutorTestRunner(const
make_unique<Shiftboss>(&bus_, &bus_local_, storage_manager_.get(), worker_directory_.get(),
storage_manager_->hdfs());
- foreman_->start();
-
data_exchanger_.start();
shiftboss_->start();
worker_->start();