Skip to content

Commit 4dc1b22

Browse files
committed
[Spark Job History] SQL UI Page does not support Pagination
1 parent d6be46e commit 4dc1b22

File tree

3 files changed

+341
-127
lines changed

3 files changed

+341
-127
lines changed

core/src/main/resources/org/apache/spark/ui/static/webui.js

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,7 +83,7 @@ $(function() {
8383
collapseTablePageLoad('collapse-aggregated-rdds','aggregated-rdds');
8484
collapseTablePageLoad('collapse-aggregated-activeBatches','aggregated-activeBatches');
8585
collapseTablePageLoad('collapse-aggregated-completedBatches','aggregated-completedBatches');
86-
collapseTablePageLoad('collapse-aggregated-runningExecutions','runningExecutions');
87-
collapseTablePageLoad('collapse-aggregated-completedExecutions','completedExecutions');
88-
collapseTablePageLoad('collapse-aggregated-failedExecutions','failedExecutions');
86+
collapseTablePageLoad('collapse-aggregated-runningExecutions','aggregated-runningExecutions');
87+
collapseTablePageLoad('collapse-aggregated-completedExecutions','aggregated-completedExecutions');
88+
collapseTablePageLoad('collapse-aggregated-failedExecutions','aggregated-failedExecutions');
8989
});

core/src/main/scala/org/apache/spark/ui/PagedTable.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,7 @@ import org.apache.spark.util.Utils
3131
*
3232
* @param pageSize the number of rows in a page
3333
*/
34-
private[ui] abstract class PagedDataSource[T](val pageSize: Int) {
34+
private[spark] abstract class PagedDataSource[T](val pageSize: Int) {
3535

3636
if (pageSize <= 0) {
3737
throw new IllegalArgumentException("Page size must be positive")
@@ -72,7 +72,7 @@ private[ui] case class PageData[T](totalPage: Int, data: Seq[T])
7272
/**
7373
* A paged table that will generate a HTML table for a specified page and also the page navigation.
7474
*/
75-
private[ui] trait PagedTable[T] {
75+
private[spark] trait PagedTable[T] {
7676

7777
def tableId: String
7878

0 commit comments

Comments
 (0)