Apache Flink 1.9.0于2019年8月22日发布。我试着运行来自Beam2.15.0和Flink runner " Beam -runners-flink-1.8“的Beam字数计数示例，但似乎不起作用。1.9.0版本是否有兼容flink runner工件的预计到达时间？我使用下面的Maven依赖项构建： <dependency>
<groupId>or
浏览 13提问于2019-09-09得票数 0
回答已采纳
有没有一个地方我们可以快速参考和查看Apache beam和运行时环境(Flink，Spark等)之间的版本兼容性。我正在以一种艰难的方式学习它：我不确定我的问题有多少是由版本错误造成的。目前我使用的是光束2.4.0，看看flink runner pom ()，它使用的是flink 1.4.0 jars。所以我假设Apache
浏览 0提问于2018-06-14得票数 0
我开始研究用Scala语言编写的Apache Flink的CEP库，当我试图通过执行https://ci.apache.org/projects/flink/flink-docs-stable/devimport org.apache.flink.cep.CEP
import org.apache.flink.cep.scala.patte
浏览 50提问于2020-01-14得票数 0
回答已采纳
一个使用Akka 2.5.23的简单示例运行良好。如果我在真正的开发项目中添加功能，我会遇到一个非常奇怪的问题： Uncaught error from thread [RemoteSystem-akka.remote.default-remote-dispatchernetty.tcp { port = 2552 }
} 我仔细检查了所有的Akka jar都是相同的版本我
浏览 112提问于2019-06-30得票数 1
', name: 'flink-connector-kafka_2.11', version: '1.9.0' // https://mvnrepository.com/ar
浏览 4提问于2020-03-09得票数 0
回答已采纳
独立罐<dependency> <artifactId>flink-core</artifactId></dependency> <groupId>
浏览 1提问于2019-11-18得票数 1
回答已采纳
虽然我已经导入了org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011，但是我得到了以下错误。Too many arguments for constructor FlinkKafkaProducer011这是IDE的定义。public FlinkKafkaProducer011() {
public stati
浏览 5提问于2020-08-11得票数 0
回答已采纳
我有一个beam代码，可以在google数据流上运行一些etl内容(从pubsub获取gsp上的文件路径)。我的公司正在寻求切换到aws，代码也需要移动(开始只移动代码，然后我们将pubsub和gsp更改为aws服务)。代码还需要在最后更新雅典娜。有没有办法在glue中使用beam (或其他可以做这项工作的服务)？我知道beam和glue都支持spark，所以可能会有一些东西吧？ 谢谢!
浏览 11提问于2021-07-07得票数 0
我知道德鲁伊有scala/php客户端，但我使用的是java，我不想直接通过HTTP查询德鲁伊DB，有可用的java德鲁伊客户机吗？
浏览 3提问于2017-10-09得票数 0
回答已采纳
尝试将Flink 1.9 SQL-Client与Kafka一起使用，但未成功。在弄清楚所需的jar文件并将它们复制到lib目录后，当执行SELECT * FROM table-name时，我得到了以下运行时异常： Flink SQL> select * from default_catalog.default_database.member_customer_newsletters/lib/flink-sql-connector-kafka-0.11_2.12-1.9.0
浏览 231提问于2019-09-20得票数 0
在本地环境中，它工作正常，但是当我在EMR集群上部署这个Flink应用程序时，它会抛出一个与兼容性问题相关的异常。我得到的错误信息是但是，当我显式地将兼容性J
浏览 0提问于2018-02-08得票数 3
回答已采纳
我尝试在本地部署的Flink Docker集群上部署一个Apache光束管道。(RemoteStreamEnvironment.java:178)org.apache.flink.streaming.api.environmen
浏览 80提问于2020-08-20得票数 1
我正试图在Flink Runner上运行Python光束作业。我已经在我的本地机器上启动了一个minikube集群，并转发了8081端口来查看localhost:8081上的Flink Dashboard。部署的flink集群上的所有东西似乎都在运行，但当我尝试执行基本管道(在DirectRunner上运行良好)时，我在Flink completed作业仪表板上得到了这个堆栈跟踪错误： Job failedThreadPoolExec
浏览 530提问于2021-02-04得票数 0
我有一个运行在Flink runner上的光束管道，如下所示： ? 光束中的整个管道都被捆绑到这个区块中。为什么Flink用这种方式来说明它？ ? 当然，管道步骤中的不同pardo应该由不同的块和工作者来表示(就像在Google的数据流中一样)。是否需要在Flink运行器中设置某些内容以显示更细粒度的任务，或者Flink UI是否仅为原生Flink代
浏览 24提问于2021-07-05得票数 1
2回答
在EMR上部署flink应用程序时出现此错误 at java.lang.Class.forName(Class.java:348)
at org.apache.hadoop.util.RunJar.run我在EMR<e
浏览 2提问于2019-12-15得票数 0
1回答
我希望有人能澄清TensorFlow与它的依赖关系(Beam、AirFlow、Flink等)梁的例子？如果没有，那么你能运行TFX只有梁和它的转轮吗？如果是的话，为何没有这样的例子呢？在taxi_pipeline_flin
浏览 0提问于2019-05-17得票数 6
回答已采纳
我正在尝试使用Google Pub/Sub连接器与Flink，请看这里。java.lang.NoClassDefFoundError: Could not initialize class com.google.cloud.pubsub.v1.stub.GrpcPublisherStub 我有连接器的依赖版本是1.9.0 <dependency>
<groupId>org.apache.flink<
浏览 6提问于2019-08-30得票数 1
在使用Flink的Hive连接器查询Hive时，我有以下异常：Distinct without an aggregation。Hive版本：2.1.1select devid as pdevid,
count(distinct vtype) as v
浏览 21提问于2022-07-08得票数 0
因为Flink支持Hadoop FileSystem抽象，并且有一个库在Google之上实现它。
如何使用此回购中的代码创建Flink文件源？
浏览 0提问于2019-04-10得票数 2
回答已采纳
我最近将我们的Flink从1.9.0迁移到了没有HA作业集群的1.11.1。我面临以下错误，它导致JobManager在每隔5分钟后失败，并且Flink作业通过AWS ECS卡在这些重新启动循环中。 在升级1.11.1后，它曾经在Flink 1.9.0中工作过，但现在不行了。因为我没有JM，所以我为每个flink作业生成固定的--job-id，而不是默认的id 00000000000。我是Flink
浏览 195提问于2020-12-04得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
