diff --git a/src/t_stream.c b/src/t_stream.c index d2c5b45a3..19b20ee56 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -281,7 +281,7 @@ int streamAppendItem(stream *s, robj **argv, int64_t numfields, streamID *added_ } int flags = STREAM_ITEM_FLAG_NONE; - if (lp == NULL || lp_bytes >= server.stream_node_max_bytes) { + if (lp == NULL) { master_id = id; streamEncodeID(rax_key,&id); /* Create the listpack having the master entry ID and fields. */