Skip to content

Commit bff90de

Browse files
committed
scalastyle
1 parent f4a16a5 commit bff90de

2 files changed

Lines changed: 5 additions & 4 deletions

File tree

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/HiveThriftServer2Listener.scala

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -248,9 +248,9 @@ private[thriftserver] class HiveThriftServer2Listener(
248248
}
249249

250250
/**
251-
* Remove at least (retainedSize / 10) items to reduce friction. Because tracking may be done
252-
* asynchronously, this method may return 0 in case enough items have been deleted already.
253-
*/
251+
* Remove at least (retainedSize / 10) items to reduce friction. Because tracking may be done
252+
* asynchronously, this method may return 0 in case enough items have been deleted already.
253+
*/
254254
private def calculateNumberToRemove(dataSize: Long, retainedSize: Long): Long = {
255255
if (dataSize > retainedSize) {
256256
math.max(retainedSize / 10L, dataSize - retainedSize)

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/SparkExecuteStatementOperation.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -287,7 +287,8 @@ private[hive] class SparkExecuteStatementOperation(
287287
"in this session.")
288288
case _ =>
289289
}
290-
HiveThriftServer2.listener.postLiveListenerBus(SparkListenerStatementParsed(statementId, result.queryExecution.toString()))
290+
HiveThriftServer2.listener.postLiveListenerBus(SparkListenerStatementParsed(statementId,
291+
result.queryExecution.toString()))
291292
iter = {
292293
if (sqlContext.getConf(SQLConf.THRIFTSERVER_INCREMENTAL_COLLECT.key).toBoolean) {
293294
resultList = None

0 commit comments

Comments
 (0)