minor update

uncleGen · uncleGen · commit 5cb950281e2c · 2019-04-23T15:37:07.000+08:00
diff --git a/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRecordToUnsafeRowConverter.scala b/external/kafka-0-10-sql/src/main/scala/org/apache/spark/sql/kafka010/KafkaRecordToUnsafeRowConverter.scala
@@ -36,7 +36,7 @@ private[kafka010] class KafkaRecordToUnsafeRowConverter {
     } else {
       rowWriter.write(0, record.key)
     }
-    if (record.value() == null) {
+    if (record.value == null) {
       rowWriter.setNullAt(1)
     } else {
       rowWriter.write(1, record.value)

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ private[kafka010] class KafkaRecordToUnsafeRowConverter {`
`36`	`36`	`} else {`
`37`	`37`	`rowWriter.write(0, record.key)`
`38`	`38`	`}`
`39`		`- if (record.value() == null) {`
	`39`	`+ if (record.value == null) {`
`40`	`40`	`rowWriter.setNullAt(1)`
`41`	`41`	`} else {`
`42`	`42`	`rowWriter.write(1, record.value)`