Pavel Tupitsyn
Pavel Tupitsyn
Fixes #1126 . Starting with .NET 6, when `InvariantGlobalization` is enabled, `CultureInfo` constructor throws `CultureNotFoundException` for all cultures except invariant: https://docs.microsoft.com/en-us/dotnet/core/compatibility/globalization/6.0/culture-creation-invariant-mode * Handle `CultureNotFoundException` when creating the default formatter. *...
* `ComputeClientDisabledTests` hangs on start: fix default `maxPort` in `TestUtils`. Some tests hang because a single server binds to 47501, and can't find the endpoint on 47500. * `TestStreamerDoesNotLoseDataOnRandomTopologyChanges` hangs:...
Change `DataStreamer` API to allow data removal: * `IDataStreamerTarget` now accepts `IAsyncEnumerable` * Simplified overload accepts `IAsyncEnumerable` as it was before * `DataStreamerItem` is a struct record (no allocations), accepts...
Use one shared lazily-initialized scheduled executor for data streamer auto flush functionality per node / client (instead of new executor per streamer).
Introduce `DataStreamerItem` interface that holds the original item plus `isRemoved` flag. https://issues.apache.org/jira/browse/IGNITE-21340
Previously, msgpack upgrade caused the release build to fail, which was not caught by CI, and we had to roll it back: https://github.com/apache/ignite-3/pull/3319
Within the same streamer batch, skip previous insert operations when a delete operation is encountered. https://issues.apache.org/jira/browse/IGNITE-21992