diff --git a/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanJsonFunctionsTranslatorTestSuite.scala b/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanJsonFunctionsTranslatorTestSuite.scala index 23f6ba5d2..5a09af992 100644 --- a/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanJsonFunctionsTranslatorTestSuite.scala +++ b/ppl-spark-integration/src/test/scala/org/opensearch/flint/spark/ppl/PPLLogicalPlanJsonFunctionsTranslatorTestSuite.scala @@ -235,31 +235,7 @@ class PPLLogicalPlanJsonFunctionsTranslatorTestSuite val expectedPlan = Project(Seq(UnresolvedStar(None)), eval) comparePlans(expectedPlan, logPlan, false) } - - test("test json_extend()") { - val context = new CatalystPlanContext - val logPlan = - planTransformer.visit( - plan( - pplParser, - """source=t | eval result = json_extend('{"a":[{"b":1},{"c":2}]}', array('a.b', 'c','d'))"""), - context) - - val table = UnresolvedRelation(Seq("t")) - val keysExpression = - UnresolvedFunction( - "array", - Seq(Literal("a.b"), Literal("c"), Literal("d")), - isDistinct = false) - val jsonObjExp = - Literal("""{"a":[{"b":1},{"c":2}]}""") - val jsonFunc = - Alias(visit("json_extend", util.List.of(jsonObjExp, keysExpression)), "result")() - val eval = Project(Seq(UnresolvedStar(None), jsonFunc), table) - val expectedPlan = Project(Seq(UnresolvedStar(None)), eval) - comparePlans(expectedPlan, logPlan, false) - } - + test("test json_keys()") { val context = new CatalystPlanContext val logPlan =