How can I build the flink docker image from source code?

2021-08-19 Thread Chenyu Zheng
Hi contributors, I’ve changed a little bit code in flink, and want to build a docker image to test it. Could you tell me how can I build the image from source code? Thx!

Re: Flink 1.12.5: The heartbeat of JobManager/TaskManager with id xxx timed out

2021-08-10 Thread Chenyu Zheng
akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [flink-dist_2.11-1.12.5.jar:1.12.5] Caused by: java.util.concurrent.TimeoutException: The heartbeat of JobManager with id 1da1bb0693814dd8cc2549e4f5cd368a timed out. ... 27 more From: Chenyu Zheng Date: Tuesday

Flink 1.12.5: The heartbeat of JobManager/TaskManager with id xxx timed out

2021-08-10 Thread Chenyu Zheng
Hi there, I’m trying to run my flink job on Kubernetes cluster, but when I try to give my job a larger parallelism (128) I get an error said “java.util.concurrent.TimeoutException: The heartbeat of JobManager with id 56ad1a5ded99f9f16ec1c786ad299159 timed out.” And then my job is cancelled. We

Flink v1.12.2 Kubernetes Session Mode cannot mount log4j.properties in configMap

2021-06-19 Thread Chenyu Zheng
e some guide or support? Thanks so much! BRs. Chenyu Zheng