[Question] Using RedisIO with Redis Cluster

Hello! I am trying to use the RedisIO connector with Redis cluster but it looks like the Jedis client that RedisIO uses only works on a standalone Redis server, not on a cluster. I get this error when trying to read from Redis: Exception in thread "main" org.apache.beam.sdk.Pipeline$PipelineEx

Output from Window not getting materialized

Hi everyone! We are developing a new IO connector using the SDF API, and testing it with the following simple counting pipeline: p.apply(MyIO.read()     .withStream(inputStream)     .withStreamPartitions(Arrays.asList(0))     .withConsumerConfig(config)     ) // gets a PCollection>

Re: KafkaIO committing semantics

Thank you very much for your explanation! commitOffsetsInFinalize() -> although checkpointing depends on the runner is it not configurable in a connector implementation? Basically, I want to understand how this can be done with a new IO connector implementation, esp. with the new SDF API. If I