CODEWITHSUNDEEP
streamapache-flink
Eranga Heshan
Eranga Heshan

Reputation: 5804

Enforce an operation to run in an exact host in flink

I need the source and output streams of my flink job to run inside the same node. Is there a way to do it?

Upvotes: 1

Views: 133

Answers (1)

gior91
gior91

Reputation: 1775

There is a way to do it in Flink (> 1.0.0).

Check this link DataStream API - Task Chaining. In particular you can use the slotSharingGroup() API.

This will enable co-location of operators which do exactly what you want.

Upvotes: 1

Related Questions