diff options
Diffstat (limited to 'contrib/native/client/example/querySubmitter.cpp')
| -rw-r--r-- | contrib/native/client/example/querySubmitter.cpp | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/contrib/native/client/example/querySubmitter.cpp b/contrib/native/client/example/querySubmitter.cpp index 85e89e0c2..960ff4f44 100644 --- a/contrib/native/client/example/querySubmitter.cpp +++ b/contrib/native/client/example/querySubmitter.cpp @@ -82,6 +82,7 @@ Drill::status_t QueryResultsListener(void* ctx, Drill::RecordBatch* b, Drill::Dr } }else{ std::cout << "Query Complete." << std::endl; + return Drill::QRY_SUCCESS; } }else{ assert(b==NULL); @@ -368,7 +369,7 @@ int main(int argc, char* argv[]) { row=0; Drill::RecordIterator* pRecIter=*recordIterIter; Drill::FieldDefPtr fields= pRecIter->getColDefs(); - while((ret=pRecIter->next()), ret==Drill::QRY_SUCCESS || ret==Drill::QRY_SUCCESS_WITH_INFO){ + while((ret=pRecIter->next()), (ret==Drill::QRY_SUCCESS || ret==Drill::QRY_SUCCESS_WITH_INFO) && !pRecIter->hasError()){ fields = pRecIter->getColDefs(); row++; if( (ret==Drill::QRY_SUCCESS_WITH_INFO && pRecIter->hasSchemaChanged() )|| ( row%100==1)){ |