JennyChen

Support deserializing json in kafka source

5

Currently Kafka Source only support StringDeserializer, we have to use some special character to identify a vertex or edge, something like this. ``INSERT INTO dy_modern.person(id, name) SELECT cast(trim(split_ex(t1, ',', 0))...

[FEATURE] Support Kafka Metrics Report in JsonReporterService

1

### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) ### Search before asking - [X] I have searched in the [issues](https://github.com/apache/kyuubi/issues?q=is%3Aissue) and found no...

## Why are the changes needed? Close #138. ## Brief change log - End2End test case for clickhouse connector ## How was this patch tested? - [ ] Add some...

[Bug] aggregation options are not verified when executing DDL

3

### Purpose Linked issue: close #5079 validate aggregation functions that doesn't exists before creating sink and source, instead of throw exception when insert and reading data ### Tests PreAggregationITCase.NotExistAggregationFunctionITCase PartiallUpdateITCase.testSequenceGroupWithNotExistAgg...

[Bug] aggregation options are not verified when executing DDL

5

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version master : [7f01330] ### Compute Engine Flink ### Minimal reproduce step Basically...

### Search before asking - [x] I searched in the [issues](https://github.com/apache/paimon/issues) and found nothing similar. ### Paimon version master ### Compute Engine Flink 1.18 ### Minimal reproduce step 1. create...

This closes https://issues.apache.org/jira/browse/FLINK-38110 When there's column name in Chinese in PG tables, Postgresql connector with pgoutput plugin will decode them as garbled characters, especially during incremental capure. The reason is...