Hi
I encounter the same problem for the Kinesis producer and will try to play
around with the config setting and look into the code base. If I figure it out
l let you know and please do the same if you figure it out before me
Med venlig hilsen / Best regards
Lasse Nedergaard
> Den 27. apr. 20
Hi,
Hope this is the right place to ask, but I have a 5 Raspberry Pi 3 cluster
running Flink on which I’m hitting memory issues. Each Pi has 1Gb and is
running with a 256Gb USB drive, however I don’t seem to be able to configure
Java to use more than 256M of heap. The memory problem, I’m reason
The TaskManager cannot reach the JobManager. I get this error. Any ideas?
Caused by:
org.apache.flink.runtime.client.JobClientActorConnectionTimeoutException:
Lost connection to the JobManager.
Best,
Max
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
Hi!
Thank you for pinging us on this one - I left a comment, after that I would
merge the PR.
The Flink community had a bit of a slow phase for PRs, with many committers
being at the Flink Forward Conference, being involved in the 1.5 release
testing.
We plan to speed up reviews again now.
Thank
Hi all,
I need to send a request to an external web service and then store the
response in a DB table, and I am wondering how people have approached this
or similar problems in the past.
The flow is: Kafka source (msgs only every few seconds) => filter/map
operators => result sent to web service
Hi, I have an Flink .jar file and I submit it on yarn cluster using the
command:
flink run -m yarn-cluster -yn 5 -yjm 768 -ytm 1400 -ys 2 -yqu streamQ
my_program.jar
According to the submitting command I expect:
// It will create 5 containers > satisfied
// each container should use 2 core -
Hi,
You have to enable CPU scheduling in YARN, otherwise it always shows
that only 1 CPU is allocated for each container,
regardless of how many Flink try to allocated.
TaskManager memory is 1400MB, but Flink reserves some amount for for
off-heap memory, so the actual heap size is smaller.
Hi Nicholas,
Try reducing
containerized.heap-cutoff-min
from the default 600MB to a lower number.
Still, I think RPi is way too under-powered to run any serious Flink apps.
Regards,
Kien
On 4/28/2018 4:38 PM, Nicholas Walton wrote:
Hi,
Hope this is the right place to ask, but