1回答
目前，我正在为一些分布式处理工具构建基准测试工具，Apache Flink遇到了一些问题。pojoList.stream().min(new LogPojo.Comp()).get().getValue();public double processLogso1 : o2;
浏览 15提问于2017-03-09得票数 0
回答已采纳
我们的一些POJO包含来自java.time接口(LocalDate，LocalDateTime)的字段。当我们的管道处理它们时，我们可以在日志中看到以下信息：
org.apache.flink.api.java.typeutils.TypeExtractor - Class class java.time.LocalDate据我所知，LocalDate不能归类为POJO，所以flink不使用POJO</em
浏览 240提问于2021-02-17得票数 1
回答已采纳
flink运行时正在崩溃，因为它无法实例化org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils 下面是堆栈跟踪： stack: java.lang.ClassCastException: class org.apache.flink.formats.avro.utils.AvroKryoSerializerUtils
java.lang.RuntimeException: Couldat org.
浏览 38提问于2020-09-25得票数 0
我尝试创建3个数据类--每个序列化类型一个：
向数据类中添加
浏览 66提问于2022-07-02得票数 2
在flink项目中，我使用case类单击。访问单击对象的日期字段的某些函数会引发NullPointerExceptions。这些函数的例子是getHourOfDay、toString等。我能够确保click类的date字段不是null。如何使用java.typeutils.runtime.kryo？16:44:53,998 DEBUG org.<e
浏览 11提问于2015-11-11得票数 4
回答已采纳
我正在使用Flink的Scala。我在reports = DataStream[Tuple15]上进行了一些转换( Tuple15是Scala，所有字段都是Int)。Type: GenericType<scala.Tuple5> at org.apache.f
浏览 7提问于2016-07-06得票数 4
回答已采纳
1回答
我使用flink动态地分析json类型数据，并使用给定列进行keyby和sum，在我的mapFunction中，我将json转换为case类，但是结果流没有在keyBy函数中得到编译器，得到了这样的错误Exception in thread "main" org.apache.flink.api.common.InvalidProgramException: This type (GenericType<java.lang.Object>) cannot
浏览 4提问于2020-09-29得票数 1
我正在用Kotlin编写Flink应用程序，数据类(以及其他Kotlin类)没有标识为有效的POJO类型。Flink文档指出，如果满足以下条件，数据类型将被识别为POJO类型(并允许“按名称”字段引用)：
[main] INFO org.apache.flink.api.java.ty
浏览 15提问于2019-01-18得票数 4
回答已采纳
我使用的是Flink 1.12.0，我有以下简单的测试用例：public interfaceAbstractDataModel，但是有编译错误抱怨：MapFunction<com.ConcreteModel,java.lang.String>如果我仍然想使用AbstractDataModel作为MapFunction中的泛型
浏览 5提问于2021-06-29得票数 0
回答已采纳
不是一个错误，但我确实看到了这一行，根据消息可能会影响性能： 2019-01-02 14:44:44,879 INFO org.apache.flink.api.java.typeutils.TypeExtractor- class org.apache.flink.streaming.connectors.kafka.internals.KafkaTopicPartition 2019-01-02 14:44:44,8
浏览 123提问于2019-01-02得票数 0
2回答
，它有一个字符串字段'keyfield‘。然后在这个字段上输入流。at org.apache.flink.util.Preconditions.checkNotNull(Preconditions.java:75)
at org.apache.flink.runtime.state.heap.CopyOnWriteStateTable.checkKeyNamespacePreconditions(CopyOnWriteStateTable.ja
浏览 0提问于2018-02-01得票数 4
回答已采纳
我不需要将"file.csv“打开到目录中，逗号分隔的元素通过Flink传递给EventDeserializationSchema，这个元素用于"Event”来处理每个事件。import java.io.Serializable;import org.apache.flink.sh
浏览 0提问于2020-10-29得票数 0
回答已采纳
3回答
我有一个类可以满足作为POJO处理的需求，这是流作业中的主要传输类(它只包含原语和Map<String, String>)。我添加了一个新的String字段和相应的getter和setter，但是如果我停止使用带有保存点的前一个类的作业，并尝试使用它重新启动新类，则会得到一个异常： at org.apache.flink.runtime.taskmanager.Task.doRun(Tas
浏览 31提问于2020-11-05得票数 0
回答已采纳
我有scala类，它有两个字段，即、vals、，但是flink说它没有setter。因此，任务是不可序列化的。19:54:49.997 [main] DEBUG o.a.flink.api.scala.ClosureCleaner:172)Caused by: java.io.NotSerializableExcept
浏览 7提问于2016-08-08得票数 3
相关问题：https://issues.apache.org/jira/browse/FLINK-14380 在使用类型提取器Flink判断一个类是否符合POJO时，Flink会检查该类是否实现了setter问题位于https://github.com/apache/flink/blob/master/flink-c
浏览 37提问于2019-10-12得票数 2
在我的Flink应用程序中，我使用java.time.Instant来表示UTC时间戳。应用程序运行正常，但我最近在Flink日志中注意到了这条消息：当我去阅读文档时，没有太多关于使用</em
浏览 93提问于2020-02-05得票数 0
回答已采纳
我的Flink管道目前使用一个Pojo，其中包含一些列表和映射( Strings)，按照 private List<String> myList =at org.apache.flink.api.java.typeutils.GenericTypeInfo.createSerializer(GenericTypeInfo.java:86)at org.apache.flink</e
浏览 16提问于2020-01-18得票数 3
回答已采纳
1回答
我在flink上有个问题。我实时计算引擎使用groovy脚本扩展计算类型(如:sum、average、、count等)。然后，应用程序可以逐个任务地读取脚本，并通过GroovyClassLoader加载到虚拟机中。这个程序不用再用Flink了，看工作做的很好。原因是Flink使用另一个ClassLoader (FlinkUserCodeClassLoaders$ChildFirstClassLoader)在检查点加载由groovy脚本实例化的对象，而不是使用at org
浏览 2提问于2019-01-14得票数 2
我对Flink的表-api (1.13+)有一些问题.我有一个包含几个字段的POJO，其中之一是：我为这个字段使用以下声明来创建我的表： ...之后，当我试图使用DataStream方法将表转换为toRetractStreamMY_POJO时，我得到了以下错误：
未注册表的查询结果和接收器的线程“主”or
浏览 2提问于2022-01-19得票数 5
1回答
我在flink中使用广播状态模式，在这里我试图连接两个流，一个流是规则的控制流，另一个流是整数流(用于虚拟播放目的)。修改代码以将int字段val2添加到Rule中，如上面所示。创建一个新jar.
尝试使用flink -s <savepoint>命令还原作业。在org.apache.flink.streaming.api.operators.BackendRestorerProcedure.createAndRestore(BackendRestorerPr
浏览 3提问于2022-05-06得票数 0
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
