From a24b273eac1c87ab813e428da9f02156f4711305 Mon Sep 17 00:00:00 2001 From: wuyi Date: Wed, 27 Nov 2019 16:06:22 +0800 Subject: [PATCH] improve IO_WARNING_LARGEFILETHRESHOLD --- .../scala/org/apache/spark/internal/config/package.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/core/src/main/scala/org/apache/spark/internal/config/package.scala b/core/src/main/scala/org/apache/spark/internal/config/package.scala index 0f402e0bf2bb8..489c5f8fa6b76 100644 --- a/core/src/main/scala/org/apache/spark/internal/config/package.scala +++ b/core/src/main/scala/org/apache/spark/internal/config/package.scala @@ -1325,9 +1325,9 @@ package object config { private[spark] val IO_WARNING_LARGEFILETHRESHOLD = ConfigBuilder("spark.io.warning.largeFileThreshold") .internal() - .doc("When spark loading one single large file, if file size exceed this " + - "threshold, then log warning with possible reasons.") - .longConf + .doc("If the size in bytes of a file loaded by Spark exceeds this threshold, " + + "a warning is logged with the possible reasons.") + .bytesConf(ByteUnit.BYTE) .createWithDefault(1024 * 1024 * 1024) private[spark] val EVENT_LOG_COMPRESSION_CODEC =