diff --git a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala index 58ce488a7..2c30ba3fe 100644 --- a/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala +++ b/integ-test/src/integration/scala/org/opensearch/flint/spark/ppl/FlintSparkPPLBasicITSuite.scala @@ -67,8 +67,11 @@ class FlintSparkPPLBasicITSuite val logicalPlan: LogicalPlan = frame.queryExecution.commandExecuted.asInstanceOf[CommandResult].commandLogicalPlan // Define the expected logical plan val expectedPlan: LogicalPlan = - DescribeTableCommand(TableIdentifier("default.flint_ppl_test"), Map.empty, isExtended = false, output = DescribeRelation.getOutputAttrs - ); + DescribeTableCommand( + TableIdentifier("flint_ppl_test"), + Map.empty[String, String], + isExtended = false, + output = DescribeRelation.getOutputAttrs) // Compare the two plans comparePlans(logicalPlan, expectedPlan, checkAnalysis = false) } diff --git a/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala b/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala index 95c18449a..a021f5b4a 100644 --- a/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala +++ b/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanBasicQueriesTranslatorTestSuite.scala @@ -31,7 +31,7 @@ class PPLLogicalPlanBasicQueriesTranslatorTestSuite val context = new CatalystPlanContext val logPlan = planTransformer.visit(plan(pplParser, "describe t", false), context) - val expectedPlan = DescribeTableCommand(TableIdentifier("t"), Map.empty, isExtended = false, output = DescribeRelation.getOutputAttrs) + val expectedPlan = DescribeTableCommand(TableIdentifier("t"), Map.empty[String, String], isExtended = false, output = DescribeRelation.getOutputAttrs) comparePlans(expectedPlan, logPlan, false) } @@ -41,7 +41,7 @@ test("test FQN table describe table clause") { val context = new CatalystPlanContext val logPlan = planTransformer.visit(plan(pplParser, "describe catalog.schema.t", false), context) - val expectedPlan = DescribeTableCommand(TableIdentifier("describe catalog.schema.t"), Map.empty, isExtended = false, output = DescribeRelation.getOutputAttrs) + val expectedPlan = DescribeTableCommand(TableIdentifier("describe catalog.schema.t"), Map.empty[String, String].empty, isExtended = false, output = DescribeRelation.getOutputAttrs) comparePlans(expectedPlan, logPlan, false) }