This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.2.0
in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
The following commit(s) were added to refs/heads/dev-1.2.0 by this push:
new cf349ec9c Fixed the problem that some rows might be lost when reading
the result set (#2756) (#2829)
cf349ec9c is described below
commit cf349ec9cc6df677fd621429c374c6c21d7f3e83
Author: aiceflower <[email protected]>
AuthorDate: Wed Aug 17 14:14:22 2022 +0800
Fixed the problem that some rows might be lost when reading the result set
(#2756) (#2829)
Co-authored-by: huiyuanjjjjuice
<[email protected]>
---
.../scala/org/apache/linkis/storage/utils/StorageUtils.scala | 9 ++++++++-
1 file changed, 8 insertions(+), 1 deletion(-)
diff --git
a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala
b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala
index f3dfe2b37..57fd8cfeb 100644
---
a/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala
+++
b/linkis-commons/linkis-storage/src/main/scala/org/apache/linkis/storage/utils/StorageUtils.scala
@@ -187,7 +187,14 @@ object StorageUtils extends Logging{
}
def readBytes(inputStream: InputStream, bytes: Array[Byte], len: Int): Int =
{
- inputStream.read(bytes, 0 , len)
+ var count = 0
+ var readLen = 0
+ while (readLen < len) {
+ count = inputStream.read(bytes, readLen, len - readLen)
+ if (count == -1 && inputStream.available() < 1) return readLen
+ readLen += count
+ }
+ readLen
}
def colToString(col: Any, nullValue: String = "NULL"): String = {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
