的定义使用了新的映像：kind: FlinkDeployment name: flink-examplenamespace: default image: "flink-example:0.1.0"kubectl describe pod flink-exampleContaine
浏览 8提问于2022-09-05得票数 1
回答已采纳
/flinkrecovery.jobmanager.port:6123
如您所见，应该将检查点保存到s3a://example-staging-flink/checkpoints目录中，但我没有看到
浏览 2提问于2016-04-15得票数 3
回答已采纳
我正试图在官方的帮助下将Flink流处理器部署到Kubernetes集群。Flink应用程序还使用Minio作为其状态后端。: namespace: default serviceAccount: sa-example apiVersionflinkVersion: v1_14 presto.s3.endpoint: https://s3-exampl
浏览 20提问于2022-09-02得票数 3
我正在尝试Flink 1.14中的细粒度资源管理特性，希望它能够为某些TaskManagers分配特定的运算符。遵循中基于GPU的示例，如何确保Flink“知道”哪个任务管理器实际上拥有所需的GPU？
浏览 1提问于2021-11-09得票数 0
回答已采纳
/bin/flink run -c org.example.CointegrationOfPairs ..at org.example.CointegrationOfPairs$.main(CointegrationOfPairs.scala:38) "org.apache.flink" %% "fl
浏览 1提问于2018-07-23得票数 1
回答已采纳
org.apache.flink.api.scala.typeutils.Types testHarness.open()
}构建错误： found : org.example.RideKeySelectorrequired: org.apache.flink.a
浏览 7提问于2021-12-31得票数 2
;
* Simple example on how to read with a Kafka consumer * Note that the Kafka source is expectinghost:port,host1:port1 --zookeeper.connect host:port --topic testTopic" * This is a valid input examplecall is causing a repartitioning of the data so that all ma
浏览 29提问于2020-01-19得票数 0
我可以将流部署到Apache的独立安装(使用一个JobManager和多个TaskManagers)，没有问题：
state.backend.fs.che
浏览 7提问于2016-04-14得票数 1
回答已采纳
我想在processwindowfunction中设置状态的TTL。此状态在窗口之间共享。此TTL需要基于事件本身中的属性。所以我不能计算状态描述符中的TTL。此外，在processwindowfunction中不支持onTimer函数。 有没有其他方法可以做到这一点？
浏览 15提问于2021-04-08得票数 0
回答已采纳
import org.apache.flink.streaming.api.scala._ def main(args: Array[String]): Unit = { out.collect((key, count))
case _
浏览 2提问于2020-03-18得票数 1
回答已采纳
我正在尝试flink并在flink集群上部署作业时遇到异常(在kubernetes上)。Resolver.mavenLocalversion := "0.1-SNAPSHOT" ExclusionRule("org.ow2.asm", "*")
assembly /
浏览 1提问于2018-03-15得票数 0
1回答
我使用flink流从Kafka源主题中读取事件，在去复制之后，编写来将avro主题中的kafka主题分离开来。流 .uid("Example-Kafka-Avro-Sink")我为输出模式创建了avro模式
浏览 6提问于2022-11-20得票数 0
我是flink和Kafka的新手。我正在尝试使用Confluent Schema注册表对avro数据进行反序列化。我已经在ec2机器上安装了flink和Kafka。运行flink可执行jar的命令： ./bin/flink run -c com.streaming.example.ConfluentSchemaRegistryExample /opt/flink-1.7.2/kafka-flink-stream-proc
浏览 43提问于2019-04-22得票数 1
我正在用最新版本的flink 1.5在kubernetes上试用flink作业。我的问题是如何在上面的flink集群上运行一个示例应用程序。提供了如何使用flink应用程序构建docker镜像并将该应用程序提交给flink的信息。我遵循了示例，只是将flink的版本更改为最新版本。我发现应用程序(example-a
浏览 0提问于2018-06-22得票数 1
/bin/kubernetes-session.sh \-Dtaskmanager.memory.process.sizeSTATUS RESTARTS AGE
dproc-example-flink-cluster-id-68c79bf67-mwh52 1/1 Running 0=dproc-example-flink</em
浏览 31提问于2022-03-25得票数 1
flink流具有多个数据流，然后使用org.apache.flink.streaming.api.datastream.DataStream#union方法对这些数据流进行合并。Sorting union of streams to identify user sessions in Apache Flink 我得到了答案，但com.liam.learn.flink.example.union.UnionStreamDemo.SortFunction环境信息: flink版本1.7.0
浏览 30提问于2019-01-12得票数 2
我需要为不同的应用程序指定不同的Flink设置。换句话说，每个应用程序都应该使用它的自定义文件flink-conf.yaml运行。正确的方法是什么？我找到了一些旧的建议来声明FLINK_CONF_DIR，指向具有Flink配置文件的自定义目录(例如：)。但是，官方的Flink文档根本没有提到FLINK_CONF_DIR变量(从Flink 1.13开始)。因此，我有疑问，这种方式是正式推荐和支持的Flink开发人员。下面是我如何启动应用程序：
"
浏览 23提问于2021-05-05得票数 0
回答已采纳
mvn archetype:generate -DarchetypeVersion=0.10.1-DgroupId=org.apache.flink.quickstart
-DartifactId=flink-scala-projectcd flink
浏览 2提问于2016-03-04得票数 4
问题
如果不可能，在Kafka和HDFS都受到Kerberos保护的情况下，对于Kafka-Flink-HDFS数据流来说，什
浏览 0提问于2018-05-02得票数 5
回答已采纳
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号