Re: Exception Help

Are you sure you're always matching the output row type provided by DynamicTableFactory ? Also looking at the javadocs it seems like you can us

Re: Exception Help

No, I'm creating a custom SQL lookup table (which uses AsyncTableFunction) which requires the internal types. I implement the LookupTableSource, AsyncTableFunction, DynamicTableSourceFactory trio as per the examples in the docs. My construction is the equivalent of this, and it still errors with

Re: Exception Help

Hi, >From what I understand, you're creating a scalar function taking a string with json and then converting it to a map using a custom function. Assuming I understood correctly, I think the problem here is that you're using internal data types for UDFs, which is discouraged in most of the use ca

Re: Exception Help

I've narrowed it down to a TableSource that is returning a MAP type as a column. Only errors when the column is referenced, and not on the first row, but somewhere in the stream of rows. On 1.15 master branch (I need the new JSON features in 1.15 for this project so riding the daily snapshot durin

Re: Exception Help

Hi Jonathan, It would be better if you describe your scenario along with the code. It would be easier for the community to help. On Tue, 15 Feb 2022, 23:33 Jonathan Weaver, wrote: > I'm getting the following exception running locally from my IDE (IntelliJ) > but seems to not occur > when runnin

Exception Help

I'm getting the following exception running locally from my IDE (IntelliJ) but seems to not occur when running on a cluster. I'm assuming it may be related to memory settings on the runtime (machine has 64GB of ram avail) but not sure what setting to try and change. Caused by: java.lang.IndexOutOf