回答情况：
提问时间：
问题标签：
我是Flink的新手，我一直在遵循SocketWindowWordCount的例子。: org.apache.flink.api.common.typeinfo.TypeInformationimport org.apache.flink.streaming.api.scala" %% "flink-scala" % flinkVersion,
"org.apache.flink" %% "flink-st
浏览 7修改于2017-10-27得票数 4
指挥：(one,1)
在Flink上运行的flink集群. o
浏览 2修改于2016-07-13得票数 3
回答已采纳
at org.apache.flink.client.program.Client.run(Client.java:413) at org.apache.flink.api.scala.DataSet.collect:54)
at
浏览 0提问于2015-10-27得票数 2
回答已采纳
获取以下flink作业提交错误， @centos1 flink-1.10.0]$ ./bin/flink run -m 10.0.2.4:8081 .: org.apache.flink.runtime.messages.FlinkJobNotFoundException: Could not find Flink job (33d489aee848401e08c425b053c854f9: Could not find Flink job (33d489aee848
浏览 1218提问于2020-03-19得票数 0
回答已采纳
我正在尝试向我的flink集群提交一个作业，但我一直遇到以下错误：java.lang.NoSuchMethodError: org/apache/flink/api/common/state/OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apache/flink/api/common/
浏览 5提问于2021-05-04得票数 1
1回答
FLINK_OPT_DIR/flink-python*.jar $FLINK_LIB_DIR; fi && if [ -f ${FLINK_INSTALL_PATH}/flink-shaded-hadoop* ]; then ln -s ${FLINK_INSTALL_PATH}/flink-shaded-hadoop* $FLINK_LIB_DIR; fi && addgroup
浏览 2修改于2019-12-09得票数 0
回答已采纳
说我们不应该同时升级Flink和Kafka连接器版本。
但是我不能用旧版本的卡夫卡连接器与更新的Flink。我尝试使用Flink -连接器-kafka-010 1.10.2和Flink 1.14，并获得异常：java.lang.NoSuchMethodError: org.apache.flink.api.common.state.OperatorStateStore.getSerializableListState(Ljava/lang/String;)Lorg/apach
浏览 12提问于2022-08-31得票数 0
回答已采纳
我们需要替换flink控制台UI，并使用CLI实用程序启用Flink Web控制台的所有功能，对于一些功能，如启动作业、保存点等，我们使用的是Flink CLI。我的问题是我正在寻找一种解决方案，在这种解决方案中，待命工程师可以使用命令行/终端完全监控并在flink上操作，而不需要使用
浏览 3提问于2022-01-03得票数 0
回答已采纳
/bin/flink run ./myApp.jar./bin/flink run ./bin/flink run ./myApp.jar -c myMain.scala./bin&
浏览 2修改于2016-05-26得票数 4
我让flink系统在远程系统中运行..假设IP为10.XX.XX.XX，端口为6123。现在我想通过RemoteExecution环境从另一个使用Pyflink的系统进行连接。我看过文档https://ci.apache.org/projects/flink/flink-docs-stable/dev/python/table-api-users-guide/table_environment.html
浏览 58提问于2021-04-08得票数 0
回答已采纳
我的代码：import org.apache.flink.streaming.connectors.rabbitmq.RMQSourceimport org.apache.flink.streaming.util.serialization.SimpleStringSchema
val envIntelliJ IDE中的错误：Error:(10, 29)
浏览 4修改于2016-06-07得票数 0
回答已采纳
使用flink 0.10.1在本地，由于以下错误，我无法与作业管理器连接： <version>0.10.1</version>
浏览 3提问于2015-12-30得票数 0
回答已采纳
我有一个flink演示，可以找到dataSet 1的一列，而不是在其他dataSet中。我用flink sql编写它。这看起来和代码没什么关系，但不起作用。我使用的版本是：
importorg.apache.flink.api.common.functions.MapFunction;
import org.apache.
浏览 1修改于2019-05-06得票数 1
0回答
问个flink 和 flink cdc的小白问题？
sql、flink、部署、客户端
按照flink官网，直接部署完，启动 sql客户端，已经可以通过sql完成cdc功能。比如当前最新的flink2.0.0 ，flink-cdc是3.0.4
浏览 63提问于2025-07-18
我正在考虑为不同的流处理应用程序使用Flink或Apache (与flink运行器一起)。我试图比较这两种选择，并做出更好的选择。下面是我正在研究的标准，并且我很难为flink跑步者找到信息(我已经找到了flink独立的所有信息)：以下是我认为我也知道答案的其他准则：
执行有状态操作的能力:是的，bothExactly-once保证:是的，bothIn
浏览 4修改于2022-07-16得票数 0
我一直在研究flink。我对flink中的内存管理有疑问。在flink中内存是如何管理的。在flink中是否也有类似的功能，比如"blocks in spark“？请让我知道，如果有好的地方阅读flink中的内存管理。
浏览 12提问于2019-02-15得票数 0
回答已采纳
我正在尝试使用这个JSONKeyValueDeserializationSchema类测试一个Flink程序来读取来自Kafka的JSON数据。然而，我的Intellij找不到这个类。我的pom.xml <dependency> <artifactId<groupId>org.apache.flink</
浏览 12提问于2016-09-02得票数 0
回答已采纳
假设我有一个可执行的jar文件，里面没有任何flink代码，我的工作是让它与flink一起分发。我已经在代码中的某个地方创建并执行了StreamExecutionEnvironment，并将可以分发的jar代码放在flink运算符(即映射函数)中，从而做到了这一点。他们告诉我要找到一种方法来包装这个无flink的jar，这样它就可以被flink集群执行(不需要像我上面那样注入代码和修改jar )。有没有办法做到这一点？将它放在flink运算符中，但不幸的是，我不知道这个jar是否可以
浏览 15提问于2020-06-02得票数 0
:flink-annotations</exclude> <exclude>org.apache.flink:f
浏览 10修改于2016-07-28得票数 0
我正在为数据流工作apache (1.3.1)，我必须在Windows 2012 R2下设置它，我在Flink HA设置上有一个问题。任何帮助都是非常感谢的。谢谢。在flink-#en0#.high中高可用性.：
它可以通过“cygdrive/Y/flink-recovery”路径从Cygwin终端访问资源服务器。问题:当我在Cygwin下运行start-cluster.sh命令时，Flink HA将在所有Flink服务器中创建一个文件夹'c:/cygdrive
浏览 0提问于2017-11-05得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号