You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
com.alibaba.graphar.util.FileSystem.scala
def writeValue(..){}
After close output, we do not close fs.
Expected Behavior
def writeValue(
value: Long,
outputPath: String,
hadoopConfig: Configuration
): Unit = {
val path = new Path(outputPath)
val fs = path.getFileSystem(hadoopConfig)
val output: FSDataOutputStream = fs.create(path, true) // create or overwrite
// consistent with c++ library, convert to little-endian
output.writeLong(java.lang.Long.reverseBytes(value))
output.close() fs.close()
}
Minimal Reproducible Example
com.alibaba.graphar.util.FileSystem.scala
def writeValue(..){}
After close output, we do not close fs.
Environment
Operating system:mac
GraphAr version:main
Link to GraphAr Logs
No response
Further Information
No response
The text was updated successfully, but these errors were encountered:
haohao0103
pushed a commit
to haohao0103/GraphAr
that referenced
this issue
Oct 20, 2023
Is there an existing issue for this?
Current Behavior
com.alibaba.graphar.util.FileSystem.scala
def writeValue(..){}
After close output, we do not close fs.
Expected Behavior
def writeValue(
value: Long,
outputPath: String,
hadoopConfig: Configuration
): Unit = {
val path = new Path(outputPath)
val fs = path.getFileSystem(hadoopConfig)
val output: FSDataOutputStream = fs.create(path, true) // create or overwrite
// consistent with c++ library, convert to little-endian
output.writeLong(java.lang.Long.reverseBytes(value))
output.close()
fs.close()
}
Minimal Reproducible Example
com.alibaba.graphar.util.FileSystem.scala
def writeValue(..){}
After close output, we do not close fs.
Environment
Link to GraphAr Logs
No response
Further Information
No response
The text was updated successfully, but these errors were encountered: