我正在读Flink hive连接器代码，找到接口HiveShim，它有很多实现类。但是我发现实现类使用了反射API。为什么不导入依赖项，代码如此晦涩难懂。
浏览 14提问于2021-10-23得票数 0
回答已采纳
我正在通过prometheus Flink metrics Reporter向Prometheus发送自定义应用程序指标。指标创建正确，因为我能够在flink仪表板中准确地看到它们。当我转向prometheus端点(curl http://localhost:9090/api/v1/metrics)时，我只能看到集群指标，而不能看到我正在创建的自定义指标。创建指标的flink工作代码(在Flin
浏览 45提问于2021-08-06得票数 2
我想使用flink sql client创建一个配置单元表。我已经在conf/sql-client-defaults.yaml文件中设置执行类型为batch。 我会问这里有什么问题。谢谢!Flink SQL> use testdb1;
[INFO] Table has been createdFlink SQL&g
浏览 103提问于2020-12-21得票数 0
回答已采纳
1回答
如果我向flink和提交了一个作业，那么我知道此任务所需的最大内存。如何调整工作中的任务管理器内存？
浏览 7提问于2022-05-01得票数 0
回答已采纳
我刚刚尝试使用Rosetta 2兼容层在苹果Mac上运行和新的M1处理器。flink-1.12.2 ./bin/flink run .WARNING: Please consider reporting this to the maintainers of org.apache.flink.api.java.ClosureCleaner有没有机会在苹果的硅上执行Flink作业？
编辑(13.04
浏览 2提问于2021-04-13得票数 3
1回答
我只是尝试在Flink中使用Scala类型的类。LikeEvent](payload: T): Event[T] = Event(payload) 我得到以下错误：found : org.apache.flink.api.scala.DataSet[Product with Serializable]
required: org.apache.flink.api.scala.DataSet[com.salvalcantara.
浏览 5提问于2020-04-13得票数 2
回答已采纳
我试图使用google反射库扩展flink进程的业务逻辑。我在运行时被这个异常困住了。有人做过同样的实验吗。我怀疑有冲突，但我不知道。我粘贴了异常和pom文件。 <?<exclude>org.apache.flink:flink-core</exclude>
<exclude>org.apache.flinkexclude>commons
浏览 1提问于2018-02-28得票数 1
2回答
我正在尝试从运行在clojure中的Apache中获得一个小示例，但是现在我被困住了，因为clojure中的类型暗示和flink中的一些奇怪的怪癖。这是我的代码： (:import (org.apache.flink.api.common.functionsFlatMapFunction)
(o
浏览 2提问于2015-08-20得票数 5
回答已采纳
Flink /SQL有很多关于DataType系统的包，包括：
org.apache.flink.table.api.DataTypesorg.apache.flink.table.api.Typesorg.apache.flink.table.types.DataTypeorg.apache.flink.table.data我对软件包之间的关系相当困惑，有人能给我一些提示来理解Flink开发人员的想法吗？
浏览 1提问于2021-03-07得票数 0
回答已采纳
1回答
Flink码头组合自定义库
、、、、
我正在尝试设置一个Flink会话集群使用坞-撰写。我希望在Flink中加载一个自定义库，因为这个库包含我所有作业使用的代码。当我使用Web提交作业时，我的作业运行正常，只有一个例外：
在我的库中，我有一个flink映射操作符(称为DeserialisationMapper)，它使用来自Kafka的JSON消息，并根据消息中的标记创建定制的我使用Java反射来实现这
浏览 6提问于2020-11-11得票数 0
我在Flink (Java)中创建了一个程序来计算3个不同房间平均9个假传感器。如果启动jar文件，程序运行良好。为什么我不能看到作业在仪表板()上运行，但是如果我看到日志文件(尾-f日志/flink-客户机-*-T430.log)，我可以看到正在处理的东西？此外，print()方法正在将输出溢出到控制台。我使用以下命令./bin/flink run examples/expl
浏览 0提问于2019-02-01得票数 0
回答已采纳
假设我有通过Kafka主题输入的数据，并将输出数据发送给Kafka主题，那么在什么情况下Flink能够比Kafka流更快地处理数据？至少说到花在消费和生产上的时间，我不会期望Flink比Kafka流更快。
浏览 3提问于2022-08-09得票数 0
我有一个在本地运行良好的Flink作业，但是当我尝试在集群上flink run作业时失败了。它基本上是读卡夫卡，做一些转换，并写到一个水槽。</groupId>Caused by: org.apache.flink.table
浏览 16提问于2021-03-10得票数 0
回答已采纳
我已经在IDE (Intellij)和独立集群中运行了我的Flink程序(在Scala中)。在我的程序中，我打印出运行时间。在IDE中运行时，我得到了20多个，在独立集群中运行的是74s。我非常困惑，为什么在一个具有10个并行性的集群中运行这么多次。我试图比较Flink性能与火花基本上。有人能
浏览 3提问于2021-07-11得票数 0
2回答
我使用Flink (最新的通过git)从卡夫卡流到卡桑德拉。为了简化单元测试，我通过Dagger添加了依赖注入。ObjectGraph似乎正在正确地设置自己，但是Flink将“内部对象”标记为“不可串行化”。如果我直接包括这些对象，它们就能工作-那么有什么区别呢？类实现了、MapFunction、和@Inject，一个用于cassandra的模块，一个用于读取配置文件。
是否有一种方法来构建这个，以便我可以使用后期绑定，还是Flink使这不可能？Dagger不允许<em
浏览 4提问于2015-12-06得票数 11
回答已采纳
我们开始使用Apache进行数据流处理。它处理数据，然后更新接收器中的数据库。我们将数据库端点/凭据配置为Flink配置数据(因为我们有标准dev/test/prod设置)，但不幸的是，密码/api-键与所有其他配置数据一起以明文形式显示在Flink配置仪表板中。是否有一种配置flink的方法，以便java代码仍然可以通过
浏览 0提问于2019-09-10得票数 2
1回答
Flink状态模式迁移
、、、
我在一个使用MemoryStateBackend的独立集群上有一个flink流应用程序。Kryo的TaggedFieldSerializer被用作默认的序列化程序。当我更改状态的模式并重新部署应用程序时，我得到了以下异常at org.apache.<e
浏览 1提问于2018-03-10得票数 1
回答已采纳
我正在开发一个Java应用程序，它在Flink 1.14上使用UDF。我使用PipelineOptions.JARS配置在应用程序代码中动态添加包含UDF类的jar文件，但是应用程序无法使用ClassNotFoundException从配置好的jar文件加载UDF类。如果使用“Flink run”和"-C“选项来更新类路径，通过flink</em
浏览 20提问于2021-12-15得票数 0
大多数情况下，计算可以在不知道其他处理器的状态的情况下完成。如果是这样的话，您有另一个Streams实例来计算结果。如图所示：Flink到底在哪里存储它的状态？Flink是否也可以在本地存储状态，或者总是将它们发布到所有实例(任务)？是否可以将Flink配置为将状态存储在Kafka代理中？
浏览 0提问于2019-02-10得票数 3
1回答
查找有关在何处存储/访问Flink参考数据的建议。这里的用例非常简单--我有一个包含国家列表的单列文本文件。我正在发送twitter数据，然后根据tweet的(已解析的)位置字段从文本文件中匹配国家。在IDE (Eclipse)中，这一切都很好，因为在我的Flinks (即实现Flinks ArrayList )中，当例程通过静态构建方法触发时，就填充了一个静态MapFunction。要点是，当在运行时从流中调用重写的map函数时，国家数据的
浏览 2提问于2017-12-15得票数 1
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号