我们在我们的google云平台中使用apache beam,并实现了一个写入postgres数据库的数据流作业。然而,我们注意到,一旦我们开始同时使用两个JdbcIO.write()语句,我们的流作业就开始抛出如下错误: Operation ongoing in step JdbcIO.WriteVoid/ParDo:356)
at org.apache.commons.dbcp2.PoolingDataSource.getConnection (PoolingDataSour
我正在尝试使用来自Java的Apache作为数据管道。我编写了一个简单的类,它来自Google并深入到,但我无法让它为我的生命构建。我使用Maven构建并添加了我能找到的每一个束包,但是我仍然会得到“类文件未找到”错误。class file for org.apache.beam.sdk.options.GcsOptions not found
有人知道我需要添加哪些包来解决这些问题吗?-- https://mvnrepository.com/artifact/org.apa