正在尝试运行flink站点上的SocketWindowWordCount示例教程。我启动了flink集群，然后运行本地套接字服务器：在编译取自的示例源代码之后，我运行该作业
flink run target/SocketWindowWordCount.jar:54:35,673 ERROR org.apache.flink.runtime.rest.handler.
浏览 130提问于2019-07-10得票数 5
回答已采纳
当批处理作业完成时，ApplicationCluster状态应该是什么？“增加restartNonce”是一种重新运行工作的设计方式吗？我试图使用flink操作符来部署flink批处理作业，并每天在特定时间使用kubernetes Cron作业触发它。
浏览 19提问于2022-11-23得票数 0
回答已采纳
我目前正在尝试以类似于以下示例KafkaIO的ByteDeserializer格式读取消息。我的测试设置如下： 选项1:配置为使用--runner=PortableRunner 选项2:启动本地flink作业服务器， docker run --net=host apache/beam_flink1.10'--job_endpoint', 'localhost:8099',
'--environm
浏览 17提问于2021-07-07得票数 0
我正在从AWS控制台(使用Add )启动EMR中的Flink作业，并希望传递JVM参数。根据Flink文档，我们应该按照下面的方式传递args。=dev -Djob.name=Flink_Job_1 -Dkafka.brokers:<>:9092" -yid application_1591030260237_0047flink-0.0.1-SNAPSHOT.jar无法使用JVM参数
尽管我们提供-yid，但这些<
浏览 18提问于2020-06-23得票数 0
说：
org.apache.flink.runtime.jobmanager.scheduler.NoResourceAvailableException: Could
浏览 3提问于2019-08-30得票数 0
回答已采纳
我试图在kubernetes环境中运行Flink作业集群(1.8.1)。我使用用Job创建了停靠映像。作业管理器控制台日志：Starting standalonejob as a console application on host flink-job</e
浏览 0提问于2019-07-16得票数 0
我正在尝试flink并在flink集群上部署作业时遇到异常(在kubernetes上)。% "provided", "org.apache.flinkassemblyOption := (assembly &
浏览 1提问于2018-03-15得票数 0
作业管理器从提供的保存点(-s参数)开始并恢复。.-restoreMode CLAIMERROR org.apache.flink.runtime.entrypoint.ClusterEntrypointUtilsorg.apache</em
浏览 22提问于2022-10-20得票数 0
1回答
"); Error msg: org.apache.flink.
浏览 2提问于2020-06-16得票数 0
1回答
我一直试图让与Python和Apache一起工作，但我似乎找不到一套完整的指令来使环境正常工作。是否有任何具有完整的先决条件和步骤列表的引用来使一个简单的python管道工作？
浏览 1提问于2018-12-04得票数 3
回答已采纳
各位朋友：每个flink作业都使用以下内容来运行-> > env.execute("FLINK-JOB");
> } catc
浏览 5提问于2019-02-22得票数 1
我正在尝试恢复作业，并在作业管理器关闭而我无法成功重新启动作业时进行状态。我想知道是否有一种方法可以在没有zookeeper的情况下恢复作业管理器？当所有作业管理器都宕机时，flink是否能够恢复？当我重新启动作业管理器时，我得到了以下异常：org.apache.flink.runtime.rest.NotFoundException: J
浏览 16提问于2018-09-07得票数 1
回答已采纳
在集成测试中测试flink mini集群上的流时，我遇到了一个问题。该流映射一个生成的Avro Java类( SpecificRecord )。 流作业是用Scala编写的。flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCastException(KryoSerializer.java:572)
浏览 38提问于2020-09-25得票数 0
1回答
让我以一种通用的方式开始，看看我是否错过了一些概念:我有一个流flink作业，我从该作业创建了一个保存点。此作业的简化版本如下所示 Pseduo-代码： val flink = StreamExecutionEnvironment.getExecutionEnvironmentstream.process(new ProcessorWithKeyedState())
CassandraSink.addSink(stream) 只要我在没有保存点的情况下运行</
浏览 51提问于2021-08-03得票数 0
回答已采纳
我们在Flink中开发了一个系统，该系统从目录中读取文件，按客户端对文件进行分组，并根据信息的类型，将这些文件推送到接收器。我们在本地机器上安装了Flink，它工作正常，没有任何问题。但是，当我们将项目停靠时，我们的作业被正确提交，并且UI显示它正在运行，但作业实际上从未启动过。当我们转到详细信息时，在UI中显示如下：Flink dashboard screenshot 作业中的日志显示以下内容：
浏览 449提问于2021-10-15得票数 1
回答已采纳
1回答
Apache将卷安装到作业包
、、、、
;import org.apache.flink.api.java.ExecutionEnvironment;import org.apache.flink.api.java.utils.ParameterTool;
import/Documents/se
浏览 1提问于2021-06-02得票数 1
回答已采纳
我刚刚将我的flink从1.9.1升级到1.11.2 (使用docker) --当我尝试升级到1.11.1并重新运行我的作业时，已经有许多flink作业在1.9.1版本中运行，它会显示错误。failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found[] - Authentication
浏览 5提问于2020-11-11得票数 0
回答已采纳
1回答
我有几个Apache Flink作业是在Datadog中监视的。我试图解决的问题是，我希望有一个仪表板，并切换Flink作业名(和环境)，这样我就不必用完全相同的上下文构建多个仪表板，而只需要构建一个不同的作业标识符/名称。例如，这是我拥有的示例Memory Usage小部件的JSON： "viz": "timeseries",
浏览 4提问于2022-06-07得票数 0
我在同一个Flink项目中有多个工作。我想知道，当我向Flink集群提交作业时，我不知道哪个作业正在为这个提交的jar运行。例如：然后，我更改job2，并创建新的jar文件。然后使用新上传的jar提交job2。
在这种情况下，当查看提交UI时，我真的不知道哪个作业是从这个j
浏览 7提问于2021-04-21得票数 0
2回答
我正在尝试在Kubernetes集群(Azure AKS)中部署Flink作业。作业群集在启动后立即中止，但任务管理器运行正常。 docker镜像创建成功，没有任何异常。我能够运行docker镜像，也能够通过SSH连接到docker镜像。Caused by: org.apache.flink.util.FlinkException: Failed to find job JAR on class path.请在下面找到完整的日志： A. fli
浏览 79提问于2019-12-13得票数 2
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
腾讯云开发者
