Fix bug

zanmato1984 · Jan 12, 2024 · ed1dd4b · ed1dd4b
1 parent 04f3d19
commit ed1dd4b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/cpp/src/arrow/acero/swiss_join.cc b/cpp/src/arrow/acero/swiss_join.cc
@@ -1578,7 +1578,7 @@ Status JoinResultMaterialize::AppendProbeOnly(const ExecBatch& key_and_payload,
                                               int num_rows_to_append,
                                               const uint16_t* row_ids,
                                               int* num_rows_appended) {
-  if (num_rows_to_append) {
+  if (num_rows_to_append == 0) {
     *num_rows_appended = 0;
     return Status::OK();
   }
@@ -1608,7 +1608,7 @@ Status JoinResultMaterialize::AppendBuildOnly(int num_rows_to_append,
                                               const uint32_t* key_ids,
                                               const uint32_t* payload_ids,
                                               int* num_rows_appended) {
-  if (num_rows_to_append) {
+  if (num_rows_to_append == 0) {
     *num_rows_appended = 0;
     return Status::OK();
   }
@@ -1639,7 +1639,7 @@ Status JoinResultMaterialize::Append(const ExecBatch& key_and_payload,
                                      int num_rows_to_append, const uint16_t* row_ids,
                                      const uint32_t* key_ids, const uint32_t* payload_ids,
                                      int* num_rows_appended) {
-  if (num_rows_to_append) {
+  if (num_rows_to_append == 0) {
     *num_rows_appended = 0;
     return Status::OK();
   }