Skip to content

Commit 35c5bdf

Browse files
committed
Fix a crash issue for BulkWriter in Java 24
Signed-off-by: yhmo <yihua.mo@zilliz.com>
1 parent c333d38 commit 35c5bdf

3 files changed

Lines changed: 4 additions & 0 deletions

File tree

sdk-bulkwriter/src/main/java/io/milvus/bulkwriter/writer/ParquetFileWriter.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -54,6 +54,8 @@ private void initWriter() throws IOException {
5454

5555
// declare and define the ParquetWriter.
5656
Configuration configuration = new Configuration();
57+
// set fs.file.impl.disable.cache to true for this issue: https://github.com/milvus-io/milvus-sdk-java/issues/1381
58+
configuration.set("fs.file.impl.disable.cache", "true");
5759
GroupWriteSupport.setSchema(messageType, configuration);
5860
GroupWriteSupport writeSupport = new GroupWriteSupport();
5961
this.writer = new ParquetWriter<>(new Path(filePath),

sdk-core/src/main/java/io/milvus/v2/service/collection/response/DescribeCollectionResp.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -46,6 +46,7 @@ public class DescribeCollectionResp {
4646

4747
private CreateCollectionReq.CollectionSchema collectionSchema;
4848
private Long createTime;
49+
private Long createUtcTime;
4950
private ConsistencyLevel consistencyLevel;
5051
private Integer shardsNum;
5152
@Builder.Default

sdk-core/src/main/java/io/milvus/v2/utils/ConvertUtils.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -145,6 +145,7 @@ public DescribeCollectionResp convertDescCollectionResp(DescribeCollectionRespon
145145
.vectorFieldNames(response.getSchema().getFieldsList().stream().filter(fieldSchema -> ParamUtils.isVectorDataType(fieldSchema.getDataType())).map(FieldSchema::getName).collect(java.util.stream.Collectors.toList()))
146146
.primaryFieldName(response.getSchema().getFieldsList().stream().filter(FieldSchema::getIsPrimaryKey).map(FieldSchema::getName).collect(java.util.stream.Collectors.toList()).get(0))
147147
.createTime(response.getCreatedTimestamp())
148+
.createUtcTime(response.getCreatedUtcTimestamp())
148149
.consistencyLevel(io.milvus.v2.common.ConsistencyLevel.valueOf(response.getConsistencyLevel().name().toUpperCase()))
149150
.shardsNum(response.getShardsNum())
150151
.properties(properties)

0 commit comments

Comments
 (0)