Github user koeninger commented on a diff in the pull request:
https://github.com/apache/spark/pull/22223#discussion_r212691455
--- Diff: docs/configuration.md ---
@@ -1925,6 +1925,14 @@ showDF(properties, numRows = 200, truncate = FALSE)
first batch when the backpressure mechanism is enabled.
</td>
</tr>
+<tr>
+
<td><code>spark.streaming.backpressure.fixedMinMessagePerPartition</code></td>
--- End diff --
This only applies to Kafka. Why not namespace it under
spark.streaming.kafka?
What does the word "fixed" add to the explanation?
There's already a maxRatePerPartition, why not minRatePerPartition?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
