@flink.apache.org
Subject: [BULK]Re: DisableGenericTypes is not compatible with Kafka
Unfortunately, the fact that the Kafka Sources use Kryo for state
serialization is a very early design misstep that we cannot get rid of
for now. We will get rid of that when the new source interface lands
([1]) and
?
Thanks
Kind Regards
Oleksandr
From: Aljoscha Krettek
Sent: Tuesday, February 4, 2020 2:29 PM
To: user@flink.apache.org
Subject: [BULK]Re: DisableGenericTypes is not compatible with Kafka
Unfortunately, the fact that the Kafka Sources use Kryo for state
serialization
Unfortunately, the fact that the Kafka Sources use Kryo for state
serialization is a very early design misstep that we cannot get rid of
for now. We will get rid of that when the new source interface lands
([1]) and when we have a new Kafka Source based on that.
As a workaround, we should chan
Hi,
I think there could be two workaround ways to 'disableGenericType' in case
of KafkaSource :
1. adding the TypeInfo annotation [1] to the KafaTopicPartition.
2. using the reflection to call the private method. :)
Maybe we could add this TypeInfo annotation to the KafakaConnector.
[1]
https://c
Hi guys,
We have encountered on some issue related with possibility to
‘disableGenericTypes’ (disabling Kryo for the job). It seems a very nice as
idea to ensure that nobody introduce some random change which penalize the
performance of the job.
The issue we have encountered is that Flink’s Ka
