Skip to content

Commit ffc18c5

Browse files
yabolaCopilot
andauthored
Update extensions/spark/kyuubi-spark-connector-hive/src/main/scala/org/apache/kyuubi/spark/connector/hive/HiveTable.scala
Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com>
1 parent 93466e2 commit ffc18c5

File tree

1 file changed

+2
-2
lines changed
  • extensions/spark/kyuubi-spark-connector-hive/src/main/scala/org/apache/kyuubi/spark/connector/hive

1 file changed

+2
-2
lines changed

extensions/spark/kyuubi-spark-connector-hive/src/main/scala/org/apache/kyuubi/spark/connector/hive/HiveTable.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -193,11 +193,11 @@ case class HiveTable(
193193
s"Schema size (${schema.size}) does not match numFields (${ident.numFields})")
194194
schema.zipWithIndex.map { case (field, index) =>
195195
val value = ident.get(index, field.dataType)
196-
val filedValue = HiveConnectorUtils.castExpression(
196+
val fieldValue = HiveConnectorUtils.castExpression(
197197
Literal(value, field.dataType),
198198
StringType,
199199
Some(sparkSession.sessionState.conf.sessionLocalTimeZone)).eval().toString
200-
field.name -> filedValue
200+
field.name -> fieldValue
201201
}.toMap
202202
}
203203

0 commit comments

Comments
 (0)