How many Eventhubs partitions are you reading from?

Only 1 partition.

Check your Ganglia UI to check your cluster utilization

Prcture.1

What's the time it takes to write the data to the sink?

Prcture.2

​

I found that no matter how much setMaxEventsPerTrigger the numInputRow is 1000.

Can't finish writing in 1 second， which causes a delay for the next write， so event hubs' outgoing bytes are Low.

if I can set numInputRow to exceed 1000， I think the question can resolve.

Event​Hubs is in Prcture3.

​

​

​