Help Center/ MapReduce Service/ Component Operation Guide (LTS)/ Using Hive/ Common Issues About Hive/ What Do I Do If Error Message "Not expecting to handle any events" Is Displayed When the Tez Engine Is Used to Execute Hive SQL Tasks?
Updated on 2025-04-15 GMT+08:00

What Do I Do If Error Message "Not expecting to handle any events" Is Displayed When the Tez Engine Is Used to Execute Hive SQL Tasks?

Question

When the Tez engine is used to execute Hive SQL tasks in MRS 3.5.1 or later, some queries fail and the following information is included in the displayed error message:
Error: Error while processing statement: FAILED: Execution Error, return code 2 from org.apache.hadoop.hive.ql.exec.tez.TezTask. Vertex failed, vertexName=Map 4, vertexId=vertex_1742299541057_0014_1_02, diagnostics=[Vertex vertex_1742299541057_0014_1_02 [Map 4] killed/failed due to:ROOT_INPUT_INIT_FAILURE, Vertex Input: $hdt$_0:$hdt$_0:$hdt$_0:store_returns initializer failed, vertex=vertex_1742299541057_0014_1_02 [Map 4], java.lang.UnsupportedOperationException: Not expecting to handle any events
	at org.apache.tez.mapreduce.common.MRInputAMSplitGenerator.handleInputInitializerEvent(MRInputAMSplitGenerator.java:192)
	at org.apache.tez.dag.app.dag.RootInputInitializerManager$InitializerWrapper.sendEvents(RootInputInitializerManager.java:521)
	at org.apache.tez.dag.app.dag.RootInputInitializerManager$InitializerWrapper.onTaskSucceeded(RootInputInitializerManager.java:471)
	at org.apache.tez.dag.app.dag.StateChangeNotifier.taskSucceeded(StateChangeNotifier.java:295)
	at org.apache.tez.dag.app.dag.impl.TaskImpl$TaskStateChangedCallback.onStateChanged(TaskImpl.java:1458)
	at org.apache.tez.dag.app.dag.impl.TaskImpl$TaskStateChangedCallback.onStateChanged(TaskImpl.java:1442)
	at org.apache.tez.state.StateMachineTez.doTransition(StateMachineTez.java:68)
	at org.apache.tez.dag.app.dag.impl.TaskImpl.handle(TaskImpl.java:842)
	at org.apache.tez.dag.app.dag.impl.TaskImpl.handle(TaskImpl.java:114)
	at org.apache.tez.dag.app.DAGAppMaster$TaskEventDispatcher.handle(DAGAppMaster.java:2193)
	at org.apache.tez.dag.app.DAGAppMaster$TaskEventDispatcher.handle(DAGAppMaster.java:2180)
	at org.apache.tez.common.AsyncDispatcher.dispatch(AsyncDispatcher.java:195)
	at org.apache.tez.common.AsyncDispatcher$1.run(AsyncDispatcher.java:115)
	at java.base/java.lang.Thread.run(Thread.java:840)

Answer

You can run the set hive.tez.dynamic.partition.pruning=false; command on the Hive client to disable dynamic partition pruning and execute related Hive SQL tasks again.