diff --git a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java
index d45227d12..37085d4fa 100644
--- a/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java
+++ b/spring-data-redis/src/main/java/org/springframework/data/keyvalue/redis/connection/jedis/JedisConnection.java
@@ -1664,6 +1664,7 @@ public class JedisConnection implements RedisConnection {
 					redis.clients.jedis.ZParams.Aggregate.valueOf(aggregate.name()));
 			if (isPipelined()) {
 				pipeline.zinterstore(destKey, zparams, sets);
+				return null;
 			}
 			return jedis.zinterstore(destKey, zparams, sets);
 		} catch (Exception ex) {