回答情况：
提问时间：
问题标签：
主任务管理器也是jobmanager和taskmanager (4个任务管理器和一个作业管理器)，所以当我运行jar文件时，它只使用了一个插槽，而我有4个插槽，大约一个插槽用于一个任务管理器，我不知道为什么框架不使用所有可用的插槽
浏览 33修改于2020-01-25得票数 1
回答已采纳
比较Flink和Spark Streaming，Flink和Storm，Storm和Heron有很多问题。这个问题的来源是Apache Flink和Twitter Heron都是真正的流处理框架(而不是像Spark Streaming这样的微批处理框架)。在Flink和Flink vs Spark上有斯利姆·巴尔塔吉的精彩演讲：关于Flink vs Storm的有趣想法：
但我还
浏览 27修改于2018-04-10得票数 9
我的Flink日志哪儿也没出现。所以我在读如何解决这个问题。我读过一些关于如何在flink/conf文件中更改日志级别的文章，以帮助我解决这个问题。
但后来我读到flink有两个日志框架选项。那么现在如何确定我的Flink应用程序使用的是哪个框架呢？
浏览 18提问于2022-06-02得票数 2
回答已采纳
是否可以在运行时更改flink框架的日志级别？什么时候flink集群已经在运行？我参考了下面的文件，没有提到它。https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/logging.html
浏览 267提问于2020-11-24得票数 0
1回答
在一个受保护的Hadoop集群中，我试图访问Flink am页面并从纱线中登录，并看到以下错误：User %remoteUser are not authorized to view application%appIDAMContainerSpec是ContainerLaunchContext类，它有一个PB实现，从框架端提交从Flink中，该对象是在Ab
浏览 3提问于2018-06-14得票数 0
我很想知道用于外部数据访问的Asynchronous I/O Flink API是否也适用于Beam。我找不到任何具体的东西。我知道横梁使用Flink作为执行框架，所以异步I/O对横梁也是可能的，但我不确定API是否已经定义。
浏览 18提问于2021-10-06得票数 0
我的问题是关于Apache框架。我目前工作在星火流，这是限制在那里。
通过其他流框架(如Apache、Storm或NIFI )可以实现这一点吗？
浏览 5修改于2019-04-05得票数 5
回答已采纳
我有一个flink工作，其中我使用logback作为我的日志记录框架。如果我从Eclipse运行flink作业，日志将被发送到指定的logstash服务器。我的flink设置是在windows上运行的，按照这里的说明。我使用start-cluster.bat启动
浏览 25修改于2018-11-28得票数 0
最近，在使用logback.xml作为日志记录时，我在独立集群模式下的Flink日志记录遇到了一个问题。我的要求是我的所有作业都应该记录在特定的文件夹中，我的flink框架日志应该放在单独的文件夹中，而且对于在我的flink集群中运行的每个作业，应该有一个单独的文件夹用于不同的作业。我在我的本地集群中测试了它，它工作得很好，我得到了我所有的日志，分别提交了我的Flink作业的文件夹，但是一旦我在独立集群中部署了我的代码以及每个作业的相应logback.xml，它就根本不会记录日志。Flink</e
浏览 47提问于2020-08-06得票数 0
一些反应式框架具有groupByUntil功能。允许按键对元素进行分组，并在特定事件或时间间隔(即，来自RxJS的描述)之后将其移除。
正如我所看到的，apache-flink没有这样的开箱即用功能。谁能解释一下如何在apache-flink中实现这样的功能？
浏览 0提问于2015-11-25得票数 1
有没有一种方法可以在分布式文件系统上运行Spark或Flink，比如lustre，或者除了HDFS或者S3之外的任何东西。因此，我们可以使用Unix集群创建分布式文件系统框架，我们是否可以在集群模式下运行spark/flink，而不是独立运行。
浏览 1修改于2020-08-29得票数 0
我有一个flink作业，它使用logback作为日志框架，因为需要将日志发送到logstash，而logback有一个logstash (Logstash appender )。但是，当我通过flink仪表板将此作业部署到flink集群(独立，开始使用./start-cluster.bat)时，logback配置将被忽略，日志不会发送到logstash。我阅读了更多关于flink日志机制的内容，并看到了。尽管上面提到的步骤有效，但这是有问题的，因为flink使用的fli
浏览 1修改于2018-11-29得票数 3
回答已采纳
我刚接触过Flink，目前正在测试一个实用程序的框架，该框架包括丰富来自Kafka的具有许多历史特性的事务(例如，相同来源和相同目标之间过去的事务数)，然后使用机器学习模型对此事务进行评分。目前，功能都保持在Flink状态，相同的工作是对丰富的事务进行评分。但是我想把功能计算工作和评分工作分开，我不知道如何做到这一点。对Flink来说，将两份工作分开是个坏主意吗？为了避免复杂的作业(并检查它是否对延迟有任何积极的影响)，我们采用这种方法对Kafka流进行相同的测试。一些额外信息:我正在使用Flin
浏览 0提问于2018-02-02得票数 0
回答已采纳
我正在使用此工具执行Flink作业。我认为两者都可以通过正确的配置来完成完全相同的任务。Kinesis Data Analytics是否做了EMR不能做的事情，反之亦然？Amazon Elastic Map Reduce提供了一个托管的Hadoop框架，使其能够轻松、快速且经济高效地跨动态可扩展的亚马逊Hadoop实例处理海量数据。您还可以在EMR中运行其他流行的分布式框架，如Apache Spark、HBase、Presto和Flink。
浏览 29提问于2019-05-17得票数 7
我还没有选择一个流媒体框架，但我现在正在摆弄Flink。但是，我对使用Beam，Spark Streaming持开放态度，无论我发现什么适合我的用例。., z 对于Flink来说，求平均值似乎是通过AggregateFunction https://github.com/apache/flink/blob/master/flink-core/src/main/java/org/apach
浏览 6提问于2019-04-16得票数 0
我目前正在使用HiBench框架和为Flink实现的WordCount微基准。我注意到，如果在执行过程中杀死一个TaskManager，Flink操作符的状态会在自动“重新部署”之后恢复，但是会有很多(全部？)从基准发送到Kafka的元组被忽略(存储在Kafka中，但没有在Flink中接收)。
浏览 0修改于2018-04-16得票数 3
回答已采纳
我正在Scala (2.11.8)和使用Flink框架(1.8.3)中工作。我的导入包括:导入org.apache.flink.api.scala._导入org.apache.flink.streaming.api.scala._
附加信息：readCsvFile：DataSetT
浏览 10修改于2020-08-12得票数 1
我在mysql中定义了一个推荐表，其中包含3列: user_id、item_id、rank、flink将计算一些建议并将结果插入mysql中，当用户单击某个项时，我只希望mysql存储用户最近一次单击所触发的建议既然flink mysql连接器不支持delete，我如何做到这一点？如果需要大数据计算，这种框架在这种情况下是否常见？
浏览 5提问于2022-06-28得票数 0
在flink流处理框架中，我没有几个问题。请告诉我你对这些问题的意见。
假设我用task-manger/job-manger?Does flink具有分区和数据倾斜的概念?如果flink连接到脉冲星并需要从分段主题读取数据，则为。那么，这里的并行性是什么呢？)并行等于no。或者完全取决于flink任务管理器的no.of任务槽)在作业图上有内置的优化吗？(例如。我的工作图有这么多filter，map，flatmap。等)。请你提出任何关于flink作业的文档/材料，我们
浏览 10提问于2022-08-17得票数 0
这个框架部分是用Scala编写的，在执行单词计数示例时，会抛出一个异常(还有许多其他的异常，我不会发布)：at org.apache.flink.runtime.minicluster.FlinkMiniCluster.<init>(FlinkMiniCluster.scala:76)
at org.apache.flink.runtime.minicluster.LocalFlinkMiniCluster.<init>(LocalFlinkM
浏览 4修改于2017-05-23得票数 0
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号