Skip to content

Commit ebb9341

Browse files
committed
Fix build failure
1 parent a7aac78 commit ebb9341

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

external/kafka-0-10-sql/src/test/scala/org/apache/spark/sql/kafka010/KafkaSinkSuite.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -370,7 +370,7 @@ class KafkaContinuousSinkSuite extends KafkaSinkStreamingSuiteBase {
370370
iter.foreach(writeTask.write(_))
371371
writeTask.commit()
372372
} finally {
373-
writeTask.invalidateProducer()
373+
writeTask.close()
374374
}
375375
}
376376
}

0 commit comments

Comments
 (0)