Alexis Sarda-Espinosa created FLINK-10194:
-
Summary: Serialization issue with Scala's AggregateDataSet[Row]
Key: FLINK-10194
URL: https://issues.apache.org/jira/browse/FLINK-10194
Pr
Thanks!
I tested the KeyedSerializationSchema and it indeed works.
I tried to use TypeInformationKeyValueSerializationSchema just to make
things a bit more automated :)
--
View this message in context:
http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Serialization-Issue
; FlinkKafkaProducer010.FlinkKafkaProducer010Configuration
> flinkKafkaProducerConfig = FlinkKafkaProducer010.writeToKafkaWithTimestamps(
> stream,
> "topic",
> schema,
> kafkaProducerProperties);*
>
>
>
> --
> View this message in context:
> http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/Serialization-Issue-tp19400p19401.html
> Sent from the Apache Flink Mailing List archive. mailing list archive at
> Nabble.com.
ializationSchema<>(resultType,
resultType, env.getConfig());
FlinkKafkaProducer010.FlinkKafkaProducer010Configuration
flinkKafkaProducerConfig = FlinkKafkaProducer010.writeToKafkaWithTimestamps(
stream,
"topic",
schema,
kafkaProducerProperties);*
--
My stream is producing records of type Tuple2
*.toString()* output *(usr12345,{"_key":"usr12345","_temperature":46.6})*
where the key is *usr12345* and value is
*{"_key":"usr12345","_temperature":46.6}*
The *.print()* on the stream outputs the value correctly:
*(usr12345,{"_key":"usr12345","_tem
Metzger
wrote:
> Were you able to resolve the issue?
>
> I first thought its an JVM-version incompatibility, but this thread
> suggests a serialization issue:
>
> http://stackoverflow.com/questions/851491/java-deserialization-of-java-lang-integer-exception
>
> By the way
Were you able to resolve the issue?
I first thought its an JVM-version incompatibility, but this thread
suggests a serialization issue:
http://stackoverflow.com/questions/851491/java-deserialization-of-java-lang-integer-exception
By the way: your emails to the dev@ list sometimes end up in the
Hi,
I want to use t-digest by Ted Dunning (
https://github.com/tdunning/t-digest/blob/master/src/main/java/com/tdunning/math/stats/ArrayDigest.java)
on Flink.
Locally that works perfectly. But on the cluster I get the following error:
java.lang.Exception: Call to registerInputOutput() of invokab
