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 that doesn’t seem to help either.
I was wondering if others have run into this issue and have recommendations for a fix. Relevant Part of the stack trace tat org.apache.flink.streaming.api.operators.AbstractStreamOperator$CountingOutput.collect(AbstractStreamOperator.java:696)\n\tat org.apache.flink.streaming.api.operators.StreamSourceContexts$ManualWatermarkContext.processAndCollect(StreamSourceContexts.java:305)\n\tat org.apache.flink.streaming.api.operators.StreamSourceContexts$WatermarkContext.collect(StreamSourceContexts.java:394)\n\tat org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.emitElement(UnboundedSourceWrapper.java:341)\n\tat org.apache.beam.runners.flink.translation.wrappers.streaming.io.UnboundedSourceWrapper.run(UnboundedSourceWrapper.java:267)\n\tat org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:93)\n\tat org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:57)\n\tat org.apache.flink.streaming.runtime.tasks.SourceStreamTask.run(SourceStreamTask.java:97)\n\tat org.apache.flink.streaming.runtime.tasks.StoppableSourceStreamTask.run(StoppableSourceStreamTask.java:45)\n\tat org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:300)\n\tat org.apache.flink.runtime.taskmanager.Task.run(Task.java:711)\n\tat java.lang.Thread.run(Thread.java:748)\nCaused by: java.lang.NoSuchMethodError: com.google.common.util.concurrent.Futures.addCallback(Lcom/google/common/util/concurrent/ListenableFuture;Lcom/google/common/util/concurrent/FutureCallback;)V\n\tat org.apache.beam.sdk.io.kinesis.KinesisIO$Write$KinesisWriterFn.processElement(KinesisIO.java:665)\n"} Thanks in advance Best, Ankit
