diff --git a/splunklib/searchcommands/internals.py b/splunklib/searchcommands/internals.py
index 9a2a4e9e2..d421d27be 100644
--- a/splunklib/searchcommands/internals.py
+++ b/splunklib/searchcommands/internals.py
@@ -750,6 +750,11 @@ def flush(self, finished=None, partial=None):
         RecordWriter.flush(self, finished, partial)  # validates arguments and the state of this instance
         inspector = self._inspector
 
+        if partial:
+            # Don't flush partial chunks, since the SCP v2 protocol does not
+            # provide a way to send partial chunks yet.
+            return
+
         if self._flushed is False:
 
             self._total_record_count += self._record_count
diff --git a/splunklib/searchcommands/search_command.py b/splunklib/searchcommands/search_command.py
index b2835eec6..bb75ecefc 100644
--- a/splunklib/searchcommands/search_command.py
+++ b/splunklib/searchcommands/search_command.py
@@ -398,7 +398,7 @@ def flush(self):
         :return: :const:`None`
 
         """
-        self._record_writer.flush(partial=True)
+        self._record_writer.flush(finished=False)
 
     def prepare(self):
         """ Prepare for execution.