impala-reviews mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dan Hecht (Code Review)" <>
Subject [Impala-ASF-CR] IMPALA-4856: Port data stream service to KRPC
Date Wed, 08 Nov 2017 01:32:58 GMT
Dan Hecht has posted comments on this change. ( )

Change subject: IMPALA-4856: Port data stream service to KRPC

Patch Set 9:

File be/src/runtime/
PS9, Line 62:       min(FLAGS_datastream_service_num_deserialization_threads, CpuInfo::num_cores()),
why disallow the setting of this greater than num_cores? Given that it takes locks, there
could be some benefit to doing so, right?
File be/src/runtime/
PS9, Line 67: data
the resources
PS9, Line 195: cur_batch_
PS9, Line 225: DCHECK
shoudl we also DCHECK that num_pending_enqueue_ == 0 (otherwise, we could have acquired the
lock while it was dropped for deserialization and there is still a row batch)?
PS9, Line 248: batch_queue_.pop_front();
this is part of the same operation as line 244 (both are adjusting the queue state), so mind
moving it to be adjacent?
PS9, Line 252:     // Don't hold lock when calling EnqueueDeserializeTask() as it may block.
how about moving this to line 250 now that it's that scope that drops the lock. Also, it's
important that this happens after batch_queue_.pop_front(), right? maybe note that.

To view, visit
To unsubscribe, visit

Gerrit-Project: Impala-ASF
Gerrit-Branch: master
Gerrit-MessageType: comment
Gerrit-Change-Id: Ic0b8c1e50678da66ab1547d16530f88b323ed8c1
Gerrit-Change-Number: 8023
Gerrit-PatchSet: 9
Gerrit-Owner: Michael Ho <>
Gerrit-Reviewer: Dan Hecht <>
Gerrit-Reviewer: Michael Ho <>
Gerrit-Reviewer: Mostafa Mokhtar <>
Gerrit-Reviewer: Sailesh Mukil <>
Gerrit-Comment-Date: Wed, 08 Nov 2017 01:32:58 +0000
Gerrit-HasComments: Yes

  • Unnamed multipart/alternative (inline, 8-Bit, 0 bytes)
View raw message