Skip to content

Commit df75bff

Browse files
committed
address comments
1 parent 661e5d9 commit df75bff

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

sql/catalyst/src/test/scala/org/apache/spark/sql/catalyst/optimizer/FoldablePropagationSuite.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -147,8 +147,8 @@ class FoldablePropagationSuite extends PlanTest {
147147
test("Propagate in expand") {
148148
val c1 = Literal(1).as('a)
149149
val c2 = Literal(2).as('b)
150-
val a1 = c1.toAttribute.withNullability(true)
151-
val a2 = c2.toAttribute.withNullability(true)
150+
val a1 = c1.toAttribute.newInstance().withNullability(true)
151+
val a2 = c2.toAttribute.newInstance().withNullability(true)
152152
val expand = Expand(
153153
Seq(Seq(Literal(null), 'b), Seq('a, Literal(null))),
154154
Seq(a1, a2),
@@ -164,7 +164,7 @@ class FoldablePropagationSuite extends PlanTest {
164164

165165
test("Propagate above outer join") {
166166
val left = LocalRelation('a.int).select('a, Literal(1).as('b))
167-
val right = LocalRelation('c.int).select('c, Literal(1).as("d"))
167+
val right = LocalRelation('c.int).select('c, Literal(1).as('d))
168168

169169
val join = left.join(
170170
right,

0 commit comments

Comments
 (0)