Hi!
The Blob server runs on the JobManager and is used to distribute JAR files.
The best way to handle this scale is the following:
Option (1) Use the 1.2-SNAPSHOT version to run Flink on YARN, it will add
the JAR files to the Job's YARN resources - so no BLOBs need to be fetched.
Option (2)
Hi, all
I use Flink DataSet API to do some batch job, read some log then group and
sort them. Our cluster has almost 2000 servers, we get used to use
traditional MR job, then I tried Flink to do some experiment job, but I
counter this error and can not continue, does anyone can help with it?
Our