Skip to content

Commit

Permalink
refactor(s3): remove useless sourceObjectIds in `CommitWALObjectReq…
Browse files Browse the repository at this point in the history
…uest` (#65)

1. remove useless `sourceObjectIds` in `CommitWALObjectRequest`

Signed-off-by: TheR1sing3un <[email protected]>
  • Loading branch information
TheR1sing3un authored Sep 6, 2023
1 parent c41ad99 commit 44721e6
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -118,12 +118,6 @@
"type": "int64",
"versions": "0+",
"about": "The end offset of the stream range"
},
{
"name": "sourceObjectIds",
"type": "[]int64",
"versions": "0+",
"about": "The IDs of the source S3 objects"
}
]
},
Expand Down
3 changes: 1 addition & 2 deletions core/src/main/scala/kafka/log/s3/objects/StreamObject.java
Original file line number Diff line number Diff line change
Expand Up @@ -86,8 +86,7 @@ public CommitWALObjectRequestData.StreamObject toStreamObjectInRequest() {
.setObjectId(objectId)
.setObjectSize(objectSize)
.setStartOffset(startOffset)
.setEndOffset(endOffset)
.setSourceObjectIds(sourceObjectIds);
.setEndOffset(endOffset);
}

@Override
Expand Down

0 comments on commit 44721e6

Please sign in to comment.