How to request Redis server using a streaming input PCollection?

Using RedisIO, I’m trying to query a collection to a redis server. The Redis server is ok and responding good only when batch pipeline (no streaming). But, using streaming input data (from files) like this: PCollection<String> stream = pipeline.apply(“ReadMyFile”, TextIO.read().from(“/home/out/**”) .watchForNewFiles(Duration.standardSeconds(60), Watch.Growth.<String>never())) .apply(“ParseFn”, ParDo.of(new ParseFn())) .apply(“GlobalString”, GlobalString.get(Duration.ZERO, Duration.standardSeconds(60))); And then, apply the redisIO read() function:…

Details