You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@flink.apache.org by Kien Truong <du...@gmail.com> on 2017/12/01 12:42:54 UTC
Re: Non-intrusive way to detect which type is using kryo ?
Hi Timo,
Having a utility like that would be great. It'd be even better if it's
can be executed without having to actually run a cluster.
Best regards,
Kien
On 11/28/2017 3:39 PM, Timo Walther wrote:
> Hi Kien,
>
> at the moment I'm working on some improvements to the type system that
> will make it easier to tell if a type is a POJO or not. I have some
> utility in mind like `ensurePojo(MyType.class)` that would throw an
> exception with a reason why this type must be treated as a generic type.
>
> Would this help in your case?
>
> Regards,
> Timo
>
> Am 11/28/17 um 2:40 AM schrieb Kien Truong:
>> Hi,
>>
>> Are there any way to only log when Kryo serializer is used? It's a
>> pain to disable generic type then try to solve the exception one by one.
>>
>> Best regards,
>> Kien
>
>
Re: Non-intrusive way to detect which type is using kryo ?
Posted by Timo Walther <tw...@apache.org>.
Generally, you don't need to run it on the cluster. Types are available
in the so-called pre-flight phase (before calling env.execute()). So you
can just print the types in your IDE while developing:
"println(stream.getType)"
Regards,
Timo
Am 12/1/17 um 1:42 PM schrieb Kien Truong:
> Hi Timo,
>
> Having a utility like that would be great. It'd be even better if it's
> can be executed without having to actually run a cluster.
>
>
> Best regards,
>
> Kien
>
>
> On 11/28/2017 3:39 PM, Timo Walther wrote:
>> Hi Kien,
>>
>> at the moment I'm working on some improvements to the type system
>> that will make it easier to tell if a type is a POJO or not. I have
>> some utility in mind like `ensurePojo(MyType.class)` that would throw
>> an exception with a reason why this type must be treated as a generic
>> type.
>>
>> Would this help in your case?
>>
>> Regards,
>> Timo
>>
>> Am 11/28/17 um 2:40 AM schrieb Kien Truong:
>>> Hi,
>>>
>>> Are there any way to only log when Kryo serializer is used? It's a
>>> pain to disable generic type then try to solve the exception one by
>>> one.
>>>
>>> Best regards,
>>> Kien
>>
>>