1回答
有没有关于Apache Flink运行时上下文的文档？
apache-flink
我知道flink有一些预定义的变量，比如<host>，我可以通过以下方式获取它:flink谢谢
浏览 14提问于2017-07-01得票数 0
回答已采纳
1回答
Flink UI概述
apache-flink、apache-beam、flink-streaming
我有一个flink UI仪表板，在“概述”选项卡下，我看到一个带有以下文本的框。只是想知道这意味着什么。(我理解ParDo等的概念)
浏览 2提问于2018-09-12得票数 0
回答已采纳
1回答
Apache Flink:在发生大量事件后，.countWindow()是处理代码的正确方式吗？
apache-flink、flink-streaming
在Apache Flink 1.8.1上 我正在阅读https://flink.apache.org/news/2015/12/04/Introducing-windows.html，我正在尝试弄清楚使用我很困惑，因为关于.countWindow()的文档有限，而且我很难确认它是否已被弃用，转而采用另一种方法。 我正在尝试这个(忽略红色的高亮部分)： ? countWindow()
浏览 14提问于2020-03-31得票数 0
回答已采纳
1回答
理解和分析flink代码，特别是调度部分
streaming、apache-flink、flink-streaming、bigdata
我正在改进apache flink的资源和任务调度，请分享任何关于apache flink内部架构的教程或任何文档。还分享了调试flink代码的正确方法。您在分析flink代码方面的帮助和经验将不胜感激。
浏览 0提问于2017-03-28得票数 0
1回答
Apache SBT依赖失败
sbt、rabbitmq、apache-flink、flink-streaming
我正在尝试使用带有RabbitMq流连接器的Flink。尝试了所有可能的版本组合，但仍然失败。下面是我的sbt构建片段
val flinkDependencies = S
浏览 0提问于2016-03-08得票数 2
2回答
在集成测试中测试flink mini集群上的流时，我遇到了一个问题。该流映射一个生成的Avro Java类( SpecificRecord )。 流作业是用Scala编写的。flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCastExceptionnot instantiate
浏览 38提问于2020-09-25得票数 0
1回答
带有Apache Flink 1.5的Apache Bean 2.4.0
apache-flink、apache-beam
有没有一个地方我们可以快速参考和查看Apache beam和运行时环境(Flink，Spark等)之间的版本兼容性。我正在以一种艰难的方式学习它：我不确定我的问题有多少是由版本错误造成的。目前我使用的是光束2.4.0，看看flink runner pom ()，它使用的是flink 1.4.0 jars。所以我假设Apache beam 2.4.0可以与A
浏览 0提问于2018-06-14得票数 0
2回答
Scala:无法解析重载方法(Flink WatermarkStrategy)
apache-kafka、apache-flink、flink-streaming
下面是Flink关于如何将WatermarkStrategy与KafkaConsumer结合使用的文档。[String])org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase[String] <and>
[ERROR] (x$1: org.apache.flink.streaming.api.functions.AssignerWithPunctuatedW
浏览 5提问于2020-11-23得票数 4
回答已采纳
1回答
pyflink 1.11的RabbitMQ自定义表源和接收器
rabbitmq、apache-flink、ddl、pyflink
根据这里的文档： https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/connectors/ 和 https://ci.apache.org/projects/flink/flink-docs-release-1.11
浏览 58提问于2020-07-10得票数 0
1回答
如何使用AWS EMR上的Apache Flink安全地更新正在运行的作业？
apache-flink、amazon-emr、flink-streaming
我找不到关于如何安全更新代码的说明。我看到了有关如何使用保存点的Flink文档。我希望有一个简单的解决方案来更新AWS EMR中的Flink作业。https://ci.apache.org/projects/flink/flink-docs-release-1.9/ops/deployment/aws.html http
浏览 28提问于2020-06-11得票数 1
1回答
四个Flink表API/SQL数据类型包之间有什么关系？
apache-flink、flink-sql
Flink /SQL有很多关于DataType系统的包，包括：
org.apache.flink.table.api.DataTypesorg.apache.flink.table.api.Typesorg.apache.flink.table.types.DataTypeorg.apache.flink.table.data我对软件包之间的关系相当困惑，有人能给我一些提
浏览 1提问于2021-03-07得票数 0
回答已采纳
1回答
使用Flink处理twitter数据时的依赖问题
maven、twitter、apache-flink
我正在尝试使用Apache连接twitter，使用官方文档进行流传输。java.lang.NoClassDefFoundError: org/apache/flink/twitter/shaded/com/google/common/base/Preconditions<init>(StatusesSampleEndpoint.java:24)
at org.apache.flink.s
浏览 6提问于2017-10-03得票数 2
回答已采纳
1回答
Flink优化器是如何决定并行性的？
apache-flink
下面是我观看的演示文稿中关于Flink优化器的幻灯片。对于Flink的优化器根据提供的数据集的基数来决定并行性的评论，我特别感到困惑。我目前正在阅读Flink 1.4 (我正在使用的版本)文档，我似乎找不到任何关于Flink关于并行性的决定的文档。，我是否需要为Fli
浏览 0提问于2019-05-20得票数 1
回答已采纳
1回答
Apache本地设置，独立JAR与start-cluster.sh之间的实际差异
apache-flink
独立罐<dependency> <artifactId>flink-core</artifactId></dependency> <groupId>org.a
浏览 1提问于2019-11-18得票数 1
回答已采纳
1回答
IDE eclipse中的scala和maven错误
scala、maven、apache-flink
我使用双倍创建了这个示例程序log4j:WARN No appenders could be found for logger (org.apache.flink.api.scala.ClosureCleanerat org.apache.flink.api.common.PlanExecutor.createLocalExecutor(PlanExecutor.java:161)
at org.apache.flink.api.
浏览 0提问于2016-09-06得票数 0
1回答
不能将Flink指标暴露给Prometheus
java、apache-flink、prometheus、jmx
我试图向Prometheus公开Flink的内置度量标准，但不知怎么的，Prometheus并不识别目标-- 和。: jmx, prometheus
metrics.
浏览 7提问于2020-09-17得票数 0
1回答
当我将Flink Java应用程序从1.12.2升级到1.12.3时，我会得到一个新的运行时错误。我可以脱下我的Flink应用程序到这两条线上： public static void main(String[] args) throws不会触发Flink版本1.12.2的任何错误。("org.apache.flink:flink-clients
浏览 8提问于2021-04-29得票数 0
回答已采纳
3回答
如何为一组操作/工作流创建DAG表示？
workflow、apache-flink、directed-acyclic-graphs、stream-processing
我们使用apache flink进行流处理。文档说，flink基于定义的操作(对流数据的转换链)生成执行图/DAG。我还可以在UI门户上看到DAG表示。
我有点好奇如何在幕后做到这一点。有没有为flink做这件事或者由Flink自己实现的可用的库？
浏览 33提问于2020-02-10得票数 0
1回答
Apache表-演练缺少依赖关系？
apache-flink
我正在遵循的步骤。但是，在为mvn install项目运行时，会出现以下错误：
org.apache.flink.table.api.ValidationException: Could not find any factoriesthat implement 'org.apache.flink.table.delegation.ExecutorFactory' in the classpath.at org.apache.flink</em
浏览 8提问于2022-08-23得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
腾讯会议
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号