我得到的错误信息是$ cd flink-0.9.0
$ .Diagnostics: File file:/home/hadoop/.flink/application_1439466798234_0008/flink-conf.yaml does not existjava.io.FileNotFoundException: File file:/home/hadoop&#
浏览 4提问于2015-08-13得票数 8
回答已采纳
1回答
EKS上的Flink集群
、、、、
我计划创建一个flink流作业，将数据从一个FileSystem流流到Kafka。我尝试使用minikube在本地设置它，并启动了会话集群，并提交了工作正常的作业。我的问题是:1)在两个选项中，作业集群和会话集群，因为作业是流作业，应该保持对文件系统的监视
浏览 9提问于2020-01-08得票数 0
回答已采纳
我正在尝试使用Linux和Windows上的Flink local来完成我的学士论文。我找到了用于本地设置的以下步骤：-bash: bin/start-local.sh: No such file or directory/flink-1.1.2/flink-dist/src/main/flink-bin/con
浏览 12提问于2016-09-21得票数 2
回答已采纳
mvn archetype:generate -DarchetypeVersion=0.10.1-DgroupId=org.apache.flink.quickstart
-DartifactId=flink-scala-projectcd flink
浏览 2提问于2016-03-04得票数 4
我创建了一个成功的Flink本地Kubernetes集群(1.14.2)。我正在尝试更新logback配置，我正在使用Flink本地Kubernetes公开的configmap。Flink本机Kubernetes在集群开始时创建这个configmap，并在集群停止时删除它，此行为与正式文档相同。但是Flink没有加载(热重新加载)这个logback配置。
此外，我希望确保即使在集群重新启动期间，logback con
浏览 13提问于2021-12-28得票数 0
我正在跟踪Flink 。打开Flink SQL客户端看起来很好，但是SELECT 'hello world'不能工作。$ /data/apache/flink/flink-1.12.0/bin/sql-client.sh embedded
SLF4J: Class path contains multiple SLF4JSLF4J: Found binding in [jar:file:/data/apache/<
浏览 14提问于2021-03-26得票数 1
回答已采纳
().build()
t_env = BatchTableEnvironment.create(evnironment_settings = env_settings) 但是我发现其中一个样式只适用于flinkrun -py batch.py，其他一些样式可以作为python batch.py运行在本地。我的问题是executionEnvironment和BatchTableEnvironment/StreamTableEnvironment有什么区别，什么时候可以使用flink运行-py，什么时候可以通过安装了
浏览 107提问于2020-12-18得票数 0
我是flink的新手，正在尝试将我的flink程序提交到flink集群。检查了文档，它似乎没有提供我们在中所做的事情
提前感谢
浏览 25提问于2019-11-15得票数 1
回答已采纳
我使用Flink (通过Kafka)在服务之间传输消息。Flink嵌入在Java应用程序中，每个应用程序都在单独的docker容器中运行。这是我第一次尝试Flink，在看完文档后，我仍然觉得我遗漏了一些基本的东西。JobManager在哪里运行？谢谢,
摩西
浏览 1提问于2017-03-29得票数 0
我正在尝试在AWS EMR群集上启动Flink批处理作业，并获得： at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:474)
at org.apache.flink.client.pr
浏览 524提问于2018-12-14得票数 4
回答已采纳
1回答
我需要在生产中运行Flink作业，我只有一台机器(不是集群)。我正在尝试为生产设置我的Flink作业，并以最好的方式完成它，就像我现在拥有的那样(以java应用程序java -jar flink_job.jar的形式运行)。我在中读到，这种部署模式只用于测试或试验，因此，对于生产，我认为我应该转到独立集群，但是，在独立集群部署模式中，我需要设置一个主服务器和至少一个工作人员。我的问题是，我必须在生产中只运行一个节点(主节点)：
--在我的情况下，在生产
浏览 9提问于2020-08-21得票数 0
1回答
例如，我想测试卡夫卡/ Flink与FlinkKafkaConsumer011和FlinkKafkaProducer011的集成。这一进程将是：
当我说测试时，这是单元/集成测试。
谢谢!
浏览 0提问于2018-04-16得票数 3
如何在开始作业时传递其他java属性？我试图通过：-yD env.java.opts="-Dconfig.file='config/jobs/twitter-analysis.conf'"参数传递它，但它不被接受：flink com.github.geoheil.streamingreference.tweets.TweetsAnalysisgit clone git@github.com:geoHeil/streaming-reference.git
cd streaming-re
浏览 6提问于2020-06-24得票数 0
回答已采纳
我使用Flink 1.9.1和PrometheusPushGateway来报告我的指标。在flink-conf.yaml文件中定义了用于报告指标的jobName，该文件使集群上运行的所有作业的jobName相同，但我希望为每个正在运行的作业报告不同的jobName。当在本地运行作业时，它起作用了。但现在我在高可用性模式下运行flink，它不再工作:(我在代码中覆盖的配置被忽略，只使用集群的flink-conf.yaml文件中的值。那么，如何更改每个作业
浏览 1提问于2019-12-17得票数 2
flink程序在本地运行正常，但打包后上传到服务器总是失败，并显示如下消息： java.lang.NoClassDefFoundError: org/netlib/blas/Dgemm$times(DenseMatrix.scala:53) at com.zte.flink
浏览 38提问于2019-12-30得票数 0
我尝试使用ExecutionConfig.setMaxParallelism()方法为Flink作业设置最大并行度，但似乎不起作用。我还修改了标准的WordCount示例以运行一些测试，setMaxParallelism()方法似乎对本地环境或独立集群都没有任何影响。
setMaxParallelism()是如何工作的？
浏览 17提问于2019-02-07得票数 1
如何使用独立应用程序(本地执行环境或迷你集群)实现flink保存点。我在flink-config.yaml文件中配置了savepoint目录，但不确定如何在关闭应用程序之前获取保存点，以及如何在重新启动应用程序后恢复？是否有任何方法或必须先使用flink群集，然后再使用CLI。
感谢你的帮助。谢谢
浏览 0提问于2020-08-18得票数 0
1回答
根据Flink的文档，我们可以在Kubernetes之上部署一个独立的Flink集群，使用Flink的独立部署，或者使用本地Kubernetes部署在Kubernetes上部署Flink。文件上说
是因为本地Kubernetes更容易开始，还是因为独立模式是一种遗产？在本机Kubernetes模式中，Flink能够根
浏览 7提问于2022-01-05得票数 1
1回答
它在本地运行良好，但当我将作业提交给flink集群时，会得到以下错误：在本地，我必须在IDE设置中添加选项“向类路径添加”提供的范围“添加依赖项，以使其工作，但我不知道如何使用maven。pom.xml
浏览 1提问于2022-01-23得票数 0
我们在生产环境中有一个安全的Kafka集群(使用TLS加密、基于证书的客户端身份验证和ACL)。我正在尝试弄清楚如何使用适当的设置配置Flink Kafka连接器，以便它可以安全地连接到我们的Kafka集群。Flink可以做到这一点吗？我是否必须通过属性传递安全配置内容？我们的Flink集群运行在Kubernetes (1.14.2)上，并使用最新的Flink稳定版本(v1.8)和集成的kafka连接器。
浏览 39提问于2019-08-14得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
