cancel
Showing results forย 
Search instead forย 
Did you mean:ย 
Data Engineering
Join discussions on data engineering best practices, architectures, and optimization strategies within the Databricks Community. Exchange insights and solutions with fellow data engineers.
cancel
Showing results forย 
Search instead forย 
Did you mean:ย 

I have a streaming aggregation query with highly variable micro-batch processing times. Seeing a lot of GC pauses in the logs . Any pointers on how to debug ?

sajith_appukutt
Honored Contributor II

Though the data volume is relatively even, the  streaming aggregation query is showing highly variable micro-batch processing times

1 ACCEPTED SOLUTION

Accepted Solutions

sajith_appukutt
Honored Contributor II

By default, the state data (streaming aggregation query) is maintained in the JVM memory of the executors and large number of state objects could put memory pressure on the JVM causing high GC pauses. If you have stateful operations in your streaming query, it is recommended to use a more optimized state management solution based on RocksDB.

More details at https://docs.databricks.com/spark/latest/structured-streaming/production.html#optimize-performance-o...

View solution in original post

1 REPLY 1

sajith_appukutt
Honored Contributor II

By default, the state data (streaming aggregation query) is maintained in the JVM memory of the executors and large number of state objects could put memory pressure on the JVM causing high GC pauses. If you have stateful operations in your streaming query, it is recommended to use a more optimized state management solution based on RocksDB.

More details at https://docs.databricks.com/spark/latest/structured-streaming/production.html#optimize-performance-o...

Join Us as a Local Community Builder!

Passionate about hosting events and connecting people? Help us grow a vibrant local communityโ€”sign up today to get started!

Sign Up Now