Skip to content

Commit c133787

Browse files
lw-linzsxwing
authored andcommitted
[SPARK-19330][DSTREAMS] Also show tooltip for successful batches
## What changes were proposed in this pull request? ### Before ![_streaming_before](https://cloud.githubusercontent.com/assets/15843379/22181462/1e45c20c-e0c8-11e6-831c-8bf69722a4ee.png) ### After ![_streaming_after](https://cloud.githubusercontent.com/assets/15843379/22181464/23f38a40-e0c8-11e6-9a87-e27b1ffb1935.png) ## How was this patch tested? Manually Author: Liwei Lin <lwlin7@gmail.com> Closes #16673 from lw-lin/streaming. (cherry picked from commit 40a4cfc) Signed-off-by: Shixiong Zhu <shixiong@databricks.com>
1 parent b94fb28 commit c133787

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

streaming/src/main/resources/org/apache/spark/streaming/ui/static/streaming-page.js

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -169,7 +169,7 @@ function drawTimeline(id, data, minX, maxX, minY, maxY, unitY, batchInterval) {
169169
.style("cursor", "pointer")
170170
.attr("cx", function(d) { return x(d.x); })
171171
.attr("cy", function(d) { return y(d.y); })
172-
.attr("r", function(d) { return isFailedBatch(d.x) ? "2" : "0";})
172+
.attr("r", function(d) { return isFailedBatch(d.x) ? "2" : "3";})
173173
.on('mouseover', function(d) {
174174
var tip = formatYValue(d.y) + " " + unitY + " at " + timeFormat[d.x];
175175
showBootstrapTooltip(d3.select(this).node(), tip);
@@ -187,7 +187,7 @@ function drawTimeline(id, data, minX, maxX, minY, maxY, unitY, batchInterval) {
187187
.attr("stroke", function(d) { return isFailedBatch(d.x) ? "red" : "white";})
188188
.attr("fill", function(d) { return isFailedBatch(d.x) ? "red" : "white";})
189189
.attr("opacity", function(d) { return isFailedBatch(d.x) ? "1" : "0";})
190-
.attr("r", function(d) { return isFailedBatch(d.x) ? "2" : "0";});
190+
.attr("r", function(d) { return isFailedBatch(d.x) ? "2" : "3";});
191191
})
192192
.on("click", function(d) {
193193
if (lastTimeout != null) {

0 commit comments

Comments
 (0)