Skip to content

Commit

Permalink
Fixing constant in BlobSourceCheckpointData to have correct schema si…
Browse files Browse the repository at this point in the history
…ze (#44839)
  • Loading branch information
amnguye authored Jul 3, 2024
1 parent 0608f96 commit e8c05c3
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ internal class SourceCheckpointData
internal const int SchemaVersion = 2;

internal const int VersionIndex = 0;
internal const int DataSize = VersionIndex + OneByte;
internal const int DataSize = VersionIndex + IntSizeInBytes;
}

internal class DestinationCheckpointData
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -52,7 +52,7 @@ public void Deserialize(BlobType blobType)
{
BlobSourceCheckpointData data = new();

using (Stream stream = new MemoryStream(DataMovementBlobConstants.DestinationCheckpointData.VariableLengthStartIndex))
using (Stream stream = new MemoryStream(DataMovementBlobConstants.SourceCheckpointData.DataSize))
{
data.Serialize(stream);
stream.Position = 0;
Expand Down

0 comments on commit e8c05c3

Please sign in to comment.