使用DataStream函数创建fromElements函数时出错
由: java.io.IOException:未能从源反序列化元素引起。如果正在使用用户定义的序列化(Value和Writable类型)，请检查序列化函数.序列化程序是org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer@599fcdda at org.apache.flink.streaming.a
浏览 7提问于2015-12-20得票数 1
我的Flink管道目前使用一个Pojo，其中包含一些列表和映射( Strings)，按照 private List<String> myList =，因此我禁用了env.getConfig().disableGenericTypes();的通用回退，如中所述。(StreamGraphGenerator.java:250)
at org.apache.flink.streaming.api.graph.StreamGraphGenera
浏览 16提问于2020-01-18得票数 3
回答已采纳
1回答
我已经写了一个小的flink应用程序。我有一些输入，并用来自外部源的数据来丰富它。它是一个RichAsyncFunction，在open方法中，我构造了一个用于丰富的http客户端。现在我想为我的工作写一个集成测试。但是由于http客户端是在open方法中创建的，所以我没有办法提供它，并在我的集成测试中模拟它。我试图在构造函数中重构它，但我总是得到序列化错误。这是我正在使用
浏览 28提问于2020-06-01得票数 2
我有一个在flink流中序列化的参数params， class P extend Serializable {...}new MyMap(params))env.setParallelism(1)
env.execute("My Job") 但是驱动节点中的参数会发生变化有没有可能基于flink流作业不停顿？
浏览 24提问于2020-06-30得票数 0
回答已采纳
1回答
在我的Flink反序列化程序中，我从getProducedType方法中得到以下错误： at org.apache.flink.streaming.api.operators.AbstractStreamOperator:86)
at org.ap
浏览 31提问于2018-01-03得票数 3
回答已采纳
'flink-core', version: '1.9.0'
// https://mvnrepository.com/artifact/org.apache.flink/flink-streaming-javacompile group: 'org.apache.flink', name: 'flink-streaming
浏览 4提问于2020-03-09得票数 0
回答已采纳
我创建了一个计算维基百科单词的程序。它工作正常，没有任何错误。然后，我创建了带有两列"word(text)和count(bigint)“的Cassandra表。127.0.0.1") }
env.execute("Streamingtoken, 1)); } }
浏览 0提问于2018-12-24得票数 0
回答已采纳
我实现了一个ProcessFunction，它使用Guava缓存来过滤传入的事件流。(StreamExecutionEnvironment.java:1560)at org.apache.flink.streaming.api.datastream.DataStream.process(DataStream.java:666)
at org
浏览 132提问于2019-04-02得票数 0
我是flink和Kafka的新手。我正在尝试使用Confluent Schema注册表对avro数据进行反序列化。我已经在ec2机器上安装了flink和Kafka。运行flink可执行jar的命令： ./bin/flink run -c com.streaming.example.ConfluentSchemaRegistryExample /opt/flink-1.7.2/kafka
浏览 43提问于2019-04-22得票数 1
我正在尝试使用Scala和Flink将消息发布到Kafka主题中。但是，当使用中提供的代码创建FlinkKafkaProducer对象时，它告诉我无法应用构造器。._这就是我得到的错误：
/home/user/Flink/flinkproj/src/main/s
浏览 103提问于2021-05-24得票数 1
我正在尝试做一个POC的Flink状态模式演变。我使用的是Flink 1.15.0和Java 11。我尝试创建3个数据类--每个序列化类型一个：
io.peleg.kryo.User -使用java.time.Instant类，我知道Flink中的POJO序列化不支持这个类。不支持Kryo序列化类的状态模式演化。但在我看来，对于所有类，它最终都使用了Kryo序列化程序，而不是P
浏览 66提问于2022-07-02得票数 2
我正在编写一个从kafka消费的flink应用程序
FlinkKafkaConsumer<MyPojo> consumer = new FlinkKafkaConsumer(TOPIC, new MyPojoDesorg.apache.flink.streaming.runtime.tasks.OperatorChain$CopyingChainingOutput.pushToOperator(OperatorChain.java:577) at org.apache.flink.st
浏览 2提问于2020-12-08得票数 0
1回答
我试图通过提供Kryo序列化程序来解决以下问题，但它仍然不起作用。它无法识别ModelCom的序列化程序。此外，任何打印功能的消息都不会显示出来。我使用的是Apache Flink 1.9.0和Apache Jena 3.10.0 我的Kotlin代码： val serializer = object : Serializer<Model>(){at org.apache.flink.streaming.api.graph
浏览 21提问于2020-04-27得票数 1
回答已采纳
1回答
我正在尝试运行一个简单的程序，它从一个动态流中读取，做一个琐碎的转换，并将结果写入另一个动态流。} at org.apache.flink.streaming.api.functio
浏览 1提问于2018-06-13得票数 0
回答已采纳
1回答
我有一个Flink应用程序，它保持与这个错误的错误。 com.org.ads.audience.traffic.MyClass@6eaa21d8 is not serializable.(StreamExecutionEnvironment.java:1558) org.apache.flink.stream
浏览 448提问于2019-09-25得票数 1
我无法让它使用不推荐的构造函数序列化数据(这并不奇怪)，我也无法在网上找到任何关于如何实现序列化器的实现或示例(所有示例都使用旧的Kafka连接器)FlinkKafkaProducer010<init>(FlinkKafkaProducer.java:525)
at org.apache.flink.streaming.connectors.kafka.FlinkK
浏览 1提问于2019-10-31得票数 6
回答已采纳
我正在尝试写案例类序列化到AVRO到HDFS使用RollingSink在Flink。为了让avro文件可以被HDFS反序列化，我使用了包装FSDataOutputStream的DataFileWriter。当我试图在DataFileWriter和FSDataOutputStream之间同步以便关闭HDFS上的数据文件时，抛出异常，实际上我每隔一个文件就会得到数据。有没有办法在Flink writer实现中同步fs流和Avro编写器？
我尝试过使用DataFileWrit
浏览 1提问于2016-03-24得票数 0
我一直试图使用文档中的参数sink.buffer-flush.max-rows和sink.buffer-flush.interval缓冲来自upsert连接器的输出。每当我尝试运行带有缓冲的INSERT查询时，我都会收到以下错误(缩写为简洁)： at org.apache.flink.streaming.connectors.kafka.table.ReducingUps
浏览 16提问于2022-02-01得票数 0
下面提到的Apache测试代码在我想使用KeyedOneInputStreamOperatorTestHarnessK、IN、Int或Long作为key (K)参数时不会在Scala中编译。可以使用字符串、整数或java.lang.Long类型的泛型参数编译相同的代码：importimport org.apache.flink.str
浏览 7提问于2021-12-31得票数 2
我正在编写一个Apache流应用程序，它反序列化数据(Avro格式)，读取一个Kafka总线(关于的更多细节)。数据正在反序列化为Scala案例类。当我运行这个程序时，我得到了一个异常，它收到了Kafka的第一条消息。(Kafka09Fetcher.java:142) at org.apache.flink</
浏览 1提问于2018-07-02得票数 5
回答已采纳
云服务器
ICP备案
云直播
对象存储
腾讯会议
腾讯云开发者
