diff options
| author | Chris Lu <chrislusf@users.noreply.github.com> | 2025-10-26 22:48:58 -0700 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2025-10-26 22:48:58 -0700 |
| commit | 0813138d578fd63b928ec1afc9ddabb191657743 (patch) | |
| tree | 19d92182af2c5946bdafd84ea7f679b9d43c8af2 /test/kafka/kafka-client-loadtest/SeekToBeginningTest.java | |
| parent | 824dcac3bf5b75fd4b74bf83d7b08895422d4374 (diff) | |
| download | seaweedfs-0813138d578fd63b928ec1afc9ddabb191657743.tar.xz seaweedfs-0813138d578fd63b928ec1afc9ddabb191657743.zip | |
Volume Server: handle incomplete ec encoding (#7384)
* handle incomplete ec encoding
* unit tests
* simplify, and better logs
* Update disk_location_ec.go
When loadEcShards() fails partway through, some EC shards may already be loaded into the l.ecVolumes map in memory. The previous code only cleaned up filesystem files but left orphaned in-memory state, which could cause memory leaks and inconsistent state.
* address comments
* Performance: Avoid Double os.Stat() Call
* Platform Compatibility: Use filepath.Join
* in memory cleanup
* Update disk_location_ec.go
* refactor
* Added Shard Size Validation
* check ec shard sizes
* validate shard size
* calculate expected shard size
* refactoring
* minor
* fix shard directory
* 10GB sparse files can be slow or fail on non-sparse FS. Use 10MB to hit SmallBlockSize math (1MB shards) deterministically.
* grouping logic should be updated to use both collection and volumeId to ensure correctness
* unexpected error
* handle exceptions in tests; use constants
* The check for orphaned shards should be performed for the previous volume before resetting sameVolumeShards for the new volume.
* address comments
* Eliminated Redundant Parsing in checkOrphanedShards
* minor
* Avoid misclassifying local EC as distributed when .dat stat errors occur; also standardize unload-before-remove.
* fmt
* refactor
* refactor
* adjust to warning
Diffstat (limited to 'test/kafka/kafka-client-loadtest/SeekToBeginningTest.java')
0 files changed, 0 insertions, 0 deletions
