title: Getting 'ERR EXEC without MULTI' when using RedisIO from Apache Beam API.
body: <p>I'm reading data from BigQuery and writing to Redis using RedisIO from Apache Beam API. Below is the code snippet. </p>
  
  <pre><code>pipeline.apply("Read Data From BigQuery",
          BigQueryIO.readTableRows().withoutValidation()
              .fromQuery(""))
      .apply("Convert Table rows into Redis Entity",
          ParDo.of(new RedisEntity()))
      .apply("Write to Redis",
          RedisIO.write().withEndpoint("localhost", 6379));
  </code></pre>
  
  <p>When trying to execute the code, I get 2,000 records written in redis and after that getting the below error. </p>
  
  <blockquote>
    <p>redis.clients.jedis.exceptions.JedisDataException: EXEC without MULTI
        at redis.clients.jedis.Pipeline.exec(Pipeline.java:139)
        at org.apache.beam.sdk.io.redis.RedisIO$Write$WriteFn.processElement(RedisIO.java:419)</p>
  </blockquote>
  
  <p>Kindly advice if I'm missing something or if there is a better way to do it. </p>