diff --git a/Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs b/Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs index 78566c5d4..7c78ace2e 100644 --- a/Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs +++ b/Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs @@ -198,7 +198,7 @@ private void DisposeStateLocal() protected override void DisposeState() { this.batch.Free(); - if (hasDisposableState) DisposeState(); + if (hasDisposableState) DisposeStateLocal(); } } }