Skip to content

Commit 10e2ffa

Browse files
chore: added decompress to unmarshal
Signed-off-by: Theis Randeris Mathiassen <[email protected]>
1 parent f63664a commit 10e2ffa

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
@@ -223,7 +223,7 @@ func (s *executorStoreImpl) recordShardStatistics(ctx context.Context, namespace
223223

224224
var stats store.ShardStatistics
225225
if len(statsResp.Kvs) > 0 {
226-
err := json.Unmarshal(statsResp.Kvs[0].Value, &stats)
226+
err := common.DecompressAndUnmarshal(statsResp.Kvs[0].Value, &stats)
227227
if err != nil {
228228
s.logger.Warn(
229229
"failed to unmarshal shard statistics for heartbeat update",

0 commit comments

Comments
 (0)