[
https://issues.apache.org/jira/browse/FLINK-28636?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler updated FLINK-28636:
-------------------------------------
Description:
Users should be encouraged to eagerly verify that their POJOs satisfy all the
requirements that Flink imposes, however we provide no convenient way to test
that.
They currently have to resort to something like below, which isn't obvious at
all:
{code:java}
TypeSerializer<Event> eventSerializer =
TypeInformation.of(Event.class).createSerializer(new
ExecutionConfig());
assertThat(eventSerializer).isInstanceOf(PojoSerializer.class);{code}
was:
Users should be encouraged to eagerly verify that their POJOs satisfy all the
requirements that Flink imposes, however we provide no convenient way to test
that.
They currently have to resort to something like below, which isn't obvious at
all:
{code:java}
TypeSerializer<Event> eventSerializer =
TypeInformation.of(Event.class).createSerializer(new
ExecutionConfig());
assertThat(eventSerializer).isInstanceOf(PojoSerializer.class);{code}
> Add utility to test POJO compliance
> -----------------------------------
>
> Key: FLINK-28636
> URL: https://issues.apache.org/jira/browse/FLINK-28636
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream, Tests
> Reporter: Chesnay Schepler
> Assignee: Chesnay Schepler
> Priority: Major
> Fix For: 1.16.0
>
>
> Users should be encouraged to eagerly verify that their POJOs satisfy all the
> requirements that Flink imposes, however we provide no convenient way to test
> that.
> They currently have to resort to something like below, which isn't obvious at
> all:
> {code:java}
> TypeSerializer<Event> eventSerializer =
> TypeInformation.of(Event.class).createSerializer(new
> ExecutionConfig());
> assertThat(eventSerializer).isInstanceOf(PojoSerializer.class);{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
