diff --git a/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs b/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs index bd38998ef..a01fbf264 100644 --- a/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs +++ b/src/FlowtideDotNet.Storage/Tree/Internal/BPlusTreeSerializer.cs @@ -65,7 +65,6 @@ public async Task CheckpointAsync(IStateSerializerCheckpointWriter ch return; } - throw new NotSupportedException(); } public async Task InitializeAsync(IStateSerializerInitializeReader reader, StateClientMetadata metadata) where TMetadata : IStorageMetadata @@ -96,7 +95,6 @@ public async Task InitializeAsync(IStateSerializerInitializeReader re return; } - throw new NotSupportedException(); } public IBPlusTreeNode Deserialize(IMemoryOwner bytes, int length, StateSerializeOptions stateSerializeOptions) diff --git a/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs b/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs index b6ecfe165..3d5d97ee7 100644 --- a/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs +++ b/tests/FlowtideDotNet.AcceptanceTests/Internal/FlowtideTestStream.cs @@ -73,7 +73,7 @@ public class FlowtideTestStream : IAsyncDisposable public SqlPlanBuilder SqlPlanBuilder => sqlPlanBuilder; - public int CachePageCount { get; set; } = 0; + public int CachePageCount { get; set; } = 1000; public Watermark? LastWatermark => _lastWatermark; @@ -225,7 +225,6 @@ public async Task StartStream( SerializeOptions = stateSerializeOptions, PersistentStorage = _persistentStorage, DefaultBPlusTreePageSize = pageSize, - //DefaultBPlusTreePageSizeBytes = 1, TemporaryStorageOptions = new Storage.FileCacheOptions() { DirectoryPath = $"./data/tempFiles/{testName}/tmp"