Update sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVOptions.scala

HyukjinKwon · web-flow · commit f1f92fb33636 · 2021-04-13T15:56:04.000+09:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVOptions.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/csv/CSVOptions.scala
@@ -211,7 +211,7 @@ class CSVOptions(
   }
   val lineSeparatorInWrite: Option[String] = lineSeparator
 
-  val inputBufferSize: Option[Int] = parameters.get("inputBuffer").map(_.toInt)
+  val inputBufferSize: Option[Int] = parameters.get("inputBufferSize").map(_.toInt)
 
   /**
    * The handling method to be used when unescaped quotes are found in the input.

Original file line number	Diff line number	Diff line change
`@@ -211,7 +211,7 @@ class CSVOptions(`
`211`	`211`	`}`
`212`	`212`	`val lineSeparatorInWrite: Option[String] = lineSeparator`
`213`	`213`
`214`		`- val inputBufferSize: Option[Int] = parameters.get("inputBuffer").map(_.toInt)`
	`214`	`+ val inputBufferSize: Option[Int] = parameters.get("inputBufferSize").map(_.toInt)`
`215`	`215`
`216`	`216`	`/**`
`217`	`217`	`* The handling method to be used when unescaped quotes are found in the input.`