due to the current version, it seems that flink does not support dynamic scaling,. If you need to increase resource allocation, you must first stop the running job. Currently I have a flink job that is used to consume data from kafka topic and then sink ...
Environment 2 machines, 203204 plans to run jobmanager and taskmanager on each of these two machines. master hz203:9081 hz204:9081 slaves hz203 hz204 flink-conf.yaml jobmanager.rpc.port: 6123 rest.port: 9081 blob.server.port: 6124 query.se...
I have a few questions about using flink, just now. I would like to ask all of you to help me. flink how to initialize spring context flink how to use scheduled tasks @ codecraft @ Ali Yunqi Community @ Fan Xuan Thank you ...