Re: left join failing with FlinkLogicalJoinConverter NPE

2019-02-26 Thread Karl Jin
Feb 26, 2019 at 1:20 AM Xingcan Cui wrote: > Yes. Please check that. If it's the nested type's problem, this might be a > bug. > > On Mon, Feb 25, 2019, 21:50 Karl Jin wrote: > >> Do you think something funky might be happening with Map/Multiset types? >> If

Re: left join failing with FlinkLogicalJoinConverter NPE

2019-02-25 Thread Karl Jin
Do you think something funky might be happening with Map/Multiset types? If so how do I deal with it (I think I can verify by removing those columns and retry?)? On Mon, Feb 25, 2019 at 6:28 PM Karl Jin wrote: > Thanks for checking in quickly, > > Below is what I got on printSchema o

Re: left join failing with FlinkLogicalJoinConverter NPE

2019-02-25 Thread Karl Jin
ms that some field types of your inputs were not properly extracted. > Could you share the result of `printSchema()` for your input tables? > > Best, > Xingcan > > > On Feb 25, 2019, at 4:35 PM, Karl Jin wrote: > > > > Hello, > > > > First time posting, so

left join failing with FlinkLogicalJoinConverter NPE

2019-02-25 Thread Karl Jin
Hello, First time posting, so please let me know if the formatting isn't correct, etc. I'm trying to left join two Kafka sources, running 1.7.2 locally, but getting the below exception. Looks like some sort of query optimization process but I'm not sure where to start investigating/debugging. I s