paimon

paimon copied to clipboard

### Purpose Linked issue: close #3219 Flink catalog doesn't support create database with properties, but jdbc and hive catalog actually support that. So this pr is to support create database...

Stephen0421

[Feature] Reduce redundant shuffle for spark dynamic bucket writes

2

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Dynamic bucket writing does two shuffles, the first `repartitionByKeyPartitionHash` seems unnecessary, It seems...

wForget

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation The `Call` syntax is defined in both Iceberg and Paimon, which may cause...

wForget

### Purpose Avoid frequent backpressure. ### Tests ### API and Format ### Documentation

JingsongLi

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Now the inner catalog already support hive and jdbc, but flink catalog still...

Stephen0421

[cdc]Fix: When the value of entry is null, subsequent java.lang.NullPointerException is thrown

4

Fix: When the value of entry is null, subsequent java.lang.NullPointerException is thrown paimon-flink/paimon-flink-cdc/src/main/java/org/apache/paimon/flink/action/cdc/format/RecordParser.java ### Purpose When the value of entry is null, subsequent java.lang.NullPointerException is thrown

scottxing

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version 0.7 ### Compute Engine flin 1.14.6 ### Minimal reproduce step CREATE CATALOG...

wudongdong00

### Search before asking - [X] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Motivation Paimon supports Nessie catalog（https://projectnessie.org/nessie-latest/） ### Solution _No response_ ### Anything else? _No response_...

sunxiaojian

[Flink]Supports SQLServer cdc

9

### Purpose Linked issue: close (https://github.com/apache/incubator-paimon/issues/2399) Add SQLServer cdc connector

sunxiaojian

[core] support PartitionKeyVisitor

1

### Purpose Linked issue: close #xxx ### Tests ### API and Format ### Documentation

YannByron