minchowang

**Describe the bug(Please use English)** In using MacBook of m1 chip to run UT, the docker image could not pull. **Environment :** - Flink version : - Flink CDC version:...

yarn队列default中没有找到运行的任务，实际上job是正常运行的

2

[Job has been submitted with JobID] 解析得到的appId是:ac0a931b5aecab0f5365ab05f6ca42b3 Job has been submitted with JobID ac0a931b5aecab0f5365ab05f6ca42b3 job-submitted-success:ac0a931b5aecab0f5365ab05f6ca42b3 rs=0 BizException(code=00000, errorMsg=yarn队列default中没有找到运行的任务 name=flink@test) （重要）请登陆服务器分别查看下面两个目录下的错误日志10.49.0.143 web系统日志目录（web日志）：/data1/flink-streaming-platform-web/logs/error.log flink提交日志目录（flink客户端日志：/data1/flink/flink-1.12.2/log/) 启动结束时间: 2021-06-09 18:06:01 ######启动结果是 失败##############################

## What changes were proposed in this pull request Issue Number: close #3501 ## Brief change log ## Verifying this change This change is a trivial rework / code cleanup...

### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### Java Version 1.8 ### Scala Version 2.12.x ### StreamPark Version 2.1.2 ###...

[postgresql] Fix debezium-postgresql data loss

3

fixed: https://github.com/ververica/flink-cdc-connectors/issues/1893

[mysql][Improvement] Use debezium SPI way converter data types output.

3

Use debezium SPI way to improve common data types output by JsonDebeziumDeserializationSchema.

[mysql] Fix use latest-offset mode during caused add newly table not …

3

…to be capture. fiexs: #1184

org.apache.flink.api.java.typeutils.TypeExtractor [] - Class class com.starrocks.connector.flink.table.sink.StarRocksSinkRowDataWithMeta cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the...

JSON column cant use the string type to write

1

### Describe the bug When we use the `ps.setString("json_val")` insert JSON column to the clickhouse server, we will have the below error. because the jdbc-diver uses `select * from the...