Re: left join failing with FlinkLogicalJoinConverter NPE

Hi, I also found the similar issue here [1]. Best, Tony Wei [1] https://issues.apache.org/jira/browse/FLINK-11433 Tony Wei 於 2019年7月19日 週五 下午5:38寫道： > Hi, > > Is there any update for this issue? I have had the same problem just like > Karl's. > After I remove query like "select collect(data) .

Re: left join failing with FlinkLogicalJoinConverter NPE

Hi, Is there any update for this issue? I have had the same problem just like Karl's. After I remove query like "select collect(data) ..." from one of the joined tables, the sql can be executed correctly without throwing any NPE. Best regards, Tony Wei Xingcan Cui 於 2019年2月27日 週三 下午12:53寫道： >

Re: left join failing with FlinkLogicalJoinConverter NPE

Hi Karl, I think this is a bug and created FLINK-11769 to track it. Best, Xingcan > On Feb 26, 2019, at 2:02 PM, Karl Jin wrote: > > I removed the multiset> field and the join worked fine. > The field was created from a Kafka source through

Re: left join failing with FlinkLogicalJoinConverter NPE

I removed the multiset> field and the join worked fine. The field was created from a Kafka source through a query that looks like "select collect(data) as i_data from ... group by pk" Do you think this is a bug or is this something I can get around using some configuration? On Tue, Feb 26, 2019 a

Re: left join failing with FlinkLogicalJoinConverter NPE

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 so how do I deal with it (I think I can verify by removing those columns > and retry?)? > >

Re: left join failing with FlinkLogicalJoinConverter NPE

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 on the two ta

Re: left join failing with FlinkLogicalJoinConverter NPE

Thanks for checking in quickly, Below is what I got on printSchema on the two tables (left joining the second one to the first one on uc_pk = i_uc_pk). rowtime in both are extracted from the string field uc_update_ts root |-- uc_pk: String |-- uc_update_ts: String |-- rowtime: TimeIndicatorTyp

Re: left join failing with FlinkLogicalJoinConverter NPE

Hi Karl, It seems 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 please let me know if the formatting isn

left join failing with FlinkLogicalJoinConverter NPE

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