λ
полный стектрейс кидай
Size: a a a
2021 January 22
RK
Не знаю, туда ли я копаю, но по идее Kryo не должен использоваться после того, как я указал следующее:
RK
val env = StreamExecutionEnvironment.getExecutionEnvironmentvar executionConfig = env.getConfig
executionConfig.enableForceAvro()
executionConfig.disableForceKryo()RK
В документации про avro десериализаторы ничего про этот Kryo-шмио не сказано https://ci.apache.org/projects/flink/flink-docs-stable/dev/connectors/kafka.html#the-deserializationschema
RK
Но, наверное, я просто вообще не в теме 😂
GP
Caused by: com.esotericsoftware.kryo.KryoException: java.lang.UnsupportedOperationException
Serialization trace:
reserved (org.apache.avro.Schema$Field)
fieldMap (org.apache.avro.Schema$RecordSchema)
schema (org.apache.avro.generic.GenericData$Record)
Serialization trace:
reserved (org.apache.avro.Schema$Field)
fieldMap (org.apache.avro.Schema$RecordSchema)
schema (org.apache.avro.generic.GenericData$Record)
пытаешься сериализовать несериализуемое
GP
мапу какуюто и для нее неверный сериалайзер
λ
походу авро схему
GP
RK
case class URLResponse (status: Int, domain: String, url: String, queue: String, html: String)RK
val schema: Schema = AvroSchema[URLResponse]RK
val stream = env.addSource(new FlinkKafkaConsumer[GenericRecord](
kafkaTopic, ConfluentRegistryAvroDeserializationSchema.forGeneric(schema, schemaRegistryURL), properties))RK
пытаешься сериализовать несериализуемое
пытаюсь десериализовать
GP
пытаюсь десериализовать
схему сделай функцией или транзиент лейзи валом
GP
и посмори что будет
GP
десериайлайзер несериализуем
RK
изменений нет, такая же ошибка 🙁
λ
У кого есть опыт кросс-билда большого проекта с кучей внешних зависимостей со Scala 3?
Как заюзать либы, не опубликованные под скала 3 в режиме совместимости?
Как заюзать либы, не опубликованные под скала 3 в режиме совместимости?
λ
У кого есть опыт кросс-билда большого проекта с кучей внешних зависимостей со Scala 3?
Как заюзать либы, не опубликованные под скала 3 в режиме совместимости?
Как заюзать либы, не опубликованные под скала 3 в режиме совместимости?
Вопрос про sbt билд