Figured it out, I need to use this code instead: FlinkJedisClusterConfig redisConfig = new FlinkJedisClusterConfig.Builder() .setNodes(new HashSet<InetSocketAddress>(Arrays.asList(new InetSocketAddress("asd", 5601)))).build();
(Replace class FlinkJedisPoolConfig with FlinkJedisClusterConfig) I've created this <https://issues.apache.org/jira/browse/BAHIR-249> issue on JIRA; the online example code should be updated. On Wed, Oct 14, 2020 at 3:52 PM Manas Kale <manaskal...@gmail.com> wrote: > Hi, > I am trying to push data from my Flink stream application to a redis > cluster. I'm following the guide at [1], but I believe the example given > might be outdated. Specifically, in the code: > > FlinkJedisPoolConfig conf = new FlinkJedisPoolConfig.Builder() > .setNodes(new HashSet<InetSocketAddress>(Arrays.asList(new > InetSocketAddress(5601)))).build(); > > *the setNodes() method is not present in my distribution of Bahir.* > Here's the dependency as per [1]: > > <dependency> > <groupId>org.apache.bahir</groupId> > <artifactId>flink-connector-redis_2.11</artifactId> > <version>1.0</version> > </dependency> > > I tried browsing through the Builder() class for a new method related to > setting nodes but couldn't find any. What is the issue? Is the example code > outdated or have I downloaded the wrong dependency? Which method do I use > for connecting to a redis cluster? > > [1] https://bahir.apache.org/docs/flink/1.0/flink-streaming-redis/ > > Thanks, > Manas Kale > >