Search before asking

• I had searched in the issues and found no similar issues.

What happened

use seatunnel sync es data
the source is es
the sink is console
when submit batch job more time,the jobmanager heap oom

SeaTunnel Version

the version is 2.3.5

SeaTunnel Config

env {
  execution.parallelism = 1
  job.mode = "BATCH"
  job.name = es-demo
}

source {
	
	  Elasticsearch {
		
	  }
    
}

transform {
 
}

sink {
	  Console {
		
		
	  }
   
  
}

Running Command

Execute SeaTunnel Flink Job: ${FLINK_HOME}/bin/flink run -c org.apache.seatunnel.core.starter.flink.SeaTunnelFlink /opt/seatunnel/starter/seatunnel-flink-15-starter.jar --config

Error Exception

the flink jobmanager heap oom

Zeta or Flink or Spark Version

flink version is 1.16.3

Java or Scala Version

open jkd 11

Screenshots

Are you willing to submit PR?

• Yes I am willing to submit a PR!

Code of Conduct

• I agree to follow this project's Code of Conduct