Thanks alot it was really related to different versions.
I have one more question about this solution
the select statement returns list of results
i see that when retrieving data we activate row mapper which handles only
one row at a time
and return PCollection of that row
do i have a way to aggreg
Hi!
It is very likely that versions of your Flink client and Flink standalone
cluster do not match. SubtaskStateMapper.DISCARD_EXTRA_STATE is removed
since Flink 1.14 so please make sure that your Flink client version is also
1.14.
Sigalit Eliazov 于2021年11月10日周三 上午5:46写道：
> Hello
>
> i am creat
