Skip to content

Commit 30b931a

Browse files
committed
Fix
1 parent ca0e362 commit 30b931a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

ingestor-default/src/main/scala/za/co/absa/hyperdrive/ingestor/implementation/transformer/dateversion/AddDateVersionTransformer.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -67,8 +67,8 @@ private[transformer] class AddDateVersionTransformer(val reportDate: String, val
6767

6868
fileCatalog.partitionSpec().partitions.map { partition =>
6969
val row: InternalRow = partition.values
70-
(row.get(0, DateType), row.getInt(1))
71-
}.filter { case (date, _) => date.toString == reportDate }.map { case (_, version) => version }.toList
70+
(row.getString(0), row.getInt(1))
71+
}.filter { case (date, _) => date == reportDate }.map { case (_, version) => version }.toList
7272
}
7373
}
7474

0 commit comments

Comments
 (0)