diff --git a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseNativeWriteTableSuite.scala b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseNativeWriteTableSuite.scala index 99f946cd7dc8..4c993e226895 100644 --- a/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseNativeWriteTableSuite.scala +++ b/backends-clickhouse/src/test/scala/org/apache/gluten/execution/GlutenClickHouseNativeWriteTableSuite.scala @@ -903,38 +903,20 @@ class GlutenClickHouseNativeWriteTableSuite | ) partitioned by (day string) | stored as $format""".stripMargin - // FIXME: - // Spark analyzer(>=3.4) will resolve map type to - // map_from_arrays(transform(map_keys(map('t1','a','t2','b')), v->v), - // transform(map_values(map('t1','a','t2','b')), v->v)) - // which cause core dump. see https://github.com/apache/incubator-gluten/issues/6561 - // for details. val insert_sql = - if (isSparkVersionLE("3.3")) { - s"""insert overwrite $table_name partition (day) - |select id as a, - | str_to_map(concat('t1:','a','&t2:','b'),'&',':'), - | struct('1', null) as c, - | '2024-01-08' as day - |from range(10)""".stripMargin - } else { - s"""insert overwrite $table_name partition (day) - |select id as a, - | map('t1', 'a', 't2', 'b'), - | struct('1', null) as c, - | '2024-01-08' as day - |from range(10)""".stripMargin - } + s"""insert overwrite $table_name partition (day) + |select id as a, + | map('t1', 'a', 't2', 'b'), + | struct('1', null) as c, + | '2024-01-08' as day + |from range(10)""".stripMargin (table_name, create_sql, insert_sql) }, (table_name, _) => - if (isSparkVersionGE("3.4")) { - // FIXME: Don't Know Why Failed - compareResultsAgainstVanillaSpark( - s"select * from $table_name", - compareResult = true, - _ => {}) - } + compareResultsAgainstVanillaSpark( + s"select * from $table_name", + compareResult = true, + _ => {}) ) } }