roryqi

> > From my sight, this feature now can't be used in Spark SQL. Maybe RDD could use this. > > This test is based on draft pr [apache/spark#50248](https://github.com/apache/spark/pull/50248). cc...

> > From my sight, this feature now can't be used in Spark SQL. Maybe RDD could use this. > > This test is based on draft pr [apache/spark#50248](https://github.com/apache/spark/pull/50248). This...

> > > > From my sight, this feature now can't be used in Spark SQL. Maybe RDD could use this. > > > > > > > > >...

Do we use AuthorizationExpression to judge whether user is in the metalake?

> > Do we use AuthorizationExpression to judge whether user is in the metalake? > > It will be judged by the GravitinoAuthorizer. OK. LGTM.

Will this pull request be affected by https://github.com/apache/incubator-uniffle/pull/2196?

> @jerqi Sorry for the mistake reply, these metrics can show the effect of #2196. > > For our scenario, we use `LOCAL_MEMORY` storage type, so the `committed_block_count` and `cached_block_count`...

1. Alter and drop objects need the ownership. 2. List operation don't need privilege, but we need to filter objects which we don't have privileges. 3. ProduceTopic and ConsumeTopic will...

> If I get this correctly: > > before decoding --> `refCnt` is `1` after decoding --> `refCnt` is `1` (keep still) business codes call `release()` --> `refCnt` is `0`...

I suspect that the issue is caused by `TransportFrameDecoder` ``` @Override public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { // Release all buffers that are still in our ownership. // Doing...