Hi all,
I have a local Flink SQL app with Kafka source running with 3 partitions
(0,1,2).
I am running the following code:
final StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
final EnvironmentSettings settings =
EnvironmentSettings.newInstance().u
Hi all,
For Flink to treat a model class as a special POJO type, these are the
documented conditions:
https://nightlies.apache.org/flink/flink-docs-release-1.13/docs/dev/serialization/types_serialization/#pojos
It says the following:
-
All fields are either public or must be accessible th
Hi all,
Just wanted to follow up on this again :) Thanks in advance.
Regards,
Mac Pandey
On Tue, Jan 25, 2022 at 12:59 PM Makhanchan Pandey <
makhanchanpan...@gmail.com> wrote:
> Hi all,
>
> For Flink to treat a model class as a special POJO type, these are the
> doc
