Skip to content

Commit 3faf1c8

Browse files
committed
fix tests
1 parent 5fcc13d commit 3faf1c8

3 files changed

Lines changed: 9 additions & 9 deletions

File tree

paimon-spark/paimon-spark-4.0/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -377,9 +377,10 @@ case class MergeIntoPaimonDataEvolutionTable(
377377
rawBlobMarkerNamesAvoiding(
378378
rawBlobUpdateColumns.size,
379379
updateColumnsSorted.map(_.name) ++ sourceTable.output.map(_.name))
380-
val rawBlobMarkerNamesByColumn = rawBlobUpdateColumns.zip(rawBlobMarkerNames).map {
381-
case (attr, markerName) => attr.name -> markerName
382-
}.toMap
380+
val rawBlobMarkerNamesByColumn = rawBlobUpdateColumns
381+
.zip(rawBlobMarkerNames)
382+
.map { case (attr, markerName) => attr.name -> markerName }
383+
.toMap
383384
val rawBlobMarkerAttributes = rawBlobUpdateColumns.map(
384385
attr =>
385386
AttributeReference(rawBlobMarkerNamesByColumn(attr.name), BooleanType, nullable = false)())

paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/commands/MergeIntoPaimonDataEvolutionTable.scala

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -376,9 +376,10 @@ case class MergeIntoPaimonDataEvolutionTable(
376376
rawBlobMarkerNamesAvoiding(
377377
rawBlobUpdateColumns.size,
378378
updateColumnsSorted.map(_.name) ++ sourceTable.output.map(_.name))
379-
val rawBlobMarkerNamesByColumn = rawBlobUpdateColumns.zip(rawBlobMarkerNames).map {
380-
case (attr, markerName) => attr.name -> markerName
381-
}.toMap
379+
val rawBlobMarkerNamesByColumn = rawBlobUpdateColumns
380+
.zip(rawBlobMarkerNames)
381+
.map { case (attr, markerName) => attr.name -> markerName }
382+
.toMap
382383
val rawBlobMarkerAttributes = rawBlobUpdateColumns.map(
383384
attr =>
384385
AttributeReference(rawBlobMarkerNamesByColumn(attr.name), BooleanType, nullable = false)())

paimon-spark/paimon-spark-ut/src/test/scala/org/apache/paimon/spark/sql/BlobUpdateTestBase.scala

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -121,9 +121,7 @@ class BlobUpdateTestBase extends PaimonSparkTestBase {
121121

122122
checkAnswer(
123123
sql("SELECT id, `__paimon_raw_blob_placeholder_0`, picture FROM t ORDER BY id"),
124-
Seq(
125-
Row(1, "new_marker_name", Array[Byte](78, 69, 87)),
126-
Row(2, "kept", Array[Byte](2)))
124+
Seq(Row(1, "new_marker_name", Array[Byte](78, 69, 87)), Row(2, "kept", Array[Byte](2)))
127125
)
128126
}
129127
}

0 commit comments

Comments
 (0)