HunterXHunter

在Hints里面增加参数： lookup.join.batch = 'true' lookup.join.batch.interval='10s' lookup.join.batch.buffer-size='1000'

环境：spark 1.6.0。kafka 0.10.0。CDH 5.14.4 程序使用spark 1.6 + kafka 010 来编写并编译。 但在spark-submit的时候遇到报错： noSuchMethod ： KafkaConsumer.assign(Collection partitions) 调试发现：程序加载的KafkaConsumer是 ：spark-assembly-1.6.0-cdh5.14.4-hadoop2.6.0-cdh5.14.4.jar 这个包里面的 KafkaConsumer 而不是编译的时候的 kafka_client-0.10.jar （通过 --jars 添加了） 。 spark-assembly是CDH自带的。我该怎么解决这个冲突呢。麻烦赐教。

[pom] Replaces the maven property with project property.

7

### Purpose In my production environment I get compilation errors : ``` [ERROR] Failed to execute goal com.diffplug.spotless:spotless-maven-plugin:2.13.0:check (spotless-check) on project paimon-parent: Execution spotless-check of goal com.diffplug.spotless:spotless-maven-plugin:2.13.0:check failed: Unable to...

[core] Fix Identifier should parse backquote.

6

When using flink procedure, table name can not parsed correctly when use `` quote. But Spark request use `` for SYSTEM_TABLE_SPLITTER ($) . So this is incompatible with Spark. e.g...

[core] Supports only execute specified actions during the writing process.

3

### Purpose There are several operations during data writing such as `partition-expire`,`snapshot-expire`,`create-tag`... Currently, these actions are either executed together or not executed at all in the framework. The purpose of...