You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by pe...@apache.org on 2022/07/29 14:44:16 UTC
[incubator-linkis] 02/02: refactor: reduce log info
This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a commit to branch dev-1.2.0
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 5dcecf8f23e61f12f2a72d7499aa54abf84a56cb
Author: Jack Xu <xu...@126.com>
AuthorDate: Fri Jul 29 17:38:54 2022 +0800
refactor: reduce log info
---
.../apache/linkis/storage/resultset/StorageResultSetReader.scala | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetReader.scala b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetReader.scala
index 580c94401..6a3b0c018 100644
--- a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetReader.scala
+++ b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/resultset/StorageResultSetReader.scala
@@ -66,7 +66,7 @@ class StorageResultSetReader[K <: MetaData, V <: Record](resultSet: ResultSet[K,
var rowLen = 0
try rowLen = Dolphin.readInt(inputStream)
catch {
- case t: StorageWarnException => logger.info(s"Read finished(读取完毕)", t); return null
+ case _: StorageWarnException => logger.info(s"Read finished(读取完毕)"); return null
case t: Throwable => throw t
}
@@ -97,8 +97,8 @@ class StorageResultSetReader[K <: MetaData, V <: Record](resultSet: ResultSet[K,
row
}
- def setFs(fs:Fs):Unit = this.fs = fs
- def getFs:Fs = this.fs
+ def setFs(fs:Fs): Unit = this.fs = fs
+ def getFs: Fs = this.fs
@scala.throws[IOException]
override def getMetaData: MetaData = {
@@ -127,7 +127,7 @@ class StorageResultSetReader[K <: MetaData, V <: Record](resultSet: ResultSet[K,
@scala.throws[IOException]
override def hasNext: Boolean = {
- if(metaData == null) getMetaData
+ if (metaData == null) getMetaData
val line = readLine()
if(line == null) return false
row = deserializer.createRecord(line)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org