我无法理解在从Hadoop获取输入文件时，如何在Flink中指定类型信息。
浏览 0提问于2017-03-30得票数 2
我是flink的新手，我正试图在emr集群上从flink 1.8升级到flink 1.11。升级到flink1.11之后，我看到的一个不同之处是，我没有得到任何度量。我发现flink 1.11在/usr/lib/ flink /opt中没有org.apache.flink.metrics.statsd.StatsDReporterFactory jar，这是flink是否有人有
浏览 2提问于2020-10-22得票数 0
我是Apache Flink的初学者，找不到任何关于扩展Flink核心的信息。我想从简单的开始:构建一个测试类。我应该将那个类保存为flink中的某个地方的jar-file吗？
浏览 0提问于2015-11-26得票数 1
我的Flink管道目前使用一个Pojo，其中包含一些列表和映射( Strings)，按照 private List<String> myList =// getters + setters...出于性能原因，我想绕过Kryo序列化，因此我禁用了env.getConfig().disableGenericTypes();的通用回退，如中所述org.apache.flink.api.java.typeutils.Pojo
浏览 16提问于2020-01-18得票数 3
回答已采纳
使用flink版本1.13.1
我写了一个自定义的度量报告，但在我的flink中似乎不起作用。, org.apache.flink.metrics.jmx.JMXReporterFactory, org.apache.flink.metrics.influxdb.InfluxdbReporterFactory但我已经在plugins文件夹中创建了名为“指标-kafka”的文件夹，而不是打包度量报告，并将jar文件复制到“指标-kafk
浏览 10提问于2021-08-25得票数 2
回答已采纳
1回答
我为Apache编写了一个非常简单的java程序，现在我对统计数据感兴趣，比如吞吐量(每秒处理的元组数)和延迟(程序处理每个输入元组所需的时间)。MyMapper().writeAsCsv("/home/LizardKing/Results.csv");
我知道Flink公开了一些指标：
但我不知道如何使用它们才能得到我想要的东西。从我所读到的链接中，可以使用“米”
浏览 1提问于2017-06-16得票数 2
回答已采纳
String]("topic", new SimpleStringSchema(), properties))
.build()
问题：如何在下沉前将org.apache.flink.api.scala.ClosureCl
浏览 16提问于2020-07-24得票数 0
1回答
我正在尝试在我的Scala Flink应用程序中按照文档测试一些有状态UDF： https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/datastream/testing/#unit-testing-stateful-or-timely-udfs--custom-operators 基于该链接，我在build.sbt文件中</e
浏览 36提问于2021-10-19得票数 0
1回答
我在flink上有个问题。我实时计算引擎使用groovy脚本扩展计算类型(如:sum、average、、count等)。我们定义了一个标准的计算接口(AbstractCompute)，如果我想在这个框架中扩展一个计算类型，我只需要执行AbstractCompute.and，然后将groovy脚本存储在数据库中。然后，应用程序可以逐个任务地读取脚本，并通过GroovyClassLoader加载到虚拟机中。这个程序不用再用Flink了，看工作做的很好。原因是Flin
浏览 2提问于2019-01-14得票数 2
在CentOS (CentOS 8.0.1905 (64位))上，我尝试在Flink(1.9)上运行Python(3.6.8)版本的WordCount程序，如所述。我得到的错误如下。同样的环境在Java版本的WordCount程序中也可以很好地工作。我在这里遗漏了什么？任何帮助都是非常感谢的。错误Starting execution o
浏览 7提问于2020-01-16得票数 0
如何在apache flink中启动和停止flink scala-shell 我已经使用命令/bin/start- scala -shell.sh local启动了flink scala shell。
浏览 50提问于2019-05-22得票数 0
我有两个流，一个是Int流，另一个是json .In，json，有一个键，就是一些int .So，我需要通过键比较来过滤json流和其他整数流，所以在Flink中可以吗？
浏览 1提问于2017-04-20得票数 2
回答已采纳
在Flink中，使用readCsvFile解析CSV文件会在包含引号的字段中引发异常，如"Fazenda São José ""OB"" Airport"：08:49:05,737 INFO
浏览 4提问于2016-07-11得票数 4
尝试在Scala2.10.4中使用0.10.0Flink版本的流api。在试图编译这个第一个版本时：import org.apache.flink.streaming.api.scala.DataStreamimport org.apache.flink.streaming.api
浏览 16提问于2015-11-15得票数 3
回答已采纳
2回答
我有一个关于在Flink中使用MapValue的问题，因为我需要将映射保存为状态的一部分，因为您知道状态需要是反序列化/可序列化的，所以我从MapValue扩展了类，因为MapValue是一个抽象类。(ReflectionUtil.java:141) at org.apache.flink.u
浏览 7提问于2022-09-07得票数 0
我在仪表板和IntelliJ中都使用Flink 1.3.2。ClassNotFoundException说，当我从源代码构建Flink时，我看到了很多警告消息，这使我相信迭代条件类没有包含在jar中，因为错误也是如此。下面是错误
Caused by: java.lang.NoClassDefFoundError: org/apache/flink/cep/pattern/conditions/IterativeCondition
浏览 1提问于2017-10-28得票数 0
回答已采纳
我试图使用Apache (org.apache.flink.streaming.util.OneInputStreamOperatorTestHarness)中的OneInputStreamOperatorTestHarness
浏览 5提问于2021-12-20得票数 -1
我正在对库伯奈特斯进行弗林克调查。我想如果我更新了TaskManager部署的副本，Kubernetes会为我增加/减少TM的数量，但我不确定这是否是我所需要做的全部。我还需要做些什么来使这份工作适应更多/更少的TMs吗？
浏览 3提问于2019-11-10得票数 1
回答已采纳
我试图在Flink中执行的代码的一部分： fieldDelimiter = "\t", includedFields= Array(1))不能将org.apache.
浏览 4提问于2015-07-08得票数 2
1回答
我有以下非常简单的Apache Flink Pipeline，我想通过Apache Flink Dashboard获得一些指标，如中所述：import org.apache.flink.configuration.Configuration;
import org.apache.fli
浏览 90提问于2020-03-02得票数 3
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号