Maybe this is related to this issue?
https://issues.apache.org/jira/browse/FLINK-17683
On Fri, Oct 30, 2020 at 8:43 PM Rex Fenley <r...@remind101.com> wrote:
> Correction, I'm using Scala case classes not strictly Java POJOs just to
> be clear.
>
> On Fri, Oct 30, 2020 at 7:56 PM Rex Fenley <r...@remind101.com> wrote:
>
>> Hello,
>>
>> I keep running into trouble moving between DataStream and SQL with POJOs
>> because my nested POJOs turn into LEGACY('STRUCTURED_TYPE', is there any
>> way to convert them back to POJOs in Flink when converting a SQL Table back
>> to a DataStream?
>>
>> Thanks!
>>
>> --
>>
>> Rex Fenley | Software Engineer - Mobile and Backend
>>
>>
>> Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/>
>> | FOLLOW US <https://twitter.com/remindhq> | LIKE US
>> <https://www.facebook.com/remindhq>
>>
>
>
> --
>
> Rex Fenley | Software Engineer - Mobile and Backend
>
>
> Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> |
> FOLLOW US <https://twitter.com/remindhq> | LIKE US
> <https://www.facebook.com/remindhq>
>
--
Rex Fenley | Software Engineer - Mobile and Backend
Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/>
| FOLLOW
US <https://twitter.com/remindhq> | LIKE US
<https://www.facebook.com/remindhq>
