liming.1018

[FLINK-28010][state] Use deleteRange to optimize the clear method of RocksDBMapState.

6

## What is the purpose of the change This pull request will use `deleteRange` to optimize the `clear` method of `RocksDBMapState`. ## Brief change log Replace RocksDB's `Iterator` with `deleteRange`....

### Purpose When consuming multiple tables, it may be necessary to align data versions in different tables to ensure version consistency. However, the current stream mode only supports incremental processing...

修复 RpcChannel 中 netty 发送失败时未调用 callback 的问题

1

Fixes #94. 在 RpcChannel 的netty发送失败时回调 callback，以保证正确的错误信息被透出以及加速失败的响应耗时。

Netty channel 在发送消息到server端时可能出现失败，但是目前没有对channelFuture进行处理，导致只能依靠超时来确保不会完全hang住，但这种方式丢失了正确的异常栈，让问题很难排查。 https://github.com/baidu/Jprotobuf-rpc-socket/blob/master/jprotobuf-rpc-core/src/main/java/com/baidu/jprotobuf/pbrpc/transport/RpcChannel.java#L141 这是使用 arthas 捕获到的一个特殊case的异常信息，但是在任何地方都没有对异常进行处理，最终只能等待RPC调用超时。 ``` method=io.netty.channel.AbstractChannelHandlerContext.writeAndFlush location=AtExit ts=2024-02-20 11:52:40; [cost=0.064681ms] result=@ArrayList[ io.netty.handler.codec.EncoderException: java.lang.RuntimeException: Negative initial size: -736704836 at io.netty.handler.codec.MessageToMessageEncoder.write(MessageToMessageEncoder.java:104) at io.netty.channel.AbstractChannelHandlerContext.invokeWrite0(AbstractChannelHandlerContext.java:881) at io.netty.channel.AbstractChannelHandlerContext.invokeWrite(AbstractChannelHandlerContext.java:863) at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:968) at io.netty.channel.AbstractChannelHandlerContext.write(AbstractChannelHandlerContext.java:856)...

[Feature] When the MergeEngine of the dimension table is aggregation / partial-update, there is no need to forcibly enable changelog-producer.

4

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Currently, two built-in compaction strategies are provided, but they are mainly set automatically...

[flink] refactor the code of the lookup and support computing the changelog generated by compact during read time.

4

### Purpose Linked issue: close #3868 [flink] refactor the code of the lookup and support computing the changelog generated by compact during read time. This is used when changelog producer...

[Bug] java.lang.NoSuchMethodError: org.apache.parquet.hadoop.ParquetFileReader.<init> when running BranchSqlITCase in IDEA

8

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version paimon-1.0-SNAPSHOT ### Compute Engine flink ### Minimal reproduce step Run BranchSqlITCase in...