ouyangwulin

Support classpath files

7

Flink command like this“-C,--classpath ” ` -C,--classpath Adds a URL to each user code classloader on all nodes in the cluster. The paths must specify a protocol (e.g. file://) and...

When flink version >= 1.10 , the "taskmanager.heap.size" is not work.

19

We have calcute flink memory use "tmMemoryOffHeapRatio" and "tmMemLimitByte' in operator, But it is not work for flink 1.10. flink 1.10 use "taskmanager.memory.process.size" to limit the flink memory. If we...

[Feature] We need to keep the state of the jobs on the cluster consistent with the state of the jobs on the platform

1

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description 1. Synchronize the job status when the k8s/yarn cluster is...

Out of use #3318

[FLINK-34901][connectors/jdbc]Update clause must EXCLUDED unique index.

4

As docs 'https://www.postgresql.org/docs/current/sql-insert.html', when we use ON CONFLICT, Update clause must EXCLUDED unique index. Or it will throw exceptions.like " modification of distribution columns in OnConflictUpdate is not supported Call...

[FLINK-35354] Support host mapping in Flink tikv cdc

5

In tidb production environment deployment, there are usually two kinds of network: internal network and public network. When we use pd mode in tikv, we need to do network mapping,...

### 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.18 ### Scala Version 2.12.x ### StreamPark Version 2.1.4 ###...

### Search before asking - [X] I had searched in the [feature](https://github.com/apache/incubator-streampark/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description Improve user experience and optimize job development methods ### Usage...

## Bug Report ### 1. Describe the bug When I start tikv cluster with version 6.9.3 in docker, throw bugs: failed to get member from pd server from http://pd0:2392, caused...