Skip to content

Commit abfc80e

Browse files
Theis-MathiassenAndreasHolt
authored andcommitted
chore: added decompress to unmarshal
Signed-off-by: Theis Randeris Mathiassen <[email protected]>
1 parent a52e86f commit abfc80e

File tree

1 file changed

+1
-1
lines changed
  • service/sharddistributor/store/etcd/executorstore

1 file changed

+1
-1
lines changed

service/sharddistributor/store/etcd/executorstore/etcdstore.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -214,7 +214,7 @@ func (s *executorStoreImpl) recordShardStatistics(ctx context.Context, namespace
214214

215215
var stats store.ShardStatistics
216216
if len(statsResp.Kvs) > 0 {
217-
err := json.Unmarshal(statsResp.Kvs[0].Value, &stats)
217+
err := common.DecompressAndUnmarshal(statsResp.Kvs[0].Value, &stats)
218218
if err != nil {
219219
s.logger.Warn(
220220
"failed to unmarshal shard statistics for heartbeat update",

0 commit comments

Comments
 (0)