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 2016/11/27 19:43:21 UTC
[1/2] incubator-quickstep git commit: A better debug log for worker.
Repository: incubator-quickstep
Updated Branches:
refs/heads/master a31dde4ea -> 0b91b77a1
A better debug log for worker.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/45fe8bca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/45fe8bca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/45fe8bca
Branch: refs/heads/master
Commit: 45fe8bcace9617efd7d8d4541dbd8564394aea9f
Parents: a31dde4
Author: Zuyu Zhang <zu...@apache.org>
Authored: Thu Nov 17 15:10:03 2016 -0800
Committer: Zuyu Zhang <zu...@apache.org>
Committed: Sun Nov 27 10:38:38 2016 -0800
----------------------------------------------------------------------
query_execution/Worker.cpp | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/45fe8bca/query_execution/Worker.cpp
----------------------------------------------------------------------
diff --git a/query_execution/Worker.cpp b/query_execution/Worker.cpp
index 31eb964..ec6c503 100644
--- a/query_execution/Worker.cpp
+++ b/query_execution/Worker.cpp
@@ -107,7 +107,14 @@ void Worker::sendWorkOrderCompleteMessage(const tmb::client_id receiver,
static_cast<const void *>(proto_bytes), proto_length, message_type);
std::free(proto_bytes);
- DLOG(INFO) << "Worker sent WorkOrderCompleteMessage (typed '" << message_type
+ DLOG(INFO) << "Worker"
+#ifdef QUICKSTEP_DISTRIBUTED
+ << " in Shiftboss " << shiftboss_index_
+#endif // QUICKSTEP_DISTRIBUTED
+ << " sent "
+ << (message_type == kWorkOrderCompleteMessage ? "WorkOrderCompleteMessage"
+ : "RebuildWorkOrderCompleteMessage")
+ << " (typed '" << message_type
<< "') to Scheduler with TMB client ID " << receiver;
const tmb::MessageBus::SendStatus send_status =
QueryExecutionUtil::SendTMBMessage(
[2/2] incubator-quickstep git commit: A better debug log for Worker.
Posted by zu...@apache.org.
A better debug log for Worker.
Project: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/commit/0b91b77a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/tree/0b91b77a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-quickstep/diff/0b91b77a
Branch: refs/heads/master
Commit: 0b91b77a10aafe370727d3dc7694a0ff133946d9
Parents: 45fe8bc
Author: Zuyu Zhang <zu...@apache.org>
Authored: Sun Nov 27 11:42:51 2016 -0800
Committer: Zuyu Zhang <zu...@apache.org>
Committed: Sun Nov 27 11:42:51 2016 -0800
----------------------------------------------------------------------
query_execution/Worker.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-quickstep/blob/0b91b77a/query_execution/Worker.cpp
----------------------------------------------------------------------
diff --git a/query_execution/Worker.cpp b/query_execution/Worker.cpp
index ec6c503..9a548fd 100644
--- a/query_execution/Worker.cpp
+++ b/query_execution/Worker.cpp
@@ -107,7 +107,7 @@ void Worker::sendWorkOrderCompleteMessage(const tmb::client_id receiver,
static_cast<const void *>(proto_bytes), proto_length, message_type);
std::free(proto_bytes);
- DLOG(INFO) << "Worker"
+ DLOG(INFO) << "Worker " << worker_thread_index_
#ifdef QUICKSTEP_DISTRIBUTED
<< " in Shiftboss " << shiftboss_index_
#endif // QUICKSTEP_DISTRIBUTED