Skip to content

Commit c30c76b

Browse files
committed
fix
1 parent a37b589 commit c30c76b

5 files changed

Lines changed: 5 additions & 5 deletions

File tree

gluten-ut/spark33/src/test/scala/org/apache/spark/sql/GlutenDataFrameWindowFunctionsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class GlutenDataFrameWindowFunctionsSuite
174174
def isShuffleExecByRequirement(
175175
plan: ColumnarShuffleExchangeExec,
176176
desiredClusterColumns: Seq[String]): Boolean = plan match {
177-
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _) =>
177+
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _, _, _) =>
178178
partitionExpressionsColumns(op.expressions) === desiredClusterColumns
179179
case _ => false
180180
}

gluten-ut/spark34/src/test/scala/org/apache/spark/sql/GlutenDataFrameWindowFunctionsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class GlutenDataFrameWindowFunctionsSuite
174174
def isShuffleExecByRequirement(
175175
plan: ColumnarShuffleExchangeExec,
176176
desiredClusterColumns: Seq[String]): Boolean = plan match {
177-
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _) =>
177+
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _, _, _) =>
178178
partitionExpressionsColumns(op.expressions) === desiredClusterColumns
179179
case _ => false
180180
}

gluten-ut/spark35/src/test/scala/org/apache/spark/sql/GlutenDataFrameWindowFunctionsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class GlutenDataFrameWindowFunctionsSuite
174174
def isShuffleExecByRequirement(
175175
plan: ColumnarShuffleExchangeExec,
176176
desiredClusterColumns: Seq[String]): Boolean = plan match {
177-
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _) =>
177+
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _, _, _) =>
178178
partitionExpressionsColumns(op.expressions) === desiredClusterColumns
179179
case _ => false
180180
}

gluten-ut/spark40/src/test/scala/org/apache/spark/sql/GlutenDataFrameWindowFunctionsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class GlutenDataFrameWindowFunctionsSuite
174174
def isShuffleExecByRequirement(
175175
plan: ColumnarShuffleExchangeExec,
176176
desiredClusterColumns: Seq[String]): Boolean = plan match {
177-
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _) =>
177+
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _, _, _) =>
178178
partitionExpressionsColumns(op.expressions) === desiredClusterColumns
179179
case _ => false
180180
}

gluten-ut/spark41/src/test/scala/org/apache/spark/sql/GlutenDataFrameWindowFunctionsSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -174,7 +174,7 @@ class GlutenDataFrameWindowFunctionsSuite
174174
def isShuffleExecByRequirement(
175175
plan: ColumnarShuffleExchangeExec,
176176
desiredClusterColumns: Seq[String]): Boolean = plan match {
177-
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _) =>
177+
case ColumnarShuffleExchangeExec(op: HashPartitioning, _, ENSURE_REQUIREMENTS, _, _, _, _) =>
178178
partitionExpressionsColumns(op.expressions) === desiredClusterColumns
179179
case _ => false
180180
}

0 commit comments

Comments
 (0)