[BEAM-6494] We do not sync pipeline with server at bundle end, only during teardown

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Affects Version/s: 2.9.0
• Fix Version/s: 2.11.0
• Component/s: io-java-redis
• Assignee: Robert Collins
• Reporter: Robert Collins
• Created: 23/Jan/19 17:01
• Updated: 16/May/20 13:53
• Resolved: 29/Jan/19 22:38

Description

The redis pipeline object only sends executed commands to the redis server when sync() or close() are called. If these are not called, the calls stay inside the buffer. As teardown is not guaranteed to be called, we should call pipeline.sync() inside finishBundle, after pipeline.exec(). docs

 

@FinishBundle
public void finishBundle() {
if (pipeline.isInMulti())

{ pipeline.exec(); }

batchCount = 0;
}

@Teardown
public void teardown()

{ jedis.close(); }

Issue Links

• links to: GitHub Pull Request #7645