Re: KinesisIO.write() returning NoSuchMethodError: com.google.common.util.concurrent.Futures.addCallback

2019-09-19 Thread Ankit Jhalaria
Thanks for looking into this Alexey. I was able to get past this issue after I upgraded to beam 2.15.0. Let me know if you would still like a JIRA for this. That said, I am running into another issue which is that the producer within the KinesisIO is throwing a NullPointerException More specifi

Re: KinesisIO.write() returning NoSuchMethodError: com.google.common.util.concurrent.Futures.addCallback

2019-09-19 Thread Alexey Romanenko
Hi Ankit, I haven’t seen this issue and I haven’t managed to reproduce it in my environment. We had similar issue [1] some time ago in Beam 2.6, related to Guava shading, but it was already fixed. Could you create a new Jira for this one? Thanks. [1] https://issues.apache.org/jira/browse/BEA

KinesisIO.write() returning NoSuchMethodError: com.google.common.util.concurrent.Futures.addCallback

2019-09-18 Thread Ankit Jhalaria
Hey beam devs, I am trying to use KinesisIO.write() with beam 2.13, running on flink and its failing while trying to do Futures.addCallback(f, new UserRecordResultFutureCallback()); Its currently pulling in beam-vendor-guava-20_0-0.1.jar I have tried updating bringing in a current version but th