Skip to content

Commit

Permalink
removed unit test since conv is marked unsupported
Browse files Browse the repository at this point in the history
Signed-off-by: cindyyuanjiang <[email protected]>
  • Loading branch information
cindyyuanjiang committed Sep 19, 2023
1 parent 460a636 commit 2c3f96a
Showing 1 changed file with 0 additions and 30 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -976,36 +976,6 @@ class SQLPlanParserSuite extends BaseTestSuite {
}
}

test("conv is supported in ProjectExec") {
TrampolineUtil.withTempDir { parquetoutputLoc =>
TrampolineUtil.withTempDir { eventLogDir =>
val (eventLog, _) = ToolTestUtils.generateEventLog(eventLogDir,
"ProjectExprsSupported") { spark =>
import spark.implicits._
val df1 = Seq("10", "-10", "-1", "FFFFFFFFFFFFFFFF").toDF("value")
// write df1 to parquet to transform LocalTableScan to ProjectExec
df1.write.parquet(s"$parquetoutputLoc/testtext")
val df2 = spark.read.parquet(s"$parquetoutputLoc/testtext")
// conv should be part of ProjectExec
df2.select(conv(df2("value"), 16, 10))
}
val pluginTypeChecker = new PluginTypeChecker()
val app = createAppFromEventlog(eventLog)
assert(app.sqlPlans.size == 2)
val parsedPlans = app.sqlPlans.map { case (sqlID, plan) =>
SQLPlanParser.parseSQLPlan(app.appId, plan, sqlID, "", pluginTypeChecker, app)
}
val allExecInfo = getAllExecsFromPlan(parsedPlans.toSeq)
val wholeStages = allExecInfo.filter(_.exec.contains("WholeStageCodegen"))
assert(wholeStages.size == 1)
assert(wholeStages.forall(_.duration.nonEmpty))
val allChildren = wholeStages.flatMap(_.children).flatten
val projects = allChildren.filter(_.exec == "Project")
assertSizeAndSupported(1, projects)
}
}
}

test("Parse SQL function Name in HashAggregateExec") {
TrampolineUtil.withTempDir { eventLogDir =>
val (eventLog, _) = ToolTestUtils.generateEventLog(eventLogDir, "sqlmetric") { spark =>
Expand Down

0 comments on commit 2c3f96a

Please sign in to comment.