写异步- 2.6.0错误

Question

我使用下面的apache库来运行数据流作业，从BigQuery读取数据，并存储/写入Cassandra。

1. 梁-sdks java-io-cassandra- 2.6.0
2. 梁-sdks-java-io-jdbc- 2.6.0
3. 电子束-sdks java-io-google-云-平台- 2.6.0
4. 梁-sdks java-核心- 2.6.0
5. 谷歌-云-数据流-java-sdk-所有- 2.5.0
6. google客户端-1.25.0

由于> 2.3版本支持saveAsync，我将我的所有库升级到2.6.0。

在库更新之后，我将在将数据插入/保存到Cassandra时得到以下错误。

java.lang.NoSuchMethodError: com.datastax.driver.mapping.Mapper.saveAsync(Ljava/lang/Object;)Lorg/apache/beam/repackaged/beam_sdks_java_io_cassandra/com/google/common/util/concurrent/ListenableFuture;
    at org.apache.beam.sdk.io.cassandra.CassandraServiceImpl$WriterImpl.write(CassandraServiceImpl.java:435)
    at org.apache.beam.sdk.io.cassandra.CassandraIO$WriteFn.processElement(CassandraIO.java:493)

看起来这是ListenableFuture的一个问题，来自戈瓦和卡桑德拉司机。

Answer 1

我有个解决办法。使用光束-sdks java-io-cassandra- 2.4.0。我正在修复这个问题。其他的东西..。会在这里更新。

更新:很可能发现了这个问题。将一个补丁推到我自己的叉子上。然而，它可能需要一些时间，直到这可以成为一个公关和释放的家伙在梁.如果有人想使用我构建的版本--您可以看看在这里完成了是如何使用的