我有一个flink项目，连接到nifi来拉取数据。在本地运行时，获取数据流的设置工作得很好。portName("MyPortName") .buildConfig();java.net.UnknownHostException
at sun.nio.ch.Net.translateException(Net.java:177)
浏览 32提问于2017-03-04得票数 0
回答已采纳
在Azure HDInsights集群上设置flink时会出现异常。抛出：[2018-10-24 00:41:17.70
浏览 2提问于2018-10-25得票数 1
回答已采纳
mvn archetype:generate -DartifactId=flink-scala-project-Dversion=0.1
-Dpackage=org.apache</em
浏览 2提问于2016-03-04得票数 4
import org.apache.flink.api.common.functions.FlatMapFunction;import org.apache.flink.api.java.io.TextInputFormat;import\\complet
浏览 34提问于2021-08-30得票数 0
回答已采纳
我试图在集群上运行Flink作业。这项工作在我的开发(本地)环境上运行良好。但是，当我使用命令将它部署到集群上时： at org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:785)
at org.apache.flink.client.cli.CliFront
浏览 1提问于2018-07-23得票数 1
回答已采纳
我能够在远程hdfs集群中的文件上运行示例wordcount.jar，而无需在flink中声明fs.hdfs.hadoopconf变量。(one,1)
浏览 2提问于2016-07-13得票数 3
回答已采纳
我正在尝试flink并在flink集群上部署作业时遇到异常(在kubernetes上)。设置斯卡拉- 2.11.12集群上的Flink对接图像-flink:1.4.2-scala_2.11-高寒ThisBuild / resolversassembly / assemblyOption := (assembly / ass
浏览 1提问于2018-03-15得票数 0
</configuration> </plugins>它提供了以下例外情况
该程序在以下例外情况下结束；必须包含所有org.apache.flink.statefun，org.apache.kafka，org.apache.flink.client.program.P
浏览 4提问于2020-05-23得票数 0
1回答
Flink状态模式迁移
、、、
我在一个使用MemoryStateBackend的独立集群上有一个flink流应用程序。Kryo的TaggedFieldSerializer被用作默认的序列化程序。当我更改状态的模式并重新部署应用程序时，我得到了以下异常at org.apache.flink.runtim
浏览 1提问于2018-03-10得票数 1
回答已采纳
我正在尝试将我的项目从Flink 1.4升级到Flink 1.9。在1.4中，我构建了一个胖jar，其中包含了我所有的hadoop 2.9.2依赖项，然后我将这些依赖项提交给k8s上的Flink集群。我没有在集群上安装hadoop。
当我将项目升级到1.9并升级集群时，我无法在集群上运行代码，尽管它在我的IntelliJ IDE上运行得很好。由于
浏览 3提问于2019-11-21得票数 0
我试图让Flink (1.2.0)在启用了HA的Hadoop集群(CDH 5.10.0)上工作，但当我通过终止活动RM来测试它时，它会导致整个集群宕机。我已经在flink-conf.yml中配置了Flink的HAhigh-availability.zookeeper.quorum: zookeeper1yarn.application-attempts: 2
然后，我使用yarn-session.sh -n 2
浏览 8提问于2017-03-08得票数 4
因为Flink支持Hadoop FileSystem抽象，并且有一个库在Google之上实现它。
如何使用此回购中的代码创建Flink文件源？
浏览 0提问于2019-04-10得票数 2
回答已采纳
我正在尝试在AWS EMR群集上启动Flink批处理作业，并获得： at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:474)
at
浏览 524提问于2018-12-14得票数 4
回答已采纳
我是flink的新手，我正试图在emr集群上从flink 1.8升级到flink 1.11。升级到flink1.11之后，我看到的一个不同之处是，我没有得到任何度量。我发现flink 1.11在/usr/lib/ flink /opt中没有org.apache.flink.metrics.statsd.StatsDReporterFactor
浏览 2提问于2020-10-22得票数 0
我目前正在开发一个从Hadoop集群读取Avro文件的Flink 1.4应用程序。但是，在我的IDE上以本地模式运行它工作得很好。:54)at org.apache.flink.runtime.taskmanager.Task.run:99)我正在使用官方的<
浏览 207提问于2018-02-14得票数 7
/bin/flink run /streaming/mvn-flinkstreaming-scala/mvn-flinkstreaming-scala-1.0.jarjava.lang.NoSuchMethodE
浏览 0提问于2020-03-09得票数 0
回答已采纳
我试图在独立的 Flink 集群上运行Python应用程序。应用程序在单个节点集群上运行良好，但它在多节点集群上抛出以下错误。from flink.plan.Environment import get_environment
from flink.plan.Constants import INT, STRING, WriteMode
浏览 1提问于2018-02-27得票数 0
回答已采纳
在本地环境中，它工作正常，但是当我在EMR集群上部署这个Flink应用程序时，它会抛出一个与兼容性问题相关的异常。at org.apache.flink.api.java.typeutils.TypeExtractor.createHadoopWritableTypeInfo(TypeExtractor.java:2025) at org.apache.flink.api.java.typeutils.TypeExtr
浏览 0提问于2018-02-08得票数 3
回答已采纳
我使用Flink (通过Kafka)在服务之间传输消息。Flink嵌入在Java应用程序中，每个应用程序都在单独的docker容器中运行。这是我第一次尝试Flink，在看完文档后，我仍然觉得我遗漏了一些基本的东西。JobManager在哪里运行？谢谢,
摩西
浏览 1提问于2017-03-29得票数 0
我正试图在Flink Runner上运行Python光束作业。我已经在我的本地机器上启动了一个minikube集群，并转发了8081端口来查看localhost:8081上的Flink Dashboard。部署的flink集群上的所有东西似乎都在运行，但当我尝试执行基本管道(在DirectRunner上运行良好)时，我在Flink</em
浏览 530提问于2021-02-04得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
