Re: "Not all slot managed memory is freed"

equals to the > total memory in the memory manager. > > G > > > On Tue, Oct 29, 2024 at 6:03 PM Jad Naous wrote: > >> Hi Flink Community, >> I'd really appreciate your help. We're trying to switch from using the >> heap state backend to rocksdb, and

"Not all slot managed memory is freed"

Hi Flink Community, I'd really appreciate your help. We're trying to switch from using the heap state backend to rocksdb, and have been encountering a warning "Not all slot managed memory is freed at TaskSlot..." when the pipeline restarts. Any pointers to troubleshoot this issue? Many thanks! Jad.

Re: Using User-defined Table Aggregates Functions in SQL

mUnconditionalRewrites(SqlValidatorImpl.java:1296) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.performUnconditionalRewrites(SqlValidatorImpl.java:1296) > at > org.apache.calcite.sql.validate.SqlValidatorImpl.validateScopedExpression(SqlValidatorImpl.java:993

Using User-defined Table Aggregates Functions in SQL

Hi, The docs don't mention the correct syntax for using UDTAGGs in SQL. Is it possible to use them with SQL? Thanks, Jad Naous <https://streaklinks.com/B4WFYnXoaG38kHdC2w4IJpgT/https%3A%2F%2Fwww.linkedin.com%2Fin%2Fjadnaous%2F> Grepr, CEO/Founder ᐧ

Re: NPE in Calcite RelMetadataQueryBase

hould each thread built its own? Thanks! Jad Naous <https://www.linkedin.com/in/jadnaous/> Grepr, CEO/Founder On Fri, Oct 13, 2023 at 5:42 PM Jad Naous wrote: > Hi all, > > We're using the Table API to read in batch mode from an Iceberg table on > s3 using DynamoDB a

NPE in Calcite RelMetadataQueryBase

Hi all, We're using the Table API to read in batch mode from an Iceberg table on s3 using DynamoDB as the catalog implementation. We're hitting a NPE in the Calcite planner. The same query works fine when using the local FS and in-memory catalog. Below is a snipped stacktrace. Any thoughts on how