ouyangwulin
ouyangwulin
@functicons ， Under my tests，When use 'taskmanager.memory.process.size' in flinkProperties, the 'taskmanager.heap.size' will set as "taskmanager.memory.flink.size", "taskmanager.memory.process.size" - "taskmanager.memory.flink.size" = "metaspace"+ "overhead" in doc [](https://ci.apache.org/projects/flink/flink-docs-release-1.10/ops/memory/mem_setup.html#configure-total-memory) ,and It will case something wrong,...
- 'taskmanager.memory.flink.size' is not specified, use the configured deprecated task manager heap value (5.625gb (6039797760 bytes)) for it.
@functicons Can we support flinkVersion 1.10, then only support flinkVersion 1.9. And other version set properties accordingly. If you agree, I can working on this issue.
@elanv I think this issue is not difficult after we disscuss clearly.Do you agree We add flinkVersion ,and support only < flink 1.9 or 1.10 , and other version user...
Ok I will commit this feature tommorrow.
@functicons I have push to my own branch, not do pr. because I don't have enougph test.
I have try to use zk for ha. but it always error: `Caused by: org.apache.flink.runtime.rest.util.RestClientException: [Internal server error., ] at org.apache.flink.runtime.rest.RestClient.parseResponse(RestClient.java:389) at org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$3(RestClient.java:373) at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:966) at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940) at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:456) at...
1.add flink properties : ``` high-availability: zookeeper high-availability.zookeeper.quorum: IP:2181, high-availability.storageDir: hdfs://Test/user/HA/ high-availability.cluster-id: "123" high-availability.jobmanager.port: "6123" high-availability.zookeeper.path.root: /flink-k8s restart-strategy: failure-rate restart-strategy.failure-rate.max-failures-per-interval: "5000" restart-strategy.failure-rate.failure-rate-interval: 6 min restart-strategy.failure-rate.delay: 1 s ``` 2. start...
Can we edit the job as detach mode replace now attach mode?
I fixed it by add flink properties.